Embed中的工作流管理#

功能可用性

Embed功能需要Embed许可证。有关何时使用Embed、费用及许可流程的更多信息，请参阅n8n网站上的Embed。

在管理跨团队或组织的嵌入式n8n部署时，您可能需要为多个用户运行相同（或相似）的工作流。为此有两种可用选项：

解决方案	优势	劣势
为每个用户创建工作流	工作流启动方式无限制（可使用任何触发器）	需要管理多个工作流。
创建一个单一的工作流，并在执行时传递用户凭据	简化工作流管理（只需更改一个工作流）	要运行该工作流，您的产品必须调用它

警告

本文档中引用的API可能会随时变更。请务必在每次版本升级时检查功能的持续性。

每个用户的工作流#

通常需要遵循以下三个步骤：

获取每个用户的凭据，以及根据工作流可能需要提供的任何额外参数。
为此用户创建n8n凭据。
创建工作流。

1. 获取用户凭证#

在这里，您需要为该用户必须进行身份验证的任何节点/服务捕获所有凭据，以及特定工作流所需的任何其他参数。所需的凭据和参数将取决于您的工作流以及您尝试实现的目标。

2. 创建用户凭证#

在获取所有相关的凭证详细信息后，您可以继续在n8n中创建相应的服务凭证。这可以通过编辑器界面或API调用来完成。

使用编辑器界面#

从菜单中选择凭证 > 新建。
使用下拉菜单选择要创建的凭证类型，例如Airtable。
在创建新凭据弹窗中，输入该用户对应的凭据详细信息，并选择可以访问这些凭据的节点。
点击创建完成并保存。

使用API#

编辑器用户界面使用的前端API也可以被调用来实现相同的结果。API端点的格式为：https:///rest/credentials。

例如，要在上述编辑器界面示例中创建凭据，请求应为：

1	`POST https:///rest/credentials`

请求体内容：

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
{
   "name":"MyAirtable",
   "type":"airtableApi",
   "nodesAccess":[
      {
         "nodeType":"n8n-nodes-base.airtable"
      }
   ],
   "data":{
      "apiKey":"q12we34r5t67yu"
   }
}

响应将包含新凭证的ID，您将在为该用户创建工作流时使用：

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
{
   "data":{
      "name":"MyAirtable",
      "type":"airtableApi",
      "data":{
         "apiKey":"q12we34r5t67yu"
      },
      "nodesAccess":[
         {
            "nodeType":"n8n-nodes-base.airtable",
            "date":"2021-09-10T07:41:27.770Z"
         }
      ],
      "id":"29",
      "createdAt":"2021-09-10T07:41:27.777Z",
      "updatedAt":"2021-09-10T07:41:27.777Z"
   }
}

3. 创建工作流#

最佳实践是创建一个“基础”工作流，然后为每个新用户复制并根据其凭据（以及其他详细信息）进行自定义。

您可以通过编辑器界面或API调用来复制并自定义模板工作流。

使用编辑器界面#

从菜单中选择工作流 > 打开以打开要复制的模板工作流。
选择 工作流 > 复制，然后为这个新工作流输入名称并点击保存。
更新所有相关节点以使用此用户（上面创建的）的凭据。
保存此工作流，并使用右上角的开关将其设置为活动状态。

使用API#

使用端点获取模板工作流的JSON：https:///rest/workflows/
1
GET https:///rest/workflows/1012

The response will contain the JSON data of the selected workflow:

