openclaw-dify-workflow-skill

分类: 数据与AI | 上传者: yunss33 | 下载: 0 | 版本: v1.0（最新）
Dify + n8n 铻嶅悎宸ヤ綔娴佸钩鍙般€侱ify 鐨?LLM 鑳藉姏 + n8n 鐨勮嚜鍔ㄥ寲缂栨帓锛屾敮鎸佸瑙﹀彂鍣ㄣ€佽妭鐐规帶鍒舵祦銆佸嚟璇佺鐞嗐€?homepage: https://dify.ai
更新日志: Source: GitHub https://github.com/yunss33/openclaw-dify-workflow-skill
目录结构

当前层级: 根目录
📁 adapters/
- 📄 __init__.py 124 B
- 📄 dify.py 14.4 KB
- 📄 midplatform.py 55.7 KB
📁 config/
- 📄 config.yaml 10.9 KB
📁 docs/
- 📄 MODULES.md 2.4 KB
- 📄 NAMING.md 1.3 KB
📁 engine/
- 📄 __init__.py 17 B
- 📄 credentials.py 11.7 KB
- 📄 node_engine.py 18.2 KB
- 📄 webhook_server.py 11.8 KB
📁 scripts/
- 📄 agent.py 10.3 KB
- 📄 task_daemon.py 7.0 KB
- 📄 task_worker.py 6.7 KB
📁 utils/
- 📄 __init__.py 110 B
- 📄 feishu_sender.py 13.6 KB
- 📄 policy_manager.py 15.3 KB
- 📄 result_store.py 4.4 KB
- 📄 task_manager.py 13.3 KB
📄 .gitignore 363 B
📄 __init__.py 8.7 KB
📄 async_workflow.py 9.2 KB
📄 bot_pusher.py 6.3 KB
📄 error_handler.py 8.0 KB
📄 progress.py 7.5 KB
📄 README.md 864 B
📄 requirements.txt 50 B
📄 SKILL.md 20.6 KB
📄 smart_router.py 11.6 KB
📄 status.py 9.9 KB
📄 status_query.py 8.5 KB
📄 storage.py 7.6 KB
SKILL.md

---
name: openclaw-dify-workflow-skill
description: Dify + n8n 铻嶅悎宸ヤ綔娴佸钩鍙般€侱ify 鐨?LLM 鑳藉姏 + n8n 鐨勮嚜鍔ㄥ寲缂栨帓锛屾敮鎸佸瑙﹀彂鍣ㄣ€佽妭鐐规帶鍒舵祦銆佸嚟璇佺鐞嗐€?homepage: https://dify.ai
metadata:
  openclaw:
    emoji: "馃"
    requires:
      bins: ["python3"]
---

# Dify + n8n 铻嶅悎宸ヤ綔娴佸钩鍙?
**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"
```

### 2. 鍚姩鏈嶅姟

```python
from openclaw_dify_workflow_skill import WorkflowPlatform

# 鍒濆鍖栧钩鍙?platform = WorkflowPlatform()

# 鍚姩 Webhook 鍜屽畾鏃朵换鍔℃湇鍔?platform.start_services()

# 妫€鏌ュ仴搴风姸鎬?print(platform.health_check())
```

### 3. 鎵ц宸ヤ綔娴?
```python
# 鎵ц宸ヤ綔娴?result = platform.execute_workflow(
    workflow_id="hello_world",
    trigger_data={"name": "OpenClaw"}
)
print(result)
```

## 瑙﹀彂鍣ㄧ被鍨?
### 1. Webhook 瑙﹀彂鍣?
鎺ユ敹 HTTP 璇锋眰瑙﹀彂宸ヤ綔娴侊細

```yaml
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"}'
```

### 2. 瀹氭椂瑙﹀彂鍣?(Cron)

```yaml
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"
```

### 3. 鎵嬪姩瑙﹀彂鍣?
```yaml
workflows:
  adhoc_task:
    name: "涓存椂浠诲姟"
    trigger:
      type: "manual"
    nodes: [...]
```

## 鑺傜偣绫诲瀷

### Dify 鑺傜偣

**宸ヤ綔娴佽妭鐐?*锛?```yaml
- id: "dify_workflow_1"
  type: "dify_workflow"
  name: "鐢熸垚鍐呭"
  config:
    app_id: "my_workflow"
    inputs:
      query: "{{$trigger.body.query}}"
      style: "professional"
