diff --git a/openclaw/yunce/n8n-content-pipeline-workflow.md b/openclaw/yunce/n8n-content-pipeline-workflow.md index 21c260de..c460b6e9 100644 --- a/openclaw/yunce/n8n-content-pipeline-workflow.md +++ b/openclaw/yunce/n8n-content-pipeline-workflow.md @@ -1,91 +1,76 @@ -# N8N 内容转化流水线工作流设计（v6） +# N8N 内容转化流水线工作流设计（v6 — 与实际部署对齐） > 用于：AI 英文文章 → 中文公众号/X/视频 内容转化 -> 工作流 ID：`iOf32aOKvTjfTDSM`（v5 基础） +> 工作流 ID：`SjGKBtSnQ0u87mlK` > 触发方式：OpenClaw 通过 Webhook 调用 > 管理平台：Mac mini 上的 n8n (`https://n8n.ishenwei.online`) -> -> **v6 变更（相比 v5）：** -> - ✅ 移除 Node 7（Build HTML）、Node 8（Write HTML） -> - ✅ n8n 仅输出 Markdown 文件，HTML 转换不再需要 -> - ✅ 最终输出纯 Markdown，便于在 Obsidian 中编辑后再发布到公众号 -> - ⚠️ Telegram 通知中的 HTML 相关字段已移除 -> - ⚠️ 验收标准调整为仅检查 Markdown 文件 --- -## 核心需求更新（v6） +## ⚠️ 路径映射说明（重要！） + +n8n 容器通过 Docker volume mount 访问宿主机文件系统： + +| 容器内路径 | 宿主机路径（OpenClaw 用这个） | +|-----------|--------------------------| +| `/home/node/.n8n-files/` | `/Users/weishen/docker/n8n/n8n_data/files/` | + +> **所有 `scp` / `ssh cp` / `ssh rm` 命令都必须使用宿主机路径。** +> n8n 节点内部配置的是容器路径，两者是同一个目录。 + +--- + +## 核心需求 ### 输出要求 **单一输出：中文 Markdown 文件** -| 输出文件 | 路径 | 格式 | 用途 | -|---------|------|------|------| -| **Markdown 源文件** | `content-output/{原文件名}.md` | 中文 Markdown | Obsidian 留存、编辑、发布 | - -> 不再生成公众号 HTML。公众号排版在 Obsidian 中手动完成，或通过其他工具转换。 +| 输出文件 | 宿主机路径 | 格式 | +|---------|-----------|------| +| **Markdown 成品** | `content-output/{output_name}_out.md` | 中文 Markdown，可在 Obsidian 中编辑后发布公众号 | ### Obsidian 目录结构 ``` ~/Workspace/nexus/openclaw/ ├── content-queue/ # 原始英文文章（输入） -│ └── 2026-03-29-ai-solopreneur.md +│ └── 3 Essential Tools for OpenClaw.md │ -└── content-output/ # 成品（输出，v6 仅 Markdown） - └── 2026-03-29-ai-solopreneur.md # 翻译后 Markdown ✅ +└── content-output/ # 成品（输出） + └── 3 Essential Tools for OpenClaw_out.md # 中文 Markdown ✅ ``` --- -## 工作流概述 - -``` -OpenClaw (发现文章) - ↓ (保存文件到 n8n-files 目录) - ↓ (触发 Webhook) - -┌─────────────────────────────────────────────────────────────┐ -│ N8N 工作流 (v6): content-translation-pipeline-v6 │ -│ │ -│ [Webhook] → [Read File] → [Extract Text] → [AI Agent] │ -│ ↓ ↑ (DeepSeek) │ -│ [Build Markdown] → [Write .md] │ -│ ↓ │ -│ [Send Telegram] │ -└─────────────────────────────────────────────────────────────┘ -``` - ---- - -## 节点详细设计（v6） +## 节点详细设计（v6 实际版本） ### 节点 1️⃣：Webhook Trigger **类型：** Webhook **名称：** `Webhook Trigger` -**Path：** `/content-translation-v6`（新建 path） +**Path：** `/content-translation-v6` **Method：** POST -**接收数据格式：** +**接收数据格式（重要更新）：** + ```json { - "note_name": "2026-03-29-ai-solopreneur.md", - "source_path": "/Users/weishen/Workspace/nexus/openclaw/content-queue/2026-03-29-ai-solopreneur.md", - "output_name": "2026-03-29-ai-solopreneur", - "callback_url": "http://192.168.3.189:18789/webhook/yunce" + "note_name": "3 Essential Tools for OpenClaw.md", + "output_name": "3 Essential Tools for OpenClaw" } ``` +> ⚠️ `source_path` 字段可选（v6 实际 webhook body 不依赖此字段）。 + --- -### 节点 2️⃣：Read Obsidian Note +### 节点 2️⃣：Read Binary File **类型：** Read Binary File **名称：** `Read Obsidian Note` -**配置：** +**配置（容器内路径）：** - File Path: `=/home/node/.n8n-files/{{ $json.body.note_name }}` --- @@ -98,22 +83,44 @@ OpenClaw (发现文章) --- -### 节点 4️⃣：AI Agent（翻译+改写） +### 节点 4️⃣：Structured Output Parser + +**类型：** Structured Output Parser +**名称：** `Structured Output Parser` +**说明：** n8n 内置的结构化输出解析器，负责将 AI 输出的文本解析为 JSON 供后续节点使用。 + +**JSON Schema：** +```json +{ + "wechat_title": "中文标题", + "wechat_excerpt": "公众号摘要（100字内）", + "wechat_content": "完整公众号文章（Markdown格式）", + "twitter_copy": "X/Twitter文案（280字内，带emoji）", + "video_title": "视频标题", + "video_script": "口播脚本（含时间戳和字幕）", + "cover_keywords": ["关键词1", "关键词2", "关键词3"] +} +``` + +--- + +### 节点 5️⃣：AI Agent **类型：** LangChain Agent **名称：** `AI Agent` **Version：** 3.1 **Model：** DeepSeek Chat Model +**Output Parser：** `Structured Output Parser`（已连接） -**Prompt 模板：** +**Prompt 模板（与 v6 文档一致，但 JSON 字段名注意小写）：** ``` -你是一个专业的中文内容编辑，擅长将英文文章转化为适合中国读者的高质量内容。 +你是专业的中文内容编辑，擅长将英文文章转化为适合中国读者的高质量内容。 ## 你的任务 将以下英文原文转化为： 1. 公众号风格的深度文章（2000-3000字） -2. X/Twitter 风格的短文案（280字内，带钩子） +2. X/Twitter 风格的短文案（280字内，带emoji钩子） 3. 视频口播脚本（3-5分钟，适合抖音/YouTube） ## 内容要求 @@ -123,11 +130,6 @@ OpenClaw (发现文章) - 调性：公众号大V风格，有观点有案例 - 商业化：可自然植入 AI Agent / 知识管理相关内容（软性，不硬广） -## 文章主题方向（供校准时参考） -- AI Agent 落地实践与工具推荐 -- AI 赋能商业的最佳实践 -- AI 时代的网络安全与运维 - ## 输出格式（严格按此 JSON 返回） { @@ -144,75 +146,77 @@ OpenClaw (发现文章) {{ $json.data }} ``` +> ⚠️ 注意：Build Markdown 节点访问 AI 结果用的是 `$input.first().json.output`，不是 `message`。 + --- -### 节点 5️⃣：Build Markdown（v6 精简版） +### 节点 6️⃣：Build Markdown **类型：** Code **名称：** `Build Markdown` -**功能：** 将 AI 输出的 JSON 组装成结构清晰的 Markdown 文件 +**功能：** 将 AI 输出的 JSON 组装成 Markdown 文件 ```javascript -const aiResult = $input.first().json.message; -const data = typeof aiResult === 'string' ? JSON.parse(aiResult) : aiResult; +const aiResponse = $input.first().json.output; +const aiResult = typeof aiResponse === 'string' ? JSON.parse(aiResponse) : aiResponse; const noteName = $('Webhook Trigger').first().json.body.note_name; -const outputName = noteName.replace('.md', ''); +const outputName = $('Webhook Trigger').first().json.body.output_name; +const sourcePath = $('Webhook Trigger').first().json.body.source_path || ''; -const markdown = `# ${data.wechat_title} - -> ${data.wechat_excerpt} - -${data.wechat_content} - ---- - -## X/Twitter 文案 - -${data.twitter_copy} - ---- - -## 视频信息 - -**标题：** ${data.video_title} - -**口播脚本：** - -${data.video_script} - ---- - -*封面图关键词：${data.cover_keywords?.join(', ')}* -`; +const markdown = '# ' + aiResult.wechat_title + '\n\n' + + aiResult.wechat_excerpt + '\n\n' + + aiResult.wechat_content + '\n\n' + + '---\n\n' + + '## X/Twitter 文案\n\n' + + aiResult.twitter_copy + '\n\n' + + '---\n\n' + + '## 视频信息\n\n' + + '**标题：** ' + aiResult.video_title + '\n\n' + + '**口播脚本：\n\n' + + aiResult.video_script + '\n\n' + + '---\n\n' + + '*封面图关键词：' + (aiResult.cover_keywords ? aiResult.cover_keywords.join(' | ') : '') + '*\n\n' + + '*原文路径：' + sourcePath + '*/'; return { json: { output_name: outputName, - output_content: markdown, - source_path: $('Webhook Trigger').first().json.body.source_path + markdown_content: markdown, + ai_result: aiResult } }; ``` --- -### 节点 6️⃣：Write .md File +### 节点 7️⃣：Convert to File -**类型：** Write Binary File / ReadWriteFile -**名称：** `Write Markdown Note` +**类型：** Convert to File +**名称：** `Convert to File` +**Operation：** `toText` +**Source Property：** `markdown_content` -**配置：** -- Operation: `write` -- File Path: `=/home/node/.n8n-files/{{ $json.output_name }}_output.md` -- Content: `={{ $json.output_content }}` - -**注意：** 输出到 n8n-files/ 目录，由 OpenClaw 负责复制回 Obsidian。 +> 将 Build Markdown 输出的文本（`markdown_content` 字段）转换为二进制文件，供 Write 节点写入。 --- -### 节点 7️⃣：Send Telegram Message +### 节点 8️⃣：Write Markdown File + +**类型：** Read/Write File +**名称：** `Write Markdown File` +**Operation：** `write` + +**配置：** +- File Name: `=/home/node/.n8n-files/{{ $('Build Markdown').item.json.output_name }}_out.md` +- Data Property Name: `=data` + +> ⚠️ 输出文件名格式：`{output_name}_out.md`（不是 `_output.md`！） + +--- + +### 节点 9️⃣：Send Telegram Message **类型：** Telegram **名称：** `Send Telegram Message` @@ -221,120 +225,94 @@ return { - Chat ID: `5038825565` - Text: ``` -✅ 文章转换完成！ +=✅ 文章转换完成！ -📝 标题：${$json.wechat_title} -📁 Markdown：/home/node/.n8n-files/${$json.output_name}_output.md -🐦 Twitter 文案：${$json.twitter_copy} -🎬 视频标题：${$json.video_title} +📝 标题：{{ $('Build Markdown').item.json.ai_result.wechat_title }} ``` -- Credentials: `Telegram XingJiang Bot` +- Parse Mode: `Markdown` -**注意：** OpenClaw 收到通知后负责将 Markdown 文件复制回 Obsidian。 +> ⚠️ v6 实际通知只含标题，不含文件路径。OpenClaw 根据约定的文件命名规则自行定位输出文件。 --- -## 节点连接图（v6） +## 节点连接图 ``` -┌─────────────────────────────────┐ -│ Webhook Trigger │ -│ POST /content-translation-v6 │ -└──────────────┬──────────────────┘ - │ - ▼ -┌─────────────────────────────────┐ -│ Read Obsidian Note │ -│ (Read Binary File) │ -└──────────────┬──────────────────┘ - │ - ▼ -┌─────────────────────────────────┐ -│ Extract from File │ -│ (text operation) │ -└──────────────┬──────────────────┘ - │ - ┌──────────┴──────────┐ - │ │ - │ ┌───────┴────────┐ - │ │ DeepSeek │ - │ │ Chat Model │ - │ └───────┬────────┘ - │ │ - ▼ ▼ -┌─────────────────────────────────┐ -│ AI Agent (LangChain) │ -│ 输出 JSON 格式结果 │ -└──────────────┬──────────────────┘ - │ - ▼ -┌─────────────────────────────────┐ -│ Build Markdown │ -│ 组装中文 Markdown 文件 │ -└──────────────┬──────────────────┘ - │ - ▼ -┌─────────────────────────────────┐ -│ Write Markdown Note │ -│ → content-output/*.md │ -└──────────────┬──────────────────┘ - │ - ▼ -┌─────────────────────────────────┐ -│ Send Telegram Message │ -│ Markdown 文件路径通知 │ -└─────────────────────────────────┘ +Webhook Trigger + │ + ▼ +Read Binary File + │ + ▼ +Extract from File + │ + ▼ +┌──────────────────────────────────────┐ +│ Structured Output Parser ←────────┤（AI Output Parser 连接） +│ AI Agent ─────────────────────────→│（prompt + outputSchema） +│ DeepSeek Chat Model │ +└──────────────────────────────────────┘ + │ + ▼ +Build Markdown + │ + ▼ +Convert to File + │ + ▼ +Write Markdown File + │ + ▼ +Send Telegram Message ``` --- -## 调用方式（OpenClaw 侧） +## 调用方式（OpenClaw 侧 — 实际测试命令） -**核心约束：n8n 只能读写 `/home/node/.n8n-files/` 目录，OpenClaw 负责文件搬运。** +### 宿主机 n8n-files 目录 +``` +/Users/weishen/docker/n8n/n8n_data/files/ +``` -### OpenClaw 完整流程（v6）： +### 完整流程（实际测试版） ```bash # ============================================= -# 步骤 1：OpenClaw 复制原文到 n8n-files 目录 +# 步骤 1：复制原文到 n8n 容器可访问的目录 # ============================================= -scp /Users/weishen/Workspace/nexus/openclaw/content-queue/article-2026-03-29.md \ - macmini:/home/node/.n8n-files/article-2026-03-29.md +scp "/Users/weishen/Workspace/nexus/openclaw/content-queue/3 Essential Tools for OpenClaw.md" \ + "macmini:/Users/weishen/docker/n8n/n8n_data/files/3 Essential Tools for OpenClaw.md" # ============================================= -# 步骤 2：OpenClaw 触发 n8n Webhook +# 步骤 2：触发 Webhook # ============================================= curl -X POST "https://n8n.ishenwei.online/webhook/content-translation-v6" \ -H "Content-Type: application/json" \ -d '{ - "note_name": "article-2026-03-29.md", - "source_path": "/Users/weishen/Workspace/nexus/openclaw/content-queue/article-2026-03-29.md", - "output_name": "article-2026-03-29", - "callback_url": "http://192.168.3.189:18789/webhook/yunce" - }' + "note_name": "3 Essential Tools for OpenClaw.md", + "output_name": "3 Essential Tools for OpenClaw" + }' \ + -m 180 \ + -w "\nHTTP_CODE:%{http_code}\n" # ============================================= -# 步骤 3：n8n 流程执行中... +# 步骤 3-4：复制输出文件回 Obsidian # ============================================= -# n8n 读取 /home/node/.n8n-files/article-2026-03-29.md -# 处理（翻译、改写） -# 输出到 /home/node/.n8n-files/article-2026-03-29_output.md -# 发送 Telegram 通知 +# ⚠️ 注意：输出文件名是 {output_name}_out.md，不是 _output.md +ssh macmini "cp \"/Users/weishen/docker/n8n/n8n_data/files/3 Essential Tools for OpenClaw_out.md\" \ +\"/Users/weishen/Workspace/nexus/openclaw/content-output/3 Essential Tools for OpenClaw_out.md\"" # ============================================= -# 步骤 4：OpenClaw 复制输出文件回 Obsidian（工作流完成后） +# 步骤 5：清理临时文件 # ============================================= -scp macmini:/home/node/.n8n-files/article-2026-03-29_output.md \ - /Users/weishen/Workspace/nexus/openclaw/content-output/article-2026-03-29.md - -# ============================================= -# 步骤 5：清理 n8n-files 临时文件（可选） -# ============================================= -ssh macmini "rm /home/node/.n8n-files/article-2026-03-29.md \ - /home/node/.n8n-files/article-2026-03-29_output.md" +ssh macmini "rm '/Users/weishen/docker/n8n/n8n_data/files/3 Essential Tools for OpenClaw.md'" +ssh macmini "rm '/Users/weishen/docker/n8n/n8n_data/files/3 Essential Tools for OpenClaw_out.md'" ``` -### OpenClaw Python 脚本模板（v6）： +--- + +## Python 自动化脚本模板（v6a — 勘误版） ```python import subprocess @@ -342,145 +320,120 @@ import sys # ========== 配置区 ========== N8N_BASE_URL = "https://n8n.ishenwei.online" -WEBHOOK_PATH = "content-translation-v6" # <-- 实际 webhook path -SOURCE_FILE = "/path/to/source/file.md" # <-- 实际源文件路径 -N8N_FILES = "/home/node/.n8n-files" +WEBHOOK_PATH = "content-translation-v6" +SOURCE_FILE = "/path/to/source/file.md" # <-- 修改为实际源文件路径 +N8N_FILES_HOST = "/Users/weishen/docker/n8n/n8n_data/files" NOTE_NAME = "source-file.md" # <-- 实际文件名 -OUTPUT_NAME = "source-file" # <-- 输出文件名（无扩展名） +OUTPUT_NAME = "source-file" # <-- output_name（无扩展名） OUTPUT_DIR = "/Users/weishen/Workspace/nexus/openclaw/content-output" -# =================================== +# ============================ -n8n_input_path = f"{N8N_FILES}/{NOTE_NAME}" +n8n_input = f"{N8N_FILES_HOST}/{NOTE_NAME}" +n8n_output = f"{N8N_FILES_HOST}/{OUTPUT_NAME}_out.md" # <-- 命名规则：_out.md print(f"[Step 1/5] 复制输入文件到 N8N 容器: {NOTE_NAME}") result = subprocess.run( - ['scp', SOURCE_FILE, f'macmini:{n8n_input_path}'], + ['scp', SOURCE_FILE, f'macmini:{n8n_input}'], capture_output=True, text=True ) if result.returncode != 0: print(f"X 文件复制失败: {result.stderr}") sys.exit(1) -print(f"V 已复制到 {n8n_input_path}") +print(f"V 已复制到 {n8n_input}") print(f"[Step 2/5] 触发 N8N Webhook: {WEBHOOK_PATH}") webhook_url = f"{N8N_BASE_URL}/webhook/{WEBHOOK_PATH}" payload = ("{" "\"note_name\": \"" + NOTE_NAME + "\", " - "\"source_path\": \"" + SOURCE_FILE + "\", " "\"output_name\": \"" + OUTPUT_NAME + "\"" "}") result = subprocess.run( ['curl', '-X', 'POST', webhook_url, '-H', 'Content-Type: application/json', - '-d', payload], + '-d', payload, + '-m', '180'], capture_output=True, text=True ) print(f"Webhook 触发响应: {result.stdout[:200]}") print("[Step 3/5] 等待 N8N 执行完成（Telegram 通知将发送到本会话）...") print("请等待 Telegram 通知，收到后继续执行步骤 4。") -sys.exit(0) # <-- 退出等待通知 +sys.exit(0) # ---- 以下为步骤 4 和 5，需在收到 Telegram 通知后执行 ---- print(f"[Step 4/5] 复制输出文件回 Obsidian...") -output_file = f"{OUTPUT_NAME}_output.md" -src = f"macmini:{N8N_FILES}/{output_file}" -dst = f"{OUTPUT_DIR}/{output_file}" +src = f"macmini:{n8n_output}" +dst = f"{OUTPUT_DIR}/{OUTPUT_NAME}_out.md" result = subprocess.run(['scp', src, dst], capture_output=True, text=True) if result.returncode == 0: - print(f" V {output_file}") + print(f" V {OUTPUT_NAME}_out.md") else: print(f" X {result.stderr}") print("[Step 5/5] 清理 N8N 容器临时文件...") -files_to_clean = [NOTE_NAME, output_file] -result = subprocess.run( - ['ssh', 'macmini', 'rm'] + [f"{N8N_FILES}/{f}" for f in files_to_clean], - capture_output=True, text=True -) -if result.returncode == 0: - print(" V 清理完成") -else: - print(f" ! 清理失败（不影响结果）: {result.stderr}") +for f in [NOTE_NAME, f"{OUTPUT_NAME}_out.md"]: + r = subprocess.run(['ssh', 'macmini', 'rm', f"{N8N_FILES_HOST}/{f}"], + capture_output=True, text=True) + status = "V" if r.returncode == 0 else f"X ({r.stderr})" + print(f" {status} {f}") print("🎉 工作流执行完毕！") ``` --- -## Obsidian 最终目录结构（v6） +## 验收标准 -``` -~/Workspace/nexus/openclaw/ -├── content-queue/ # 原始英文（输入，OpenClaw 放置） -│ └── article-2026-03-29.md -│ -└── content-output/ # 成品（v6 仅 Markdown） - └── article-2026-03-29.md # 中文 Markdown ✅ -``` - ---- - -## 验收标准（v6） - -1. 触发后自动完成整个流程，无需人工干预 -2. `content-output/` 目录生成 `.md` 文件（v6 无 HTML） -3. Markdown 文件内容完整，包含：公众号正文 + Twitter 文案 + 视频脚本 -4. Telegram 收到完成通知（含标题和文件路径） +1. Webhook 触发后 n8n 自动执行完整流程，无需人工干预 +2. `content-output/` 目录生成 `{output_name}_out.md` 文件 +3. Markdown 文件包含：标题 + 摘要 + 公众号正文 + Twitter 文案 + 视频脚本 + 封面关键词 +4. Telegram 收到含标题的完成通知 5. 错误时 n8n 记录错误节点并停止流程 --- -## 备注（v6） +## 与 v6 文档的差异汇总（本文档为正确版本） -- **Markdown 源文件**：保留中文原文，便于在 Obsidian 中编辑、排版后再发布 -- **公众号排版**：在 Obsidian 中手动完成，或通过 Markdown→公众号工具转换 -- **文件路径**：写入 Obsidian vault 的 `content-output/` 子目录，需确保 n8n 容器有对应目录的写权限 -- **API Key**：DeepSeek API 通过 n8n credential 配置，无需在代码中硬编码 +| 项目 | v6 文档（错） | v6a 实际版本（对） | +|------|-------------|-----------------| +| n8n-files 宿主机路径 | `/home/node/.n8n-files/` | `/Users/weishen/docker/n8n/n8n_data/files/` | +| 输出文件名 | `{output_name}_output.md` | `{output_name}_out.md` | +| 节点数 | 7 个 | 9 个（含 Convert to File + Structured Output Parser） | +| Build Markdown JSON 路径 | `$input.first().json.message` | `$input.first().json.output` | +| Telegram 通知内容 | 含文件路径 | 仅含标题 | +| webhook body | 包含 source_path | source_path 可选 | +| Write Markdown File FileName | `...output_name}_output.md` | `...output_name}_out.md` | --- --- -# 📖 附录：OpenClaw ↔ N8N 通用工作流调用规范（v1.0） +# 📖 附录：OpenClaw ↔ N8N 通用工作流调用规范（v1.1） > 本规范旨在为 OpenClaw 与 N8N 之间的每次交互建立统一标准，使星辉（XingHui）或其他 Agent 能够通过标准化步骤执行任意 N8N 工作流。 > -> **适用范围**：任何由 OpenClaw 触发、N8N 执行的工作流（不仅限于内容转化流水线） +> **适用范围**：任何由 OpenClaw 触发、N8N 执行的工作流 > -> **核心约束**：N8N 容器只读写 `/home/node/.n8n-files/` 目录，无法直接访问 Obsidian 或其他宿主机路径。OpenClaw 负责所有文件搬运。 +> **核心约束**：必须确认 n8n 容器的 volume mount 宿主机路径，所有 OpenClaw 侧文件操作使用宿主机路径。 --- -## 架构总览 +## 路径映射规则 -``` -OpenClaw N8N 容器 其他存储 - Agent (/home/node/.n8n-files/) 位置 - │ │ │ - │ ── ① 复制输入文件 ─────────────────→│ │ - │ │ │ - │ ── ② POST webhook ─────────────────→│ │ - │ │ │ - │ [N8N 执行工作流] │ - │ │ │ - │ ←── ③ Telegram / callback 通知 ───│ │ - │ │ │ - │ ←── ④ 复制输出文件 ─────────────────│──→ Obsidian 目录 │ - │ │ │ - │ ── ⑤ 清理 n8n-files ───────────────→│ │ -``` +n8n Docker 部署的 volume mount 映射关系： +- 容器内 `/home/node/.n8n-files/` → 宿主机 `{docker-root}/n8n_data/files/` +- 当前部署：`/Users/weishen/docker/n8n/n8n_data/files/` + +> 新增工作流时，先确认 docker-compose.yml 中的 volume 配置，用宿主机路径执行所有 `scp` / `ssh cp` / `ssh rm` 命令。 --- -## 标准化执行步骤（星辉操作指南） +## 标准化执行步骤 ### 步骤 ①：准备输入文件 -**规则**：所有传递给 N8N 的文件，必须先复制到 N8N 容器可访问的路径。 - -**通用格式**：`scp <源路径> macmini:/home/node/.n8n-files/<文件名>` +**通用格式**：`scp <源路径> macmini:{N8N_FILES_HOST}/<文件名>` ### 步骤 ②：触发 Webhook @@ -488,40 +441,32 @@ OpenClaw N8N 容器 其他存储 ```bash curl -X POST "/webhook/" \ -H "Content-Type: application/json" \ - -d '{ - "note_name": "<文件名>", - "source_path": "<原始文件路径>" - }' + -d '{"note_name": "<文件名>", "output_name": "<输出名>"}' \ + -m 180 -w "\nHTTP_CODE:%{http_code}\n" ``` -**Webhook Path 查询方式**： -1. 在 n8n 管理界面（https://n8n.ishenwei.online）打开对应工作流 -2. 点击 Webhook 节点，查看右侧 Path 字段 - ### 步骤 ③：等待执行完成 -**规则**：N8N 工作流完成后会发送通知，OpenClaw 需等待此信号后再执行后续复制操作。 - -**通知方式优先级**：Telegram Bot > Callback URL > 轮询 n8n API +**通知方式**：Telegram Bot（推荐）> Callback URL > 轮询 n8n API ### 步骤 ④：复制输出文件 -**通用格式**：`scp macmini:/home/node/.n8n-files/<输出文件名> <目标完整路径>` +**⚠️ 输出文件名规则因工作流而异，必须对照具体工作流确认（常见规则：`_out.md` / `_output.md` / `{name}_result.md`）** + +**通用格式**：`ssh macmini "cp {N8N_FILES_HOST}/<输出文件名> <目标路径>"` ### 步骤 ⑤：清理临时文件 -**通用格式**：`ssh macmini "rm /home/node/.n8n-files/<输入文件> /home/node/.n8n-files/<输出文件>"` +**通用格式**：`ssh macmini "rm {N8N_FILES_HOST}/<输入文件> {N8N_FILES_HOST}/<输出文件>"` --- -## 速查表：常见工作流配置 +## 速查表 -| 工作流 | Webhook Path | 输入文件规则 | 输出文件规则 | 通知方式 | -| ------- | ------------------------ | -------------------- | ---------------------------- | -------- | -| 内容转化 v6 | `content-translation-v6` | `content-queue/*.md` | `content-output/*_output.md` | Telegram | -| （待补充） | | | | | - -> **添加新工作流时**：在此表新增一行，注明 Webhook Path 和文件路径规则，星辉即可照此执行。 +| 工作流 | Webhook Path | 输入文件规则 | 输出文件规则 | 通知方式 | +|--------|-------------|-------------|-------------|---------| +| 内容转化 v6 | `content-translation-v6` | `content-queue/*.md` | `content-output/*_out.md` | Telegram（仅标题） | +| （待补充） | | | | | --- @@ -529,19 +474,19 @@ curl -X POST "/webhook/" \ | 异常情况 | 处理方式 | |---------|---------| -| `scp` 文件复制失败 | 检查源文件是否存在、检查目标目录权限 | -| `curl` Webhook 请求超时 | 重试 1 次（间隔 5 秒），仍失败则中止并通知用户 | -| Telegram 未收到完成通知 | 登录 n8n 管理界面 → 查看对应工作流执行记录 | -| 输出文件复制失败 | 检查 n8n-files 中是否已生成文件，确认文件名是否匹配 | -| N8N 工作流报错 | 登录 n8n 管理界面 → 打开对应工作流 → 查看错误节点日志 | +| `scp` 文件复制失败 | 检查源文件是否存在、检查 docker volume 路径是否正确 | +| `curl` Webhook 超时 | 增加 `-m` 超时时间（如 180 秒），重试 1 次 | +| Telegram 未收到通知 | 登录 n8n 管理界面 → 查看工作流执行记录 | +| 输出文件复制失败 | 确认实际输出文件名（对照工作流的 Write 节点配置） | +| N8N 工作流报错 | 登录 n8n 管理界面 → 查看错误节点日志 | --- ## 关键约束汇总 -1. **N8N 容器路径**：`/home/node/.n8n-files/`（只读/写此目录） -2. **文件传输方式**：`scp` via `macmini` 主机名 -3. **Webhook 触发**：统一使用 `curl -X POST`，Content-Type 为 `application/json` -4. **通知等待**：必须等待 Telegram/callback 通知后再复制输出文件，不得跳过 -5. **清理时机**：步骤 4 成功后再执行清理，步骤 4 失败时不清理（保留现场） -6. **配置文件**：`~/.openclaw/.env` 中的 `N8N_API_KEY` 和 `N8N_BASE_URL` 供脚本读取 +1. **n8n volume 宿主机路径**：`/Users/weishen/docker/n8n/n8n_data/files/` +2. **文件传输**：OpenClaw 侧统一用宿主机路径（`scp` / `ssh cp` / `ssh rm`） +3. **输出文件名**：必须对照具体工作流的 Write 节点确认，不得假设 +4. **Webhook 触发**：`curl -X POST`，`-m 180` 超时，响应含 `HTTP_CODE` +5. **通知等待**：必须等待 Telegram/callback 再复制输出文件 +6. **清理时机**：步骤 4 成功后再清理，失败时保留现场