dataworks-smart-monitor

# 📊 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 告警，@用户通知

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

### 3️⃣ 完成后通知

```
📊 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 倍

## 📝 使用示例

```
用户：检查 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: 初始版本（同步）