{
  "data": {
    "id": "1012",
    "name": "Nathan's Workflow",
    "active": false,
    "nodes": [
      {
        "parameters": {},
        "name": "Start",
        "type": "n8n-nodes-base.start",
        "typeVersion": 1,
        "position": [
          130,
          640
        ]
      },
      {
        "parameters": {
          "authentication": "headerAuth",
          "url": "https://internal.users.n8n.cloud/webhook/custom-erp",
          "options": {
            "splitIntoItems": true
          },
          "headerParametersUi": {
            "parameter": [
              {
                "name": "unique_id",
                "value": "recLhLYQbzNSFtHNq"
              }
            ]
          }
        },
        "name": "HTTP Request",
        "type": "n8n-nodes-base.httpRequest",
        "typeVersion": 1,
        "position": [
          430,
          300
        ],
        "credentials": {
          "httpHeaderAuth": "beginner_course"
        }
      },
      {
        "parameters": {
          "operation": "append",
          "application": "appKBGQfbm6NfW6bv",
          "table": "processingOrders",
          "options": {}
        },
        "name": "Airtable",
        "type": "n8n-nodes-base.airtable",
        "typeVersion": 1,
        "position": [
          990,
          210
        ],
        "credentials": {
          "airtableApi": "Airtable"
        }
      },
      {
        "parameters": {
          "conditions": {
            "string": [
              {
                "value1": "={{$json[\"orderStatus\"]}}",
                "value2": "processing"
              }
            ]
          }
        },
        "name": "IF",
        "type": "n8n-nodes-base.if",
        "typeVersion": 1,
        "position": [
          630,
          300
        ]
      },
      {
        "parameters": {
          "keepOnlySet": true,
          "values": {
            "number": [
              {
                "name": "=orderId",
                "value": "={{$json[\"orderID\"]}}"
              }
            ],
            "string": [
              {
                "name": "employeeName",
                "value": "={{$json[\"employeeName\"]}}"
              }
            ]
          },
          "options": {}
        },
        "name": "Set",
        "type": "n8n-nodes-base.set",
        "typeVersion": 1,
        "position": [
          800,
          210
        ]
      },
      {
        "parameters": {
          "functionCode": "let totalBooked = items.length;\nlet bookedSum = 0;\n\nfor(let i=0; i < items.length; i++) {\n  bookedSum = bookedSum + items[i].json.orderPrice;\n}\nreturn [{json:{totalBooked, bookedSum}}]\n"
        },
        "name": "Function",
        "type": "n8n-nodes-base.function",
        "typeVersion": 1,
        "position": [
          800,
          400
        ]
      },
      {
        "parameters": {
          "webhookUri": "https://discord.com/api/webhooks/865213348202151968/oD5_WPDQwtr22Vjd_82QP3-_4b_lGhAeM7RynQ8Js5DzyXrQEnj0zeAQIA6fki1JLtXE",
          "text": "=This week we have {{$json[\"totalBooked\"]}} booked orders with a total value of {{$json[\"bookedSum\"]}}. My Unique ID: {{$node[\"HTTP Request\"].parameter[\"headerParametersUi\"][\"parameter\"][0][\"value\"]}}"
        },
        "name": "Discord",
        "type": "n8n-nodes-base.discord",
        "typeVersion": 1,
        "position": [
          1000,
          400
        ]
      },
      {
        "parameters": {
          "triggerTimes": {
            "item": [
              {
                "mode": "everyWeek",
                "hour": 9
              }
            ]
          }
        },
        "name": "Cron",
        "type": "n8n-nodes-base.cron",
        "typeVersion": 1,
        "position": [
          220,
          300
        ]
      }
    ],
    "connections": {
      "HTTP Request": {
        "main": [
          [
            {
              "node": "IF",
              "type": "main",
              "index": 0
            }
          ]
        ]
      },
      "Start": {
        "main": [
          []
        ]
      },
      "IF": {
        "main": [
          [
            {
              "node": "Set",
              "type": "main",
              "index": 0
            }
          ],
          [
            {
              "node": "Function",
              "type": "main",
              "index": 0
            }
          ]
        ]
      },
      "Set": {
        "main": [
          [
            {
              "node": "Airtable",
              "type": "main",
              "index": 0
            }
          ]
        ]
      },
      "Function": {
        "main": [
          [
            {
              "node": "Discord",
              "type": "main",
              "index": 0
            }
          ]
        ]
      },
      "Cron": {
        "main": [
          [
            {
              "node": "HTTP Request",
              "type": "main",
              "index": 0
            }
          ]
        ]
      }
    },
    "createdAt": "2021-07-16T11:15:46.066Z",
    "updatedAt": "2021-07-16T12:05:44.045Z",
    "settings": {},
    "staticData": null,
    "tags": []
  }
}

保存返回的JSON数据，并为新用户更新所有相关的凭据和字段。
在端点 https:///rest/workflows 使用更新后的JSON作为请求体创建新工作流:
1
POST https:///rest/workflows/

响应将包含新工作流的ID，您将在下一步中使用它。

最后，激活新工作流：
1
PATCH https:///rest/workflows/1012

在JSON负载中传递额外的值active：

1
2
3
4
5
// ...
"active":true,
"settings": {},
"staticData": null,
"tags": []

单一工作流#

实现此方法需要遵循四个步骤：

获取每个用户的凭据，以及根据工作流可能需要提供的任何额外参数。请参阅上方的获取用户凭据。
为此用户创建n8n凭证。请参阅上方的创建用户凭证。
创建工作流。
根据需要调用工作流。

创建工作流#

此工作流程的详细内容和范围会根据具体用例而有很大差异，但有几个设计实现需要注意：

此工作流必须由Webhook节点触发。
传入的webhook调用必须包含用户的凭据以及所需的任何其他工作流参数。
每个需要使用用户凭据的节点都应使用表达式，以便节点的凭据字段读取webhook调用中提供的凭据。
保存并激活工作流，确保为Webhook节点选择了生产URL。更多信息请参考webhook node。

调用工作流#

对于每个新用户或任何现有用户（根据需要），调用定义为工作流触发器的webhook，并提供必要的凭据（以及其他工作流参数）。