菜单
Dify + n8n 铻嶅悎宸ヤ綔娴佸钩鍙般€侱ify 鐨?LLM 鑳藉姏 + n8n 鐨勮嚜鍔ㄥ寲缂栨帓锛屾敮鎸佸瑙﹀彂鍣ㄣ€佽妭鐐规帶鍒舵祦銆佸嚟璇佺鐞嗐€?homepage: https://dify.ai
用 Codex 或 Claude 帮你安装 复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。
基于 SOC 职业分类
| name | openclaw-dify-workflow-skill |
| description | Dify + n8n 铻嶅悎宸ヤ綔娴佸钩鍙般€侱ify 鐨?LLM 鑳藉姏 + n8n 鐨勮嚜鍔ㄥ寲缂栨帓锛屾敮鎸佸瑙﹀彂鍣ㄣ€佽妭鐐规帶鍒舵祦銆佸嚟璇佺鐞嗐€?homepage: https://dify.ai |
Dify 鐨?LLM 鑳藉姏 + n8n 鐨勮嚜鍔ㄥ寲缂栨帓 = 寮哄ぇ鐨勫伐浣滄祦骞冲彴
| 鐗规€? | Dify | n8n | 鏈瀺鍚堝钩鍙? |
|---|---|---|---|
| LLM 宸ヤ綔娴? | 鉁? | 猬? | 鉁? |
| 澶氳Е鍙戝櫒 | 猬? | 鉁? | 鉁? |
| 鑺傜偣缂栨帓 | 猬? | 鉁? | 鉁? |
| 鏉′欢鍒嗘敮 | 猬? | 鉁? | 鉁? |
| 寰幆澶勭悊 | 猬? | 鉁? | 鉁? |
| 鍑瘉绠＄悊 | 猬? | 鉁? | 鉁? |
| 閿欒澶勭悊 | 猬? | 鉁? | 鉁? |
鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹?鈹? 瑙﹀彂鍣ㄥ眰 (Triggers) 鈹?鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹?鈹? 鈹?Webhook 鈹? 鈹?Schedule鈹? 鈹? Event 鈹? 鈹? Manual 鈹? 鈹?鈹? 鈹?澶栭儴HTTP 鈹? 鈹?Cron瀹氭椂 鈹? 鈹?浜嬩欢鐩戝惉 鈹? 鈹?鎵嬪姩瑙﹀彂 鈹? 鈹?鈹? 鈹斺攢鈹€鈹€鈹€鈹攢鈹€鈹€鈹€鈹? 鈹斺攢鈹€鈹€鈹€鈹攢鈹€鈹€鈹€鈹? 鈹斺攢鈹€鈹€鈹€鈹攢鈹€鈹€鈹€鈹? 鈹斺攢鈹€鈹€鈹€鈹攢鈹€鈹€鈹€鈹? 鈹?鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹尖攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹尖攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹尖攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹尖攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹粹攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹粹攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹? 鈻?鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹?鈹? 宸ヤ綔娴佸紩鎿?(Workflow Engine) 鈹?鈹? 鈹?鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹?鈹? 鈹? Condition 鈹傗攢鈹€鈹€鈻垛攤 Loop 鈹傗攢鈹€鈹€鈻垛攤 Dify Node 鈹? 鈹?鈹? 鈹? 鏉′欢鍒嗘敮 鈹? 鈹? 寰幆 鈹? 鈹? LLM璋冪敤 鈹? 鈹?鈹? 鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹?鈹? 鈹? 鈹?鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹? 鈹?鈹? 鈹? HTTP Node 鈹傗梹鈹€鈹€鈹€鈹?Error Handler鈹傗梹鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹?鈹? 鈹? HTTP璇锋眰 鈹? 鈹? 閿欒澶勭悊 鈹? 鈹?鈹? 鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹?鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹? 鈹? 鈻?鈹屸攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹?鈹? 鍑瘉绠＄悊 (Credentials) 鈹?鈹? Dify API / SMTP / HTTP Auth / OAuth2 / Database ... 鈹?鈹斺攢鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹€鈹?```
## 蹇€熷紑濮?
### 1. 鐜閰嶇疆
```bash
# Dify 閰嶇疆
export DIFY_BASE_URL="https://api.dify.ai/v1"
export DIFY_API_KEY="your-dify-api-key"
# Webhook 瀹夊叏锛堝彲閫夛級
export N8N_WEBHOOK_SECRET="your-webhook-secret"
from openclaw_dify_workflow_skill import WorkflowPlatform
# 鍒濆鍖栧钩鍙?platform = WorkflowPlatform()
# 鍚姩 Webhook 鍜屽畾鏃朵换鍔℃湇鍔?platform.start_services()
# 妫€鏌ュ仴搴风姸鎬?print(platform.health_check())
# 鎵ц宸ヤ綔娴?result = platform.execute_workflow(
workflow_id="hello_world",
trigger_data={"name": "OpenClaw"}
)
print(result)
鎺ユ敹 HTTP 璇锋眰瑙﹀彂宸ヤ綔娴侊細
workflows:
my_webhook_flow:
name: "Webhook 绀轰緥"
trigger:
type: "webhook"
path: "/my-webhook" # 瀹屾暣璺緞: /webhook/my-webhook
method: "POST" # 鏀寔 POST/GET
nodes:
- id: "process"
type: "dify_workflow"
config:
app_id: "my_app"
inputs:
data: "{{$trigger.body}}" # 寮曠敤璇锋眰浣?```
**瑙﹀彂 URL**锛?```bash
curl -X POST http://localhost:5678/webhook/my-webhook \
-H "Content-Type: application/json" \
-d '{"name": "test"}'
workflows:
daily_report:
name: "姣忔棩鎶ュ憡"
trigger:
type: "schedule"
cron: "0 9 * * *" # 姣忓ぉ涓婂崍9鐐? timezone: "Asia/Shanghai"
nodes:
- id: "generate"
type: "dify_workflow"
config:
app_id: "report_generator"
workflows:
adhoc_task:
name: "涓存椂浠诲姟"
trigger:
type: "manual"
nodes: [...]
**宸ヤ綔娴佽妭鐐?*锛?```yaml
**瀵硅瘽鑺傜偣**锛?```yaml
- id: "dify_chat_1"
type: "dify_chat"
name: "鏅鸿兘瀵硅瘽"
config:
app_id: "my_chatbot"
query: "{{$trigger.body.question}}"
conversation_id: "{{$vars.conv_id}}"
- id: "check_condition"
type: "condition"
name: "妫€鏌ユ潯浠?
conditions:
- id: "is_vip"
rules:
- left: "{{$trigger.body.user_type}}"
operator: "eq"
right: "vip"
- id: "has_high_score"
rules:
- left: "{{$trigger.body.score}}"
operator: "gt"
right: "80"
logic: "and"
branches:
- condition: "is_vip" # 濡傛灉 is_vip 涓虹湡
nodes:
- id: "vip_service"
type: "dify_chat"
config:
query: "鎻愪緵VIP鏈嶅姟"
- condition: "has_high_score" # 濡傛灉 has_high_score 涓虹湡
nodes:
- id: "reward"
type: "http_request"
config:
url: "https://api.example.com/reward"
- condition: "else" # 榛樿鍒嗘敮
nodes:
- id: "normal_service"
type: "dify_chat"
config:
query: "鏅€氭湇鍔?
鏀寔鐨勮繍绠楃锛?- eq - 绛変簬
ne - 涓嶇瓑浜?- gt - 澶т簬lt - 灏忎簬gte - 澶т簬绛変簬lte - 灏忎簬绛変簬contains - 鍖呭惈starts_with - 寮€澶存槸ends_with - 缁撳熬鏄?- regex - 姝ｅ垯鍖归厤exists - 瀛樺湪empty - 涓虹┖- id: "process_items"
type: "loop"
name: "澶勭悊鍒楄〃"
config:
type: "for_each" # for_each / while
items: "{{$trigger.body.items}}" # 鏁扮粍
max_iterations: 100 # 闃叉鏃犻檺寰幆
loop_body:
- id: "process_single"
type: "dify_workflow"
config:
inputs:
item: "{{process_items.current}}" # 褰撳墠椤? index: "{{process_items.index}}" # 褰撳墠绱㈠紩
- id: "save_result"
type: "http_request"
config:
method: "POST"
url: "https://api.example.com/save"
body: "{{process_single.outputs}}"
- id: "call_api"
type: "http_request"
name: "璋冪敤澶栭儴API"
config:
method: "POST"
url: "https://api.example.com/data"
headers:
Authorization: "Bearer {{$env.API_TOKEN}}"
Content-Type: "application/json"
body:
data: "{{$trigger.body}}"
source: "dify_workflow"
timeout: 30
- id: "wait_a_moment"
type: "wait"
name: "绛夊緟"
config:
seconds: 5 # 绛夊緟5绉? max_wait: 3600 # 鏈€澶х瓑寰?灏忔椂
- id: "risky_operation"
type: "dify_workflow"
name: "椋庨櫓鎿嶄綔"
config:
app_id: "unstable_api"
on_error:
strategy: "retry" # retry / stop / continue / fallback
max_retries: 3
retry_interval: 5
fallback: # strategy=fallback 鏃舵墽琛? - id: "backup_plan"
type: "dify_workflow"
config:
app_id: "stable_backup"
- id: "notify_admin"
type: "http_request"
config:
method: "POST"
url: "{{$env.WEBHOOK_URL}}"
body:
text: "涓绘湇鍔″け璐ワ紝宸插垏鎹㈠鐢ㄦ柟妗?
workflow_platform:
credentials:
dify_production:
type: "dify_api"
data:
api_key: "app-xxxxxx"
base_url: "https://api.dify.ai/v1"
smtp_gmail:
type: "smtp"
data:
host: "smtp.gmail.com"
port: 587
user: "{{$env.GMAIL_USER}}" # 寮曠敤鐜鍙橀噺
password: "{{$env.GMAIL_PASS}}"
internal_api:
type: "http_header"
data:
headers:
X-API-Key: "{{$env.INTERNAL_API_KEY}}"
test_url: "https://internal.api/health"
| 绫诲瀷 | 璇存槑 | 瀛楁 |
|---|---|---|
dify_api | Dify API Key | api_key, base_url |
http_basic | HTTP Basic Auth | username, password |
http_header | HTTP Header Auth | headers |
oauth2 | OAuth2 | client_id, client_secret, access_token |
smtp | SMTP 閭欢 | host, port, user, password |
postgres | PostgreSQL | host, port, database, user, password |
- id: "send_email"
type: "smtp"
credential: "smtp_gmail" # 寮曠敤鍑瘉
config:
to: "user@example.com"
subject: "宸ヤ綔娴佺粨鏋?
body: "{{previous_node.outputs}}"
"{{$trigger.body.name}}" # POST 璇锋眰浣撲腑鐨?name 瀛楁
"{{$trigger.query.id}}" # URL 鏌ヨ鍙傛暟 id
"{{$trigger.headers.authorization}}" # 璇锋眰澶?"{{$trigger.method}}" # HTTP 鏂规硶
"{{$env.DIFY_API_KEY}}"
"{{$env.HOSTNAME}}"
"{{node_id.outputs.result}}"
"{{node_id.outputs.tokens}}"
"{{node_id.answer}}" # 瀵硅瘽鑺傜偣鐨勫洖绛?```
### 寰幆鍙橀噺
```yaml
"{{loop_id.current}}" # 褰撳墠椤?"{{loop_id.index}}" # 褰撳墠绱㈠紩
"{{loop_id.total}}" # 鎬绘暟
"{{loop_id.count}}" # 宸插鐞嗘暟閲?```
## 瀹屾暣绀轰緥
### 鏅鸿兘瀹㈡湇宸ヤ綔娴?
```yaml
workflows:
smart_customer_service:
name: "鏅鸿兘瀹㈡湇"
description: "鑷姩澶勭悊瀹㈡埛鍜ㄨ"
trigger:
type: "webhook"
path: "/customer-service"
nodes:
# 1. 鍒嗙被瀹㈡埛闂
- id: "classify"
type: "dify_workflow"
name: "闂鍒嗙被"
config:
app_id: "classifier"
inputs:
query: "{{$trigger.body.message}}"
# 2. 鏍规嵁绫诲埆鍒嗘祦
- id: "route"
type: "condition"
name: "璺敱"
conditions:
- id: "is_technical"
rules:
- left: "{{classify.outputs.category}}"
operator: "eq"
right: "technical"
- id: "is_sales"
rules:
- left: "{{classify.outputs.category}}"
operator: "eq"
right: "sales"
branches:
- condition: "is_technical"
nodes:
- id: "tech_support"
type: "dify_chat"
config:
app_id: "tech_bot"
query: "{{$trigger.body.message}}"
- condition: "is_sales"
nodes:
- id: "sales_support"
type: "dify_chat"
config:
app_id: "sales_bot"
query: "{{$trigger.body.message}}"
- condition: "else"
nodes:
- id: "general_support"
type: "dify_chat"
config:
app_id: "general_bot"
query: "{{$trigger.body.message}}"
# 3. 璁板綍鍒?CRM
- id: "log_crm"
type: "http_request"
name: "璁板綍CRM"
config:
method: "POST"
url: "https://crm.example.com/logs"
headers:
Authorization: "Bearer {{$env.CRM_TOKEN}}"
body:
customer: "{{$trigger.body.customer_id}}"
message: "{{$trigger.body.message}}"
response: "{{route.outputs.answer}}"
category: "{{classify.outputs.category}}"
on_error:
strategy: "continue" # CRM璁板綍澶辫触涓嶅奖鍝嶄富娴佺▼
output:
answer: "{{route.outputs.answer}}"
category: "{{classify.outputs.category}}"
handled_at: "{{$env.CURRENT_TIME}}"
workflows:
batch_processor:
name: "鎵归噺鏂囨。澶勭悊"
trigger:
type: "webhook"
nodes:
- id: "validate_input"
type: "condition"
conditions:
- id: "has_documents"
rules:
- left: "{{$trigger.body.documents}}"
operator: "exists"
branches:
- condition: "has_documents"
nodes:
- id: "process_docs"
type: "loop"
config:
type: "for_each"
items: "{{$trigger.body.documents}}"
loop_body:
- id: "analyze"
type: "dify_workflow"
config:
app_id: "doc_analyzer"
inputs:
doc_url: "{{process_docs.current.url}}"
- id: "store_result"
type: "http_request"
config:
method: "POST"
url: "https://db.example.com/results"
body:
doc_id: "{{process_docs.current.id}}"
analysis: "{{analyze.outputs}}"
- condition: "else"
nodes:
- id: "error_response"
type: "dify_chat"
config:
query: "璇锋彁渚涙枃妗ｅ垪琛?
output:
processed: "{{process_docs.count}}"
results: "{{process_docs.results}}"
# 鎵嬪姩瑙﹀彂
python -c "
from openclaw_dify_workflow_skill import WorkflowPlatform
p = WorkflowPlatform()
result = p.execute_workflow('my_workflow', {'name': 'test'})
print(result)
"
# 鍒楀嚭鍑瘉
python -c "
from openclaw_dify_workflow_skill import WorkflowPlatform
p = WorkflowPlatform()
print(p.list_credentials())
"
# 娴嬭瘯鍑瘉
python -c "
from openclaw_dify_workflow_skill import WorkflowPlatform
p = WorkflowPlatform()
print(p.test_credential('dify_production'))
"
# 鑾峰彇 Webhook URL
python -c "
from openclaw_dify_workflow_skill import WorkflowPlatform
p = WorkflowPlatform()
print(p.get_webhook_url('my_webhook_flow'))
"
# 鎵嬪姩瑙﹀彂 Webhook
python -c "
from openclaw_dify_workflow_skill import WorkflowPlatform
p = WorkflowPlatform()
result = p.trigger_webhook('my_webhook_flow', {'test': 'data'})
print(result)
"
openclaw-dify-workflow-skill/
鈹溾攢鈹€ config/
鈹? 鈹斺攢鈹€ config.yaml # 閰嶇疆鏂囦欢
鈹溾攢鈹€ adapters/
鈹? 鈹斺攢鈹€ dify.py # Dify 閫傞厤鍣?鈹溾攢鈹€ engine/
鈹? 鈹溾攢鈹€ node_engine.py # 鑺傜偣鎵ц寮曟搸
鈹? 鈹溾攢鈹€ webhook_server.py # Webhook 鏈嶅姟
鈹? 鈹斺攢鈹€ credentials.py # 鍑瘉绠＄悊
鈹溾攢鈹€ scripts/
鈹? 鈹斺攢鈹€ agent.py # CLI 宸ュ叿
鈹溾攢鈹€ SKILL.md # 鏈枃妗?鈹斺攢鈹€ __init__.py # 鏍稿績骞冲彴绫?```
## 鏁呴殰鎺掓煡
### 妫€鏌ュ钩鍙扮姸鎬?
```bash
python -c "
from openclaw_dify_workflow_skill import WorkflowPlatform
p = WorkflowPlatform()
print(p.health_check())
"
| 闂 | 鍘熷洜 | 瑙ｅ喅 |
|---|---|---|
| Webhook 鏃犳硶璁块棶 | 绔彛琚崰鐢? | 淇敼 triggers.webhook.port |
| 鍑瘉娴嬭瘯澶辫触 | 鐜鍙橀噺鏈缃? | 妫€鏌?$env.XXX 寮曠敤 |
| 鍙橀噺瑙ｆ瀽澶辫触 | 璇硶閿欒 | 纭繚浣跨敤 {{$trigger.xxx}} 鏍煎紡 |
| 寰幆涓嶆墽琛? | items 涓嶆槸鏁扮粍 | 妫€鏌ヤ紶鍏ユ暟鎹牸寮? |
| 鏉′欢鍒ゆ柇閿欒 | 杩愮畻绗︿笉鏀寔 | 浣跨敤鏀寔鐨勮繍绠楃鍒楄〃 |
| 鐗规€? | n8n | 鏈瀺鍚堝钩鍙? |
|---|---|---|
| 鍙鍖栫紪杈戝櫒 | 鉁?鏈? | 猬?閰嶇疆鏂囦欢 |
| 鑷墭绠? | 鉁? | 鉁? |
| LLM 鑺傜偣 | 鈿狅笍 闇€閰嶇疆 | 鉁?鍐呯疆 Dify |
| 鑺傜偣绫诲瀷 | 400+ | 鏍稿績鑺傜偣 + Dify |
| 绀惧尯鐢熸€? | 涓板瘜 | 涓撴敞 LLM 宸ヤ綔娴? |
閫傚悎鍦烘櫙锛?- 闇€瑕?LLM 鑳藉姏鐨勮嚜鍔ㄥ寲宸ヤ綔娴?- 宸叉湁 Dify 搴旂敤闇€瑕佺紪鎺?- 鍋忓ソ浠ｇ爜/閰嶇疆绠＄悊