Menu
Dify + n8n 铻嶅悎宸ヤ綔娴佸钩鍙般€侱ify 鐨?LLM 鑳藉姏 + n8n 鐨勮嚜鍔ㄥ寲缂栨帓锛屾敮鎸佸瑙﹀彂鍣ㄣ€佽妭鐐规帶鍒舵祦銆佸嚟璇佺鐞嗐€?homepage: https://dify.ai
Install with Codex or Claude Copy this prompt, paste it into Codex, Claude, or another assistant, and let it review the skill page and install it for you.
Based on SOC occupation classification
| 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 搴旂敤闇€瑕佺紪鎺?- 鍋忓ソ浠ｇ爜/閰嶇疆绠＄悊