iris-bi-agent

iris-bi-agent

Enables verifiable business intelligence over federated data sources, supporting semantic queries, drill-down to source rows, and raw SQL with explicit verification status.

Category
访问服务器

README

Iris — verifiable BI over federated data

A business user asks a question, gets a number, and decides on it. Usually nobody in that loop — not the user, not the analyst, not the system itself — can tell whether the number came from the data or from the model's imagination.

Iris is an attempt at the other thing: a number you can open.

Q: Tip rate for card payments by borough on rainy versus dry days

  Manhattan  dry   23.54%      ← click it
  Manhattan  wet   23.62%

  displayed 23.54  ·  recomputed from these rows 23.54  ·  ✓ agrees
  3,979,472 contributing rows (card-paid, positive fare)
    fare=13.27  tip=2.00  pickup=2024-01-27 00:38  file=yellow_tripdata_2024-01.parquet

Three sources, three engines, two joins, one question — and a receipt.

Iris architecture — one question, stage by stage

Regenerate with .venv/bin/python scripts/make_architecture_gif.py; the row counts are read from data/load_manifest.json, so the diagram cannot drift from the data.


Three claims, and the evidence for each

1. The model cannot invent a metric. It never writes SQL. It emits a SemanticQuery naming measures and dimensions from a declared manifest; anything else is rejected before execution, with the valid names in the error. A deterministic compiler turns the validated struct into SQL. → semantic/, tests/test_planner_fake_llm.py

2. Every number opens into its source rows. Click a figure and Iris returns the rows behind it — each naming the vendor file it came from — plus the measure recomputed over exactly those rows. If the two disagree, it says so. → verify/drilldown.py

3. The evaluation can measure things the agent's own machinery can't express. Ground truth is hand-written SQL against the raw views, so a case is not limited to the shapes the system already handles. → eval/fixtures/

Where those claims stop is in Limitations, and the scoring method is in docs/eval_methodology.md.


Numbers

Current run — eval/results/latest.json, 15 cases × 3 runs:

Category Result What it means
in_manifest 5/5 clean, 100% questions phrased the way the manifest phrases things
held_out 4/4 clean, 100% questions whose key terms are absent from the manifest
ambiguous 2/2 clean, 100% correct behaviour is to ask, not answer
adversarial 4/4 clean, 100% unanswerable, injected, or empty
grounding 30/30 every figure in every summary appeared in its table

p50 3.4s, $0.35 for all 45 runs. 124 tests, of which 79 need no database, no services and no API key — including the ones covering the no-fabrication guarantee.

Never quote a single-run number from this harness: planning is an LLM call and is not deterministic. Use --repeat; a case that passes sometimes is reported as FLAKY with its rate rather than resolved by whichever way the dice fell.


Data — three independent origins

Source Origin Lands in Rows
Yellow-taxi trips, 2024 Q1 NYC TLC Parquet ("the lake") 9,554,778
Taxi zone lookup NYC TLC PostgreSQL 265
GHCN-Daily weather, 4 stations NOAA MongoDB 5,204

Nobody designed these to fit together, so their seams are real. Six were measured and are catalogued in docs/join_hazards.md. The important one:

"What is the average tip rate?" has three defensible answers, 9.4 points apart — 17.60%, 22.39%, 27.00% — because cash fares never record a tip (1,330,105 trips, 13.92%, 100% zero-tip). Iris does not pick one. The manifest declares the ambiguity and the agent asks.

Runner-up: NOAA publishes tenths, so a naive loader reports TMAX=83 as 83 °C for a New York January. Plausibly typed, never errors, poisons every aggregate downstream.


Quick start

python3.12 -m venv .venv
.venv/bin/python -m pip install -r requirements.txt
( cd ui && npm install )

cp .env.example .env          # set ANTHROPIC_API_KEY
./run.sh load                 # download + load all three sources (~215 MB, one-off)
./run.sh                      # UI :9300 · API :9301 · MCP :9302

