🦞 Lobster Workflow Engine 是什么？——龙虾工作流引擎详解

# 🦞 Lobster Workflow - 妙趣AI每日营销自动化流程
# 文件名: miaoquai-daily-ops.yaml

workflow:
  name: "miaoquai-daily-ops"
  description: "妙趣AI每日自动化运营工作流"
  version: "1.0.0"

  # ===== 全局变量 =====
  vars:
    site_url: "https://miaoquai.com"
    discord_channel: "1483699648890802201"
    report_path: "/var/www/miaoquai/marketing-report.html"

  # ===== 主流程步骤 =====
  steps:

    # 步骤1: 生成AI新闻日报（顺序执行）
    - id: generate-news-digest
      name: "生成AI新闻日报"
      skill: "ai-news-digest"
      input:
        date: "${vars.current_date}"
        max_items: 10
      output: "news_html"
      retry:
        max_attempts: 3
        delay: 5s
        backoff: exponential

    # 步骤2: 并行执行多个SEO任务
    - id: parallel-seo-tasks
      name: "并行SEO任务"
      parallel:
        - id: generate-tool-pages
          skill: "seo-page-generator"
          input:
            count: 5
            category: "ai-tools"
          output: "tool_pages"
          retry:
            max_attempts: 2
            delay: 3s

        - id: check-dead-links
          skill: "seo-dead-link-checker"
          input:
            sitemap: "${vars.site_url}/sitemap.xml"
          output: "dead_links"
          retry:
            max_attempts: 2
            delay: 2s

        - id: update-glossary
          skill: "glossary-generator"
          input:
            topic: "AI术语"
            count: 1
          output: "glossary_page"

    # 步骤3: 条件分支 - 根据死链数量决定下一步
    - id: check-dead-links-condition
      name: "检查死链数量"
      condition:
        if: "${dead_links.count > 0}"
        then:
          - id: notify-dead-links
            skill: "discord-post"
            input:
              channel: "${vars.discord_channel}"
              text: "⚠️ 发现 ${dead_links.count} 个死链，请及时处理！"
        else:
          - id: log-all-good
            skill: "log"
            input:
              message: "✅ 未检测到死链，网站健康！"

    # 步骤4: 人工审批门控 - 发布前需人工确认
    - id: approval-before-publish
      name: "发布前人工审批"
      approval_gate:
        message: "📋 今日运营任务完成，是否发布营销报告？"
        timeout: 30m
        approvers:
          - "owner"
        on_approved:
          - id: publish-report
            skill: "file-write"
            input:
              path: "${vars.report_path}"
              content: "${news_html}"
        on_rejected:
          - id: notify-rejected
            skill: "discord-post"
            input:
              channel: "${vars.discord_channel}"
              text: "❌ 营销报告发布被拒绝，请检查内容。"

    # 步骤5: 循环 - 依次发布到多个社区
    - id: publish-to-communities
      name: "发布到多个社区"
      loop:
        over: ["discord", "github", "devto"]
        as: "platform"
        do:
          - id: "publish-to-${platform}"
            skill: "community-publisher"
            input:
              platform: "${platform}"
              content: "${news_html}"
            retry:
              max_attempts: 2
              delay: 3s

    # 步骤6: 生成每日营销报告
    - id: generate-marketing-report
      name: "生成营销报告"
      skill: "marketing-report-gen"
      input:
        news_count: "${news_html.items.length}"
        tool_pages: "${tool_pages.length}"
        dead_links_fixed: "${dead_links.count}"
      output: "daily_report"
      retry:
        max_attempts: 2
        delay: 5s

  # ===== 错误处理 =====
  on_error:
    action: "notify"
    skill: "discord-post"
    input:
      channel: "${vars.discord_channel}"
      text: "🚨 工作流执行失败！错误: ${error.message}"

  # ===== 定时触发 =====
  schedule: "0 8,12,18,22 * * *"  # 每天8点、12点、18点、22点执行

# 用户反馈处理工作流
workflow "user-feedback-pipeline":
    step1: 接收反馈 → 分类（bug/feature/question）
    step2: [condition]
        → bug: 分配给开发Agent → 修复 → 测试 → 通知用户
        → feature: 评估优先级 → [approval_gate] → 排入开发计划
        → question: 知识库检索 → 自动回复 → [condition] 未解决 → 转人工
    step3: 记录到CRM → 更新文档 → 发送满意度调查