OpenClaw 技能编排实战|如何组合多个技能完成复杂任务链

---name: news_digestdescription: Fetch latest news from RSS, summarize each article, and send digest to Feishu.triggers: ["新闻摘要", "日报生成", "news digest"]tools: [rss_reader, smart_summarize, feishu_sender]---# News Digest Workflow当用户要求生成新闻摘要时，严格按照以下步骤执行。## 输入参数用户需提供：- RSS 源列表（URL 数组）或 搜索关键词（将自动转换为 RSS）- 目标飞书群 webhook（若未提供则使用默认）## 执行步骤### 步骤 1：抓取文章调用 `rss_reader` 技能，参数为 RSS 源列表。等待返回结果，格式为 `[{title, link, content_snippet}, ...]`。若返回为空，输出“暂无新文章”并终止。### 步骤 2：逐篇生成摘要对步骤 1 返回的每一篇文章，依次调用 `smart_summarize` 技能，输入为 `content_snippet`。每篇文章的摘要结果保存到临时变量 `digest_items` 中。### 步骤 3：格式化摘要消息将 `digest_items` 格式化为飞书支持的 Markdown 格式：```markdown# 📰 今日新闻摘要 (YYYY-MM-DD)## 1. [标题1](链接1)摘要内容...## 2. [标题2](链接2)摘要内容...步骤 4：发送到飞书调用 feishu_sender 技能，参数为上一步生成的 Markdown 文本。发送成功后，回复用户“日报已发送至飞书群”。错误处理若某篇文章摘要生成失败（超时或返回空），跳过该篇，继续下一篇若所有文章都失败，回复用户“摘要生成失败，请检查 RSS 源是否有效”

mkdir -p ~/.openclaw/workspace/extensions/daily-reportercd ~/.openclaw/workspace/extensions/daily-reporternpm init -ynpm install @openclaw/plugin-sdk csv-parse axios xlsx

{  "id": "daily-reporter",  "name": "Daily Report Orchestrator",  "version": "1.0.0",  "description": "Orchestrate multi-source data collection, report generation, and multi-channel delivery.",  "permissions": ["read:files", "write:files", "http:send", "schedule:create"]}

import { definePluginEntry } from "@openclaw/plugin-sdk";import { schedule } from "node-cron";import fs from "fs/promises";import path from "path";interface WorkflowState {  step: "init" | "fetch_db" | "fetch_api" | "fetch_csv" | "merge" | "generate_report" | "send" | "backup";  data: any;  errors: string[];  startTime: Date;}class DailyReporter {  private state: WorkflowState;  private readonly workspace = process.env.OPENCLAW_WORKSPACE || "~/.openclaw/workspace";  constructor() {    this.state = {      step: "init",      data: {},      errors: [],      startTime: new Date()    };  }  async run() {    console.log("[DailyReporter] 工作流开始");    await this.fetchDatabaseMetrics();    await this.fetchApiMetrics();    await this.fetchCsvMetrics();    await this.mergeData();    await this.generateExcelReport();    await this.sendToDingtalk();    await this.backupToCloud();    console.log("[DailyReporter] 工作流完成", { duration: Date.now() - this.state.startTime.getTime() });  }  private async fetchDatabaseMetrics() {    this.state.step = "fetch_db";    // 示例：通过 exec 工具调用 SQL 查询（实际应使用 Plugin 提供的数据库客户端）    const result = await this.runTool("exec", { command: "mysql -e 'SELECT ...' -B -N" });    this.state.data.dbMetrics = JSON.parse(result.stdout);  }  private async fetchApiMetrics() {    this.state.step = "fetch_api";    const response = await fetch("https://api.example.com/metrics");    this.state.data.apiMetrics = await response.json();  }  private async fetchCsvMetrics() {    this.state.step = "fetch_csv";    const csvContent = await fs.readFile(path.join(this.workspace, "input/metrics.csv"), "utf-8");    // 使用 csv-parse 解析    this.state.data.csvMetrics = this.parseCSV(csvContent);  }  private async mergeData() {    this.state.step = "merge";    // 合并三个数据源，按时间戳对齐    this.state.data.merged = { ...this.state.data.dbMetrics, ...this.state.data.apiMetrics, ...this.state.data.csvMetrics };  }  private async generateExcelReport() {    this.state.step = "generate_report";    const XLSX = require("xlsx");    const workbook = XLSX.utils.book_new();    const sheet = XLSX.utils.json_to_sheet([this.state.data.merged]);    XLSX.utils.book_append_sheet(workbook, sheet, "Daily Report");    const buffer = XLSX.write(workbook, { type: "buffer", bookType: "xlsx" });    const outputPath = path.join(this.workspace, `reports/report_{this.state.data.reportPath})`      }    };    await fetch(webhook, { method: "POST", body: JSON.stringify(message), headers: { "Content-Type": "application/json" } });  }  private async backupToCloud() {    this.state.step = "backup";    // 示例：上传到 OSS    // await uploadFile(this.state.data.reportPath);  }  private async runTool(toolName: string, params: any) {    // 通过 Plugin API 调用 OpenClaw 内置工具    // 实际实现需使用 api.callTool()    console.log(`调用工具 {total}`。

// 将中间结果写入临时 JSONawait fs.writeFile(path.join(workspace, ".cache/step1.json"), JSON.stringify(data));// 后续步骤读取const data = JSON.parse(await fs.readFile(path.join(workspace, ".cache/step1.json"), "utf-8"));

## 错误处理- 若步骤 1（抓取 RSS）超时，重试最多 2 次，间隔 5 秒- 若仍失败，跳过该 RSS 源，继续处理下一个- 若所有 RSS 源均失败，回复用户“暂时无法获取新闻，请稍后重试”

import pRetry from 'p-retry';async function fetchWithRetry(url: string) {  return pRetry(async () => {    const res = await fetch(url);    if (!res.ok) throw new Error(`HTTP ${res.status}`);    return res.json();  }, { retries: 3, factor: 2, minTimeout: 1000 });}

### 步骤 1：并行抓取三个数据源同时执行以下三个操作：- 调用 `rss_reader` 抓取源 A- 调用 `rss_reader` 抓取源 B  - 调用 `rss_reader` 抓取源 C等待所有操作完成后，合并结果。

const [dataA, dataB, dataC] = await Promise.all([  fetchSourceA(),  fetchSourceB(),  fetchSourceC()]);

import pLimit from 'p-limit';const limit = pLimit(3);const results = await Promise.all(urls.map(url => limit(() => fetch(url))));