参考 · 接口
API & 数据表
SQL Engine / ID-Mapping / Assistant 三服务完整接口目录(254+ 接口,24 个域)+ 调用约定 + 核心数据表。
调用约定
控制台全部经 Nginx 网关 :8080 访问;SQL Engine 的接口统一挂在 /api/* 前缀下(网关剥离 /api 后转发)。
| 服务 | 网关路径 | 直连端口 |
|---|---|---|
| SQL Engine(CDP 主体) | /api/* | :8002 |
| ID-Mapping(OneID) | /ID-Mapping/* | :8001 |
| 智能助手 Assistant | /assistant/* | :8004 |
- 多租户:几乎所有接口都需
tenant_id(路径参数或请求体),按租户强制隔离。 - 鉴权:先
POST /api/auth/login拿 token,后续请求携带;网关在 http 层统一注入鉴权头。 - 安全边界:圈人 / 查询永不直出 SQL —— 走模板(
/api/query/*)或 DSL 校验链(/api/dsl/*)。 - Swagger:SQL Engine · ID-Mapping(在线交互式文档,含请求/响应模型)。
快速上手示例
# 1) 登录拿 token
curl -X POST http://localhost:8080/api/auth/login \
-H "Content-Type: application/json" \
-d '{"email":"admin@acme.com","password":"demo123"}'
# 2) 模板查询:按 OneID 查画像宽表
curl -X POST http://localhost:8080/api/query/profile_by_one_id \
-H "Content-Type: application/json" \
-d '{"params":{"tenant_id":1001,"one_id":100001}}'
# 3) 自然语言查询
curl -X POST http://localhost:8080/api/nl-query \
-H "Content-Type: application/json" \
-d '{"question":"查手机号13800138001的用户画像","tenant_id":1001}'
# 4) DSL 圈人:校验 → 预估人数(不执行 SQL)
curl -X POST http://localhost:8080/api/dsl/estimate \
-H "Content-Type: application/json" \
-d '{"tenant_id":1001,"rule":{"object":"user","logic":"AND","conditions":[],"relations":[]}}'
# 5) 自然语言圈人 → 候选 DSL(已过校验层)
curl -X POST http://localhost:8080/api/agent/segment/draft \
-H "Content-Type: application/json" \
-d '{"question":"近30天下过单且客单价大于500的用户","tenant_id":1001}'
# 6) 渠道 → OneID 映射 / 合并日志(ID-Mapping)
curl http://localhost:8080/ID-Mapping/mapping/1001/phone/13900001111
curl http://localhost:8080/ID-Mapping/merge-log/1001
接口总览 · 共 254+ 接口 / 24 个域
下表为 SQL Engine / ID-Mapping / Assistant 三服务的完整接口目录。完整请求/响应模型见各服务 Swagger。
鉴权 Auth · 2 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /api/auth/login | 邮箱 + 密码登录,返回 token、用户与所属租户 |
| GET | /api/auth/me | 当前登录用户与租户上下文 |
查询与模板 Query · 5 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/health | 健康检查(含 NL 查询能力开关) |
| GET | /api/templates | 列出可用的命名模板查询 |
| POST | /api/query/{template_name} | 执行命名模板查询(参数绑定,绝不拼 SQL) |
| GET | /api/query/{template_name} | 同上,查询参数形式 |
| POST | /api/nl-query | 自然语言 → 模板查询(DeepSeek 意图识别) |
圈人 DSL(安全边界) · 4 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /api/dsl/validate | 校验 DSL 规则:字段 / 操作符 / 关系 / 跳数 |
| POST | /api/dsl/echo | DSL → 中文可读摘要 |
| POST | /api/dsl/compile | DSL → SQL(仅编译,不执行) |
| POST | /api/dsl/estimate | DSL 干跑 COUNT,预估人数 |
自然语言圈人 & 受众 · 5 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /api/agent/segment/draft | 自然语言 → 候选 DSL(已过校验层) |
| POST | /api/agent/segment/confirm | 人工确认后保存为受众 |
| POST | /api/segments | 保存受众 |
| GET | /api/segments/{tenant_id} | 受众列表 |
| GET | /api/segments/{tenant_id}/{segment_code} | 受众详情 |
群组 Groups · 10 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /api/groups | 创建用户群组 |
| POST | /api/groups/search | 搜索群组 |
| GET | /api/groups/{tenant_id} | 群组列表 |
| GET | /api/groups/{tenant_id}/{group_id} | 群组详情 |
| GET | /api/groups/{tenant_id}/code/{group_code} | 按编码取群组 |
| GET | /api/groups/{tenant_id}/{group_id}/members | 群组成员 |
| POST | /api/groups/{tenant_id}/{group_id}/members | 加入成员 |
| DELETE | /api/groups/{tenant_id}/{group_id}/members/{one_id} | 移除成员 |
| GET | /api/users/{tenant_id}/{one_id} | 用户画像 |
| GET | /api/users/{tenant_id}/{one_id}/groups | 用户所属群组 |
对象 Objects · 13 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/objects/meta | 对象注册表(对象 / 字段 / 关系矩阵) |
| POST | /api/objects/upsert | upsert 对象记录 |
| POST | /api/objects/relations | 建立对象关系 |
| POST | /api/objects/search | 跨对象多跳筛选查询 |
| GET | /api/metadata/{tenant_id}/fields | 可筛选字段元数据 |
| GET | /api/objects/{tenant_id}/definitions | 对象定义 |
| POST | /api/objects/create | 新建对象类型 |
| POST | /api/objects/{tenant_id}/relations | 新增关系定义 |
| DELETE | /api/objects/{tenant_id}/relations/{src_type}/{rel_type}/{dst_type} | 删除关系定义 |
| POST | /api/objects/{tenant_id}/{object_key}/fields | 新增字段 |
| PATCH | /api/objects/{tenant_id}/{object_key}/fields/{field_code} | 修改字段 |
| GET | /api/objects/{tenant_id}/{object_key}/{pk_value} | 记录详情 |
| GET | /api/objects/{tenant_id}/{object_key}/{pk_value}/relations | 记录的关联 |
ETL 导入 · 3 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /api/etl/preview | 字段映射 / 类型强转 / 校验预览 |
| POST | /api/etl/import | 导入到目标对象(可同时建关系) |
| POST | /api/users/import | 批量导入用户 |
统一 Unify · 14 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/unify/identity-rules/{tenant_id} | 身份解析规则 |
| POST | /api/unify/identity-rules/{tenant_id} | 新增 / 更新规则 |
| DELETE | /api/unify/identity-rules/{tenant_id}/{rule_id} | 删除规则 |
| GET | /api/unify/groups/{tenant_id} | 群组列表(Unify 视角) |
| POST | /api/unify/groups/{tenant_id}/{group_id}/refresh | 重算群组人数 |
| POST | /api/unify/sql-traits/{tenant_id} | 创建 SQL 特征 |
| GET | /api/unify/sql-traits/{tenant_id} | SQL 特征列表 |
| POST | /api/unify/sql-traits/{tenant_id}/{trait_id}/execute | 执行某 SQL 特征 |
| POST | /api/unify/sql-traits/{tenant_id}/execute | 执行全部 SQL 特征 |
| POST | /api/unify/predictions/{tenant_id} | 创建预测模型 |
| GET | /api/unify/predictions/{tenant_id} | 预测模型列表 |
| POST | /api/unify/predictions/{tenant_id}/{model_id}/infer | 推理打分 |
| POST | /api/unify/profiles/sync/{tenant_id} | 档案同步回数仓 |
| POST | /api/unify/objects/search | 带标签的对象检索 |
连接 Connections · 27 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/connections/sources | 数据源列表 |
| POST | /api/connections/sources | 创建数据源 |
| GET | /api/connections/sources/{source_id} | 数据源详情 |
| POST | /api/connections/sources/{source_id}/test | 连通性测试 |
| GET | /api/connections/sources/{source_id}/events | 数据源事件流 |
| POST | /api/connections/events/track | 上报事件 |
| GET | /api/connections/destinations | 目的地列表 |
| POST | /api/connections/destinations | 创建目的地 |
| GET | /api/connections/destinations/{destination_id} | 目的地详情 |
| POST | /api/connections/destinations/{destination_id}/test | 测试目的地 |
| POST | /api/connections/destinations/{destination_id}/mappings | 保存字段映射 |
| GET | /api/connections/reverse-etl/jobs | Reverse ETL 任务列表 |
| POST | /api/connections/reverse-etl/jobs | 创建 Reverse ETL 任务 |
| GET | /api/connections/reverse-etl/jobs/{job_id}/runs | 运行记录 |
| POST | /api/connections/reverse-etl/jobs/{job_id}/run-now | 立即运行 |
| POST | /api/connections/reverse-etl/runs/{run_id}/complete | 运行完成回调 |
| GET | /api/connections/warehouses | 数据仓库列表 |
| POST | /api/connections/warehouses | 连接数仓 |
| POST | /api/connections/warehouses/{warehouse_id}/sync | 触发同步 |
| GET | /api/connections/functions | Functions 列表 |
| POST | /api/connections/functions | 创建 Function |
| POST | /api/connections/functions/{function_id}/deploy | 部署 Function |
| GET | /api/connections/functions/{function_id}/runs | 运行记录 |
| GET | /api/connections/pipelines | 管道列表 |
| POST | /api/connections/pipelines | 保存管道 |
| GET | /api/connections/pipelines/{pipeline_id} | 管道详情 |
| POST | /api/connections/pipelines/{pipeline_id}/execute | 执行管道(触发 Airflow DAG) |
调度 Scheduler(Airflow) · 4 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/connections/scheduler/health | Airflow 连通性 + DAG 状态 |
| POST | /api/connections/scheduler/pause | 暂停 / 恢复调度 |
| GET | /api/connections/scheduler/runs | 全局运行状态(最近 N 次) |
| GET | /api/connections/pipelines/{pipeline_id}/runs | 某管道执行历史 |
触达 Engage · 19 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /api/engage/estimate-audience | 受众规模预估 |
| GET | /api/engage/journeys | 旅程列表 |
| POST | /api/engage/journeys | 创建旅程 |
| GET | /api/engage/journeys/{journey_id} | 旅程详情 |
| PUT | /api/engage/journeys/{journey_id} | 更新旅程 |
| DELETE | /api/engage/journeys/{journey_id} | 删除旅程 |
| POST | /api/engage/journeys/{journey_id}/status | 设置旅程状态 |
| GET | /api/engage/journeys/{journey_id}/steps | 旅程步骤 |
| PUT | /api/engage/journeys/{journey_id}/steps | 替换步骤 |
| GET | /api/engage/journeys/{journey_id}/state | 旅程运行态 |
| GET | /api/engage/journeys/{journey_id}/stats | 旅程统计 |
| GET | /api/engage/broadcasts | 群发列表 |
| POST | /api/engage/broadcasts | 创建群发 |
| GET | /api/engage/broadcasts/{broadcast_id} | 群发详情 |
| PUT | /api/engage/broadcasts/{broadcast_id} | 更新群发 |
| DELETE | /api/engage/broadcasts/{broadcast_id} | 删除群发 |
| POST | /api/engage/broadcasts/{broadcast_id}/send | 发送群发 |
| GET | /api/engage/broadcasts/{broadcast_id}/sends | 发送明细 |
| GET | /api/engage/broadcasts/{broadcast_id}/stats | 群发统计 |
客户 Accounts · 11 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/accounts | 客户列表 |
| POST | /api/accounts/search | 客户检索 |
| GET | /api/accounts/{account_id} | 客户详情 |
| GET | /api/accounts/{account_id}/users | 客户下的用户 |
| GET | /api/accounts/{account_id}/aggregates | 客户聚合指标 |
| PUT | /api/accounts/{account_id}/aggregates | 写入聚合指标 |
| GET | /api/accounts/{account_id}/hierarchy | 客户层级 |
| PUT | /api/accounts/{account_id}/hierarchy | 写入层级 |
| GET | /api/accounts/{account_id}/merge-log | 客户合并日志 |
| GET | /api/accounts/-/merge-log | 全部合并日志 |
| POST | /api/accounts/merge | 合并客户 |
分析 Analyst · 14 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/analyst/sources | 白名单数据源目录(NL 选图用) |
| GET | /api/analyst/data | 图表数据(安全聚合) |
| GET | /api/analyst/drilldown | 图表数据点下钻明细 |
| GET | /api/analyst/kpis | KPI 卡数据 |
| GET | /api/analyst/charts | 图表列表 |
| POST | /api/analyst/charts | 保存图表 |
| DELETE | /api/analyst/charts/{cid} | 删除图表 |
| POST | /api/analyst/charts/nl | 自然语言生成图表 |
| GET | /api/analyst/dashboards | 看板列表 |
| GET | /api/analyst/dashboards/{did} | 看板详情 |
| POST | /api/analyst/dashboards | 保存看板 |
| PUT | /api/analyst/dashboards/{did} | 更新看板 |
| DELETE | /api/analyst/dashboards/{did} | 删除看板 |
| POST | /api/analyst/dashboards/nl | 自然语言生成看板 |
语义层 Semantic · 2 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/semantic/metrics | 指标目录(口径定义) |
| GET | /api/semantic/metrics/values | 指标取值 |
知识库 Knowledge · 8 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /api/kb/files | 上传文件(多模态) |
| GET | /api/kb/files | 文件列表(搜索 / 类型筛选) |
| GET | /api/kb/folders | 虚拟目录 |
| GET | /api/kb/files/{fid} | 文件详情 |
| GET | /api/kb/files/{fid}/download | 下载文件 |
| DELETE | /api/kb/files/{fid} | 删除文件 |
| POST | /api/kb/files/{fid}/links | 关联到对象记录 |
| DELETE | /api/kb/files/{fid}/links/{link_id} | 解除关联 |
应用 Apps · 3 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/apps | 应用市场列表 + 连接状态 |
| POST | /api/apps/{app_key} | 连接 / 配置应用 |
| DELETE | /api/apps/{app_key} | 断开应用 |
监控 Monitor · 18 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/monitor/overview | 投递概览 |
| GET | /api/monitor/metrics | 指标列表 |
| POST | /api/monitor/metrics | 写入指标 |
| GET | /api/monitor/sources | 数据源健康 |
| GET | /api/monitor/delivery-logs | 投递日志 |
| POST | /api/monitor/delivery-logs | 写入投递日志 |
| GET | /api/monitor/delivery-stats | 投递统计 |
| GET | /api/monitor/alert-rules | 告警规则列表 |
| POST | /api/monitor/alert-rules | 创建告警规则 |
| GET | /api/monitor/alert-rules/{rule_id} | 规则详情 |
| PUT | /api/monitor/alert-rules/{rule_id} | 更新规则 |
| DELETE | /api/monitor/alert-rules/{rule_id} | 删除规则 |
| POST | /api/monitor/alert-rules/{rule_id}/evaluate | 评估规则 |
| GET | /api/monitor/alert-events | 告警事件列表 |
| POST | /api/monitor/alert-events | 创建告警事件 |
| GET | /api/monitor/alert-events/{event_id} | 事件详情 |
| POST | /api/monitor/alert-events/{event_id}/acknowledge | 确认告警 |
| POST | /api/monitor/alert-events/{event_id}/resolve | 解决告警 |
协议 Protocols · 18 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/protocols/tracking-plans | 埋点计划列表 |
| POST | /api/protocols/tracking-plans | 创建埋点计划 |
| GET | /api/protocols/tracking-plans/{plan_id} | 计划详情 |
| PUT | /api/protocols/tracking-plans/{plan_id} | 更新计划 |
| DELETE | /api/protocols/tracking-plans/{plan_id} | 删除计划 |
| GET | /api/protocols/tracking-plans/{plan_id}/events | 计划内事件 |
| POST | /api/protocols/tracking-plans/{plan_id}/events | 新增事件 Schema |
| PUT | /api/protocols/tracking-plans/events/{event_id} | 更新事件 Schema |
| DELETE | /api/protocols/tracking-plans/events/{event_id} | 删除事件 Schema |
| POST | /api/protocols/tracking-plans/{plan_id}/validate | 按计划校验事件 |
| GET | /api/protocols/violations | 违规列表 |
| POST | /api/protocols/violations | 上报违规 |
| DELETE | /api/protocols/violations/{violation_id} | 删除违规 |
| GET | /api/protocols/transformations | 转换规则列表 |
| POST | /api/protocols/transformations | 创建转换规则 |
| GET | /api/protocols/transformations/{tf_id} | 转换详情 |
| PUT | /api/protocols/transformations/{tf_id} | 更新转换 |
| DELETE | /api/protocols/transformations/{tf_id} | 删除转换 |
隐私 Privacy · 16 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /api/privacy/pii/scan | PII 检测扫描 |
| GET | /api/privacy/pii/rules | PII 规则列表 |
| POST | /api/privacy/pii/rules | 创建 PII 规则 |
| PUT | /api/privacy/pii/rules/{rule_id} | 更新 PII 规则 |
| DELETE | /api/privacy/pii/rules/{rule_id} | 删除 PII 规则 |
| GET | /api/privacy/consent/categories | 同意分类 |
| POST | /api/privacy/consent/categories | 创建同意分类 |
| PUT | /api/privacy/consent/categories/{category_id} | 更新同意分类 |
| POST | /api/privacy/consent | 记录同意 |
| GET | /api/privacy/consent/{one_id} | 查询用户同意 |
| GET | /api/privacy/deletion | 删除请求列表 |
| POST | /api/privacy/deletion | 创建删除请求(GDPR) |
| POST | /api/privacy/deletion/{request_id}/execute | 执行删除 |
| GET | /api/privacy/deletion/{request_id} | 删除请求详情 |
| GET | /api/privacy/suppression/check | 抑制名单检查 |
| POST | /api/privacy/audit/logs | 查询审计日志 |
平台 Platform · 9 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/platform/infra-stats | 基础设施统计 |
| GET | /api/platform/tenants | 租户列表 |
| POST | /api/platform/tenants | 创建租户 |
| GET | /api/platform/tenants/{tenant_id} | 租户详情 |
| PUT | /api/platform/tenants/{tenant_id} | 更新租户 |
| PATCH | /api/platform/tenants/{tenant_id} | 切换租户状态 |
| GET | /api/platform/tenants/{tenant_id}/config | 租户配置 |
| PUT | /api/platform/tenants/{tenant_id}/config | 更新租户配置 |
| GET | /api/platform/audit/tenant-config | 租户配置变更审计 |
设置 / IAM · 23 个接口
SQL Engine · /api
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /api/tenants/{tenant_id} | 工作区信息 |
| PATCH | /api/tenants/{tenant_id} | 更新工作区 |
| GET | /api/iam/users | 成员列表 |
| POST | /api/iam/users | 新增成员(即登录账号) |
| PATCH | /api/iam/users/{user_id} | 更新成员 |
| DELETE | /api/iam/users/{user_id} | 删除成员 |
| GET | /api/iam/roles | 角色列表 |
| POST | /api/iam/roles | 创建角色 |
| PATCH | /api/iam/roles/{role_id} | 更新角色 |
| DELETE | /api/iam/roles/{role_id} | 删除角色 |
| GET | /api/iam/teams | 团队列表 |
| POST | /api/iam/teams | 创建团队 |
| POST | /api/iam/teams/{team_id}/members | 加入团队成员 |
| DELETE | /api/iam/teams/{team_id}/members/{user_id} | 移除团队成员 |
| GET | /api/iam/invitations | 邀请列表 |
| POST | /api/iam/invitations | 创建邀请 |
| POST | /api/iam/invitations/{token}/accept | 接受邀请 |
| DELETE | /api/iam/invitations/{invitation_id} | 取消邀请 |
| GET | /api/iam/tokens | API 令牌列表 |
| POST | /api/iam/tokens | 签发令牌 |
| DELETE | /api/iam/tokens/{token_id} | 吊销令牌 |
| GET | /api/iam/audit | 审计日志 |
| POST | /api/iam/audit | 写入审计 |
ID-Mapping 服务 · 8 个接口
ID-Mapping · :8001 或网关 /ID-Mapping/*
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /health | 健康检查 |
| POST | /events/process | 处理 UserEvent(实时合并) |
| POST | /users/import | 批量导入用户 |
| GET | /mapping/{tenant_id}/{channel_type}/{channel_id} | 渠道 ID → OneID 映射 |
| GET | /profile/{tenant_id}/{one_id} | 按 OneID 查画像 |
| GET | /wide/query/{tenant_id} | 宽表查询 |
| GET | /wide/{tenant_id}/{one_id} | 按 OneID 查宽表 |
| GET | /merge-log/{tenant_id} | 合并审计日志 |
智能助手 Assistant · 10 个接口
Assistant · :8004 或网关 /assistant/*
| 方法 | 路径 | 说明 |
|---|---|---|
| GET | /health | 健康检查 |
| GET | /agents | 智能体清单 |
| GET | /mcp/tools | 可调用的 MCP 工具清单 |
| POST | /chat | 对话(路由 → 专职智能体) |
| GET | /conversations | 会话列表 |
| GET | /history | 历史消息 |
| DELETE | /history | 清空历史 |
| GET | /tasks | 后台任务列表 |
| GET | /tasks/{run_id} | 任务详情 |
| POST | /observe | 埋点观测(主动式 Copilot) |
核心数据表
| 表 | 用途 |
|---|---|
tenants | 租户配置 |
id_mapping | 渠道 ID → OneID |
user_profile / doris_user_wide | 画像 / 宽表 |
object_* | 客户 / 订单 / 商品 / 门店 |
user_groups / segments | 受众 |
merge_log | 合并审计 |