```

**瀵硅瘽鑺傜偣**锛?```yaml
- id: "dify_chat_1"
  type: "dify_chat"
  name: "鏅鸿兘瀵硅瘽"
  config:
    app_id: "my_chatbot"
    query: "{{$trigger.body.question}}"
    conversation_id: "{{$vars.conv_id}}"
```

### 鏉′欢鑺傜偣 (IF/ELSE)

```yaml
- 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` - 涓虹┖

### 寰幆鑺傜偣

```yaml
- 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}}"
```

### HTTP 璇锋眰鑺傜偣

```yaml
- 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
```

### 绛夊緟鑺傜偣

```yaml
- id: "wait_a_moment"
  type: "wait"
  name: "绛夊緟"
  config:
    seconds: 5                 # 绛夊緟5绉?    max_wait: 3600            # 鏈€澶х瓑寰?灏忔椂
```

## 閿欒澶勭悊

### 鑺傜偣绾ч敊璇鐞?
```yaml
- 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: "涓绘湇鍔″け璐ワ紝宸插垏鎹㈠鐢ㄦ柟妗?
```

## 鍑瘉绠＄悊

### 閰嶇疆鍑瘉

```yaml
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` |

### 鍦ㄨ妭鐐逛腑浣跨敤鍑瘉

```yaml
- id: "send_email"
  type: "smtp"
  credential: "smtp_gmail"     # 寮曠敤鍑瘉
  config:
    to: "user@example.com"
    subject: "宸ヤ綔娴佺粨鏋?
    body: "{{previous_node.outputs}}"
```

## 鍙橀噺寮曠敤璇硶

### 瑙﹀彂鍣ㄦ暟鎹?
```yaml
"{{$trigger.body.name}}"           # POST 璇锋眰浣撲腑鐨?name 瀛楁
"{{$trigger.query.id}}"            # URL 鏌ヨ鍙傛暟 id
"{{$trigger.headers.authorization}}"  # 璇锋眰澶?"{{$trigger.method}}"              # HTTP 鏂规硶
```

### 鐜鍙橀噺

```yaml
"{{$env.DIFY_API_KEY}}"
"{{$env.HOSTNAME}}"
```

### 鑺傜偣杈撳嚭

```yaml
"{{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}}"
```

### 鎵归噺澶勭悊宸ヤ綔娴?
```yaml
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}}"
```

## API 鍙傝€?
### 鎵ц宸ヤ綔娴?
```bash
# 鎵嬪姩瑙﹀彂
python -c "
from openclaw_dify_workflow_skill import WorkflowPlatform
p = WorkflowPlatform()
result = p.execute_workflow('my_workflow', {'name': 'test'})
print(result)
"
```

### 绠＄悊鍑瘉

```bash
# 鍒楀嚭鍑瘉
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 绠＄悊

```bash
# 鑾峰彇 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 鐨勫尯鍒?
| 鐗规€?| n8n | 鏈瀺鍚堝钩鍙?|
|------|-----|-----------|
| 鍙鍖栫紪杈戝櫒 | 鉁?鏈?| 猬?閰嶇疆鏂囦欢 |
| 鑷墭绠?| 鉁?| 鉁?|
| LLM 鑺傜偣 | 鈿狅笍 闇€閰嶇疆 | 鉁?鍐呯疆 Dify |
| 鑺傜偣绫诲瀷 | 400+ | 鏍稿績鑺傜偣 + Dify |
| 绀惧尯鐢熸€?| 涓板瘜 | 涓撴敞 LLM 宸ヤ綔娴?|

閫傚悎鍦烘櫙锛?- 闇€瑕?LLM 鑳藉姏鐨勮嚜鍔ㄥ寲宸ヤ綔娴?- 宸叉湁 Dify 搴旂敤闇€瑕佺紪鎺?- 鍋忓ソ浠ｇ爜/閰嶇疆绠＄悊
登录后下载/点赞/收藏 ❤ 2 | ★ 0
openclaw-dify-workflow-skill

目录结构

SKILL.md

举报内容

提示
