架构

FluxMeter 负责计量与归因 AI 用量。它不是完整的开票、CRM 或数仓平台。

非目标包括替代你的计费系统、编造获客指标，以及在本站发布无证据的性能声明。

唯一支持路径：SDK/Gateway → HTTP Custody → Kafka 确认 → Flink 计费与聚合 → Redis 查询状态 → Usage API。

make demo 启动此栈。HTTP ingest 在 Kafka 确认后才返回 202；Kafka 不可用时返回可重试 503。Flink 是计费与聚合引擎。ClickHouse 可作为审计冷存 — 不是计费真相。

Gateway 编排：estimate → gate → reserve → upstream → Custody，并用 Redis outbox 做耐久交接。

无论经 SDK 还是 Gateway 进入，Usage API 表面相同。Intelligence 仍是建立在计量汇总上的启发式次要层。

写入使用 camelCase 字段，如 customerId、modelId、inputTokens、outputTokens。

用量查询返回 snake_case 明细，如 customer_id、period、tokens、cost_usd。

权威顺序：写入 → 计价 → 归因 → 控制（可选）→ 导出（可选）。

计价使用模型目录价；归因写入客户级账本明细。

可选预付费控制：调用前 check，流式预估 reserve，token 确定后 reconcile。

这些 API 与计量并列 — 产出用量明细并不强制依赖它们。

去重依赖应用边界上的稳定事件标识。

交付按应用级 effectively-once 理解 — 不宣称更强的无证据 sink 保证。

运维自行决定网关与预算失败如何向调用方呈现（阻断 vs 软失败）。

演示环境可能关闭鉴权；对公网暴露必须启用 API Key。

受支持栈始终包含 HTTP Custody、Kafka 与 Flink — 运维成本是唯一客户事件路径的固有部分。

本地 HTTP 测得（291.20 / 14,006.89 events/s）有环境限定，不是产品保证；10K/100K 发布门槛仍未达到。见引擎压测文档。

身份映射、价目维护、计费产品选择与生产鉴权姿态仍由你负责。

收入叠加与 Intelligence API 是计量数据上的启发式助手 — 不是财务系统的权威账本。