Requires Python 3.12+, Node 18+, a local PostgreSQL, and Docker (for Iris's own MongoDB on 27018 — it will not write into a container it does not own). run.sh refuses to start on a bound port and prints who holds it. See docs/local_setup.md.

.venv/bin/python -m pytest tests/ -q          # 124 tests
.venv/bin/python -m eval.harness --repeat 3   # the eval (needs data + a key)

How it works

   question
      │
      ▼
  ┌─────────┐  sees only declared measures and dimensions — never a column
  │  plan   │  emits SemanticQuery  ────────► clarify   (declared ambiguity)
  └────┬────┘                        └──────► refuse    (nothing can answer it)
       │ validated struct
       ▼
  ┌──────────┐  deterministic. Rejections go back to the planner verbatim, once.
  │ compile  │  join-path resolution · fan-out refusal · per-measure FILTER
  └────┬─────┘
       ▼
  ┌──────────┐   DuckDB: Parquet natively · Postgres ATTACH · Mongo → Arrow
  │ execute  │
  └────┬─────┘
       ▼
  ┌──────────┐   join match rates · sentinel impact · drill-down
  │  verify  │
  └────┬─────┘
       ▼
  ┌──────────┐   every numeral must appear in the table, or it is rewritten
  │ narrate  │
  └──────────┘

The manifest is the contract. semantic/manifest.yaml declares sources, entities, joins with cardinality, dimensions with sentinel values, measures with their populations, and ambiguity groups. Unit conversions and metric definitions live there and nowhere else.

Fan-out is refused, not hoped away. Aggregating across a one-to-many join multiplies every additive measure. The compiler checks join direction and declines. A test builds the unsafe weather join by hand and shows the exact 4× inflation it would have produced.

Portability is tested, not asserted. tests/test_portability.py takes an unrelated dataset (library lending), supplies only data and a manifest, and gets correct hand-computable answers. Zero dataset references survive in executable code across federation/ and semantic/; seven remain in docstrings, where they are explaining a hazard rather than driving behaviour. A test tokenises both packages and holds that number, so a stray if borough == cannot appear unnoticed.

Two honest edges on that claim. The foreign dataset is Parquet-only, so it demonstrates dataset portability — a new schema, new manifest, unchanged code — not engine portability; a second Postgres or Mongo deployment is not spun up in tests. And "adding an engine is one class with three methods plus a registry line" is a structural fact about federation/connectors/factory.py, not something a test proves end-to-end; what is tested is that an unknown engine fails with a message naming the three methods.

MCP is an external surface. describe_semantic_model, query_semantic (verified), drill_down, and run_sql — the last returning verified: false with a warning naming what it bypassed. The agent itself talks to the engine in-process.


Limitations, owned not buried

The eval validates the compiler, not the definitions. Reference SQL checks that Iris computes what the manifest declares. If avg_tip_rate_card is declared wrongly, the fixture written to match it is wrong the same way. That is exactly why the tip-rate case is a clarify case rather than an answer case — the choice of definition is put to the user, not graded against one.

run_sql has none of the guarantees. It exists for the long tail the manifest doesn't cover. Results carry verified: false and the UI badges them. Anything through that path is ordinary text-to-SQL.

Two of the three sources are live; MongoDB is a snapshot. Parquet is read from disk per query and Postgres is ATTACHed, so both reflect the current state. The Mongo collection is materialised into Arrow once at startup — a document written afterwards is invisible until refresh() or a restart. That is a deliberate choice for a cached third-party feed of 5,204 station-days, not a limit of the bridge, but "federated across three engines" should not be read as "three live connections." tests/test_federation.py proves the boundary by writing to MongoDB and asserting the view does not move.

Pushdown is narrower than federation demos usually imply. Every connector reports only filter and project, and only where EXPLAIN confirms it below the scan node. Joins and aggregates always run in DuckDB. An earlier version of these connectors claimed join and aggregate pushdown; the query plan did not support it, and the test now pins each claim to a real plan.

15 cases is small. All four categories at 100% over 3 runs means no failures observed in 45 runs, not proven correct. Earlier single runs did show flaky failures — that is why --repeat exists and why FLAKY is a distinct verdict.

The planner sees the whole manifest. Fine at 10 measures and 11 dimensions; at hundreds this needs retrieval rather than dumping everything into the prompt. That is the first thing that breaks at scale.

Held-out is a vocabulary test, not a reasoning test. It proves the planner maps unfamiliar wording onto declared names. It does not prove it would handle a genuinely novel analytical shape.

Single dataset. Portability is demonstrated on a synthetic second dataset in tests, not on a second production-scale one.


Layout

semantic/     manifest.yaml (the contract) · model · query + validation · compiler
federation/   DuckDB engine + per-ENGINE connectors, built from the manifest
verify/       provenance · drilldown · grounding
agent/        planner (LLM → SemanticQuery) · graph (3 terminal states) · llm
eval/         cases · scorer · harness · fixtures/*.sql (hand-written ground truth)
data_pipeline/  the three loaders — load faithfully, filter in the semantic layer
api/ ui/      FastAPI + Next.js dashboard and Trace Inspector
toolserver/   MCP server (external clients)
docs/         join_hazards · design_decisions (ADRs) · eval_methodology · local_setup

Built with Claude (Sonnet 5 planning, Haiku 4.5 narration) · DuckDB · LangGraph · MCP · FastAPI · Next.js.

推荐服务器

Baidu Map

Baidu Map

百度地图核心API现已全面兼容MCP协议,是国内首家兼容MCP协议的地图服务商。

官方
精选
JavaScript
Playwright MCP Server

Playwright MCP Server

一个模型上下文协议服务器,它使大型语言模型能够通过结构化的可访问性快照与网页进行交互,而无需视觉模型或屏幕截图。

官方
精选
TypeScript
Audiense Insights MCP Server

Audiense Insights MCP Server

通过模型上下文协议启用与 Audiense Insights 账户的交互,从而促进营销洞察和受众数据的提取和分析,包括人口统计信息、行为和影响者互动。

官方
精选
本地
TypeScript
Magic Component Platform (MCP)

Magic Component Platform (MCP)

一个由人工智能驱动的工具,可以从自然语言描述生成现代化的用户界面组件,并与流行的集成开发环境(IDE)集成,从而简化用户界面开发流程。

官方
精选
本地
TypeScript
VeyraX

VeyraX

一个单一的 MCP 工具,连接你所有喜爱的工具:Gmail、日历以及其他 40 多个工具。

官方
精选
本地
Kagi MCP Server

Kagi MCP Server

一个 MCP 服务器,集成了 Kagi 搜索功能和 Claude AI,使 Claude 能够在回答需要最新信息的问题时执行实时网络搜索。

官方
精选
Python
graphlit-mcp-server

graphlit-mcp-server

模型上下文协议 (MCP) 服务器实现了 MCP 客户端与 Graphlit 服务之间的集成。 除了网络爬取之外,还可以将任何内容(从 Slack 到 Gmail 再到播客订阅源)导入到 Graphlit 项目中,然后从 MCP 客户端检索相关内容。

官方
精选
TypeScript
Exa MCP Server

Exa MCP Server

模型上下文协议(MCP)服务器允许像 Claude 这样的 AI 助手使用 Exa AI 搜索 API 进行网络搜索。这种设置允许 AI 模型以安全和受控的方式获取实时的网络信息。

官方
精选
mcp-server-qdrant

mcp-server-qdrant

这个仓库展示了如何为向量搜索引擎 Qdrant 创建一个 MCP (Managed Control Plane) 服务器的示例。

官方
精选
e2b-mcp-server

e2b-mcp-server

使用 MCP 通过 e2b 运行代码。

官方
精选