Dataworks Smart Monitor

DataWorks 智能监控技能 - 异步分析任务运行情况，智能告警分级（不阻塞主会话）

📊 DataWorks 智能监控技能（异步版）

自动分析 DataWorks 任务运行情况，智能告警分级，生成日报，异步执行不阻塞。

🎯 触发词

• "检查 DataWorks 任务状态"
• "DataWorks 智能监控"
• "生成 DataWorks 日报"
• "查看昨天任务运行情况"
• "dataworks 监控"

🚀 核心特性

异步执行：

• ✅ 不阻塞主会话
• ✅ 可以并行执行其他任务
• ✅ 完成后主动通知
• ✅ 实时输出进度

智能分析：

• ✅ 失败原因自动分析（LLM 分析错误日志）
• ✅ 任务运行时长异常检测
• ✅ 智能告警分级（P0/P1/P2）
• ✅ 自动重试建议

📋 执行流程

1️⃣ 异步调用子 agent

javascript

sessions_spawn({
  agentId: "agent-ge",
  task: `分析 DataWorks 任务运行情况（昨天）`,
  mode: "run",
  streamTo: "parent",
  label: "dataworks-smart-monitor"
})

// 立即回复用户
"好的，正在分析 DataWorks 任务运行情况，完成后发送报告～"

2️⃣ 子 agent 执行分析

步骤：

1. 调用 DataWorks API 获取昨天的任务实例列表
2. 统计任务状态（成功/失败/运行中）
3. 提取失败任务的错误日志
4. 使用 LLM 分析失败原因
5. 智能分级（P0/P1/P2）
6. 生成详细报告（JSON + 文本）
7. 发送报告到飞书
8. 如有 P0/P1 告警，@用户通知

进度播报：

text

📊 正在获取 DataWorks 任务列表...
✅ 获取到 161 个任务实例
🔍 正在分析失败任务（3 个）...
🤖 LLM 分析失败原因...
📋 生成报告中...
📤 发送到飞书...
✅ 分析完成！

3️⃣ 完成后通知

text

📊 DataWorks 智能监控日报 (2026-03-11)

✅ 成功：158 个
❌ 失败：3 个
⏳ 运行中：0 个
📋 总计：161 个

🚨 P0 告警（严重）：1 个
  - ods_user_info_df - 数据源连接超时

⚠️ P1 告警（重要）：2 个
  - dwd_order_detail_di - 字段类型不匹配
  - ads_daily_report_di - 内存不足

📄 详细报告：已发送到飞书
🔗 控制台：https://dataworks.console.aliyun.com/...

⚙️ 配置

在 TOOLS.md 中配置 DataWorks 项目信息：

markdown

### DataWorks 配置

#### TH 项目
- PROJECT_ID: 33012
- REGION_ID: ap-southeast-1
- ACCESS_KEY_ID: [已配置]
- ACCESS_KEY_SECRET: [已配置]

#### PH 项目
- PROJECT_ID: [待配置]
- REGION_ID: ap-southeast-1
- ACCESS_KEY_ID: [待配置]
- ACCESS_KEY_SECRET: [待配置]

📊 告警分级

级别	关键词	说明	通知
P0	数据源连接、内存不足、OOM、磁盘满、权限拒绝	严重 - 需要立即处理	✅
P1	字段类型、语法错误、表不存在、分区错误	重要 - 工作时间处理	✅
P2	超时、重试、网络、临时	一般 - 可自动重试	❌

⏱️ 运行时长告警

• ⚠️ 警告：超过平均时长 2 倍
• 🚨 严重：超过平均时长 3 倍

📝 使用示例

text

用户：检查 DataWorks 任务状态
助手：好的，正在分析 DataWorks 任务运行情况，完成后发送报告～

[子 agent 异步执行中...]
[2 分钟后]
助手：📊 DataWorks 智能监控日报完成！发现 1 个 P0 告警，详细报告已发送到飞书

🗓️ 定时任务

建议配置每日上午 9:00 自动执行（使用 cron）：

javascript

// 使用 OpenClaw cron 配置
{
  "schedule": "0 9 * * *",
  "payload": {
    "kind": "agentTurn",
    "message": "检查 DataWorks 任务状态"
  }
}

🔧 技术实现

主会话（我）：

javascript

// 异步调用
sessions_spawn({
  agentId: "agent-ge",
  task: `
    1. 调用 DataWorks API 获取昨天的任务实例
    2. 统计任务状态
    3. 分析失败任务的错误日志
    4. LLM 智能分级（P0/P1/P2）
    5. 生成详细报告
    6. 发送到飞书
    7. 如有 P0/P1 告警，@用户
  `,
  mode: "run",
  label: "dataworks-smart-monitor"
})

// 立即回复，不阻塞
"好的，正在分析 DataWorks 任务运行情况，完成后发送报告～"

子 agent：

• 调用 DataWorks API
• 分析错误日志
• 生成报告并发送

⚠️ 注意事项

1. API 限流 - 避免频繁调用，建议每日执行 1-2 次
2. 敏感信息 - 错误日志中可能包含敏感信息，注意脱敏
3. 告警噪音 - P2 告警不主动通知，避免打扰

---

版本历史：

• v2.0 (2026-03-12): 改造为异步执行
• v1.0: 初始版本（同步）