📊 Dashboard

341
MCP Tools
--
Projects
--
Workflow Steps
--
Version

Recent Activity

TimestampToolStatus
Loading...

Quick Start

Get started with DataBridge AI:

📡 Agent Communication Console

Communication Stream
[--:--:--.---] SYSTEM
Agent Communication Console initialized. Ready to process requests. Type a query below or use Quick Actions.

Session Stats

0
Messages
0
Agents

Active Agents

🎯 Orchestrator
🔍 Cortex Analyst
🏗️ Hierarchy Builder

Quick Actions

🔧 Tool Workbench

Available Tools

  • Loading tools...

Select a Tool

Choose a tool from the list to configure and run it.

Output

// Tool output will appear here

📁 Hierarchy Projects

Projects

  • Loading projects...

Select a Project

Choose a project from the list to view its details.

⚡ Workflow Editor

Tool Palette

    Workflow Steps

    Click tools to add steps to your workflow.

    ✈️ Wright Pipeline Builder

    Build hierarchy-driven data marts with the 4-object pipeline pattern. Configure each step and preview generated SQL.

    Pipeline Configuration

    VW_1: Translation View

    Translates ID_SOURCE column values to physical database columns using CASE statements.

    -- Click "Generate" to create VW_1 Translation View SQL

    DT_2: Granularity Table

    UNPIVOT operation to normalize data and apply exclusion filters.

    -- Click "Generate" to create DT_2 Granularity Table SQL

    DT_3A: Pre-Aggregation Fact

    UNION ALL branches for different join patterns. Each branch handles different dimension combinations.

    -- Click "Generate" to create DT_3A Pre-Aggregation SQL

    DT_3: Final Data Mart

    Final data mart with formula precedence cascade and surrogate key generation.

    -- Click "Generate" to create DT_3 Data Mart SQL

    ⚙️ Administration

    Configuration

    📚 Documentation & Help

    DataBridge AI v0.39.0

    A headless, MCP-native data reconciliation engine with 341 MCP tools across twenty major modules.

    Core Capabilities

    🔄 Data ReconciliationCompare and validate data from CSV, SQL, PDF, JSON sources
    🏗️ Hierarchy BuilderCreate and manage multi-level hierarchy projects (up to 15 levels)
    🧠 Cortex AISnowflake Cortex integration with natural language to SQL
    📊 Wright ModuleHierarchy-driven data mart generation with 4-object pipeline
    📚 Data CatalogCentralized metadata registry with business glossary
    🔍 Lineage TrackingColumn-level lineage and impact analysis
    ✅ Data QualityExpectation suites and data contracts
    🔧 dbt IntegrationGenerate dbt projects from hierarchies

    Quick Start

    # Install from PyPI pip install databridge-ai # Run as MCP Server python -m src.server

    Architecture

    graph TD A[Claude/LLM Client] --> B[MCP Protocol] B --> C[DataBridge MCP Server] C --> D[Hierarchy Builder] C --> E[Data Reconciliation] C --> F[Cortex AI Agent] C --> G[Wright Module] D --> H[(Snowflake)] E --> I[(CSV/SQL/PDF)] F --> H G --> H

    Tool Categories (341 Tools)

    📂 File Discovery & Staging (3 tools)

    find_files stage_file get_working_directory

    🔄 Data Reconciliation (38 tools)

    load_csv load_json query_database profile_data compare_hashes fuzzy_match_columns extract_text_from_pdf ocr_image merge_sources

    🏗️ Hierarchy Builder (44 tools)

    create_hierarchy_project create_hierarchy add_source_mapping import_hierarchy_csv export_hierarchy_csv generate_hierarchy_scripts push_hierarchy_to_snowflake

    🧠 Cortex AI (25 tools)

    cortex_complete cortex_summarize cortex_sentiment cortex_reason analyst_ask create_semantic_model

    📊 Wright Module (18 tools)

    create_mart_config generate_mart_pipeline discover_hierarchy_pattern validate_mart_pipeline

    📚 Data Catalog (15 tools)

    catalog_create_asset catalog_search catalog_create_term catalog_scan_connection

    🔍 Lineage & Impact (11 tools)

    track_column_lineage analyze_change_impact export_lineage_diagram

    Available Templates (20 Templates)

    Accounting Domain

    Template IDNameIndustry
    standard_plStandard P&LGeneral
    standard_bsStandard Balance SheetGeneral
    oil_gas_losOil & Gas LOSOil & Gas
    upstream_oil_gas_plUpstream Oil & Gas P&LOil & Gas - E&P
    manufacturing_plIndustrial Manufacturing P&LManufacturing
    saas_plSaaS Company P&LSaaS

    Operations Domain

    Template IDNameIndustry
    geographic_hierarchyGeographic HierarchyGeneral
    department_hierarchyDepartment HierarchyGeneral
    upstream_field_hierarchyUpstream Field HierarchyOil & Gas
    fleet_hierarchyFleet & Route HierarchyTransportation

    Available Skills (7 Skills)

    Skill IDNameIndustriesCapabilities
    financial-analyst Financial Analyst General GL reconciliation, trial balance, bank rec, COA design
    fpa-oil-gas-analyst FP&A Oil & Gas Analyst Oil & Gas LOS analysis, JIB, reserves, hedge accounting
    manufacturing-analyst Manufacturing Analyst Manufacturing Standard costing, COGS, variances, inventory
    saas-metrics-analyst SaaS Metrics Analyst SaaS ARR/MRR, cohorts, CAC/LTV, unit economics
    transportation-analyst Transportation Analyst Transportation Operating ratio, fleet, lanes, driver metrics

    API Reference

    MCP Configuration (Claude Desktop)

    { "mcpServers": { "DataBridge_AI": { "command": "python", "args": ["-m", "src.server"] } } }

    Programmatic Usage

    from src.server import mcp # Run as MCP server mcp.run() # Or get tools list tools = await mcp.get_tools() print(f"Loaded {len(tools)} tools")

    Environment Variables

    VariableDescriptionDefault
    DATA_DIRData directory for projects./data
    NESTJS_BACKEND_URLNestJS backend URLhttp://localhost:8001
    NESTJS_API_KEYAPI key for backend-
    SNOWFLAKE_ACCOUNTSnowflake account-