工作流概览¶
Datus Agent 工作流是一个将自然语言问题转换为 SQL 并执行的智能系统。可把它类比为一位懂业务的数据分析师：理解你的意图，自动生成合适的 SQL，拿回结果。
内置工作流¶
1. 固定工作流（Fixed）¶
- 适用场景：简单、直给的问题
- 特性：性能快、路径可预期
- 示例：
- “列出加州的所有客户”
- “展示 2023 年总销售额”
- 用途：直接取数、简单聚合、基础过滤
2. 反思工作流（Reflection）¶
- 适用场景：复杂业务问题
- 特性：自检自纠、可自动改进并重试
- 示例：
- “按品类展示季度收入趋势，排除退货并考虑季节性调整”
- 用途：多步骤分析、容错纠错、复杂业务逻辑
3. 指标到 SQL（Metric-to-SQL）¶
- 适用场景：标准化的业务报表
- 特性：基于预定义业务指标，保证一致性
- 示例：
- “展示上季度 MAU”
- “计算客户流失率”
- 用途：KPI 报表、标准化指标、BI 场景
组成：节点（Nodes）¶
工作流由若干专用“节点”组成，每个节点聚焦一件事：
- Schema Linking：为问题找对表
- Generate SQL：生成查询
- Execute SQL：执行查询
- Reflect：检查结果、决定是否改进
- Output：友好呈现结果
快速上手¶
命令行¶
# 简单问题
datus run --namespace your_db --task "Show me monthly sales"
# 指定工作流类型
datus run --namespace your_db --task "Show me complex revenue trends" --plan reflection
# 使用业务指标
datus run --namespace your_db --task "Calculate customer lifetime value" --plan metric_to_sql
通过 API¶
import requests
response = requests.post(
"http://localhost:8000/workflows/run",
headers={"Authorization": "Bearer your_token"},
json={
"workflow": "reflection",
"namespace": "your_db",
"task": "Show me quarterly revenue trends",
"mode": "sync"
}
)
result = response.json()
print(result["sql"]) # 生成的 SQL
print(result["result"]) # 查询结果