跳转到主内容

n8n 工作流

AI-Corporate 可以通过生产环境 webhook 启动 n8n 工作流。当你想在 AI-Corporate 之外启动自动化流程时,这很有用,例如创建任务、更新 CRM 记录、启动报告流程,或将表单数据转发到其他系统。

示例:公司网站上的新闻文章​

假设组织已经创建了一个 n8n 工作流,用于在公司的 WordPress 网站上发布新闻文章。在 AI-Corporate 中,你只需填写一小段文本,例如关于客户案例、活动或内部里程碑的几句话。然后用这段文本启动 n8n 中的工作流。

n8n 工作流之后可以例如:

  1. 使用 LLM 节点和适合组织语气的提示词,将简短文本整理成一段正式的草稿。
  2. 使用第二个 LLM 节点生成合适的插图,例如采用品牌色和易于识别的插画风格。
  3. 将文本和图片作为博客文章准备好或直接发布到 WordPress 网站。

这样,AI-Corporate 和 n8n 就协同工作了:在 AI-Corporate 中,用户选择工作流并填写所需信息;随后 n8n 执行自动化步骤,并确保新闻文章整齐地出现在网站上。

这个集成做什么?​

你可以从工作流概览中启动一个 n8n 工作流。只有生产环境 webhook、POST 和 Header Auth 是必需的。n8n 返回的字段和回调都是可选的,并且可以彼此独立配置。

  • 如果工作流没有字段,会立即调用 webhook。
  • 如果工作流有字段,首先会打开一个表单。用户填写字段后,再点击按钮启动工作流。
  • 填写的值会作为 JSON 一并通过 POST 请求发送到 n8n webhook。
  • 如果没有回调,AI-Corporate 只会确认工作流已启动,后续在 n8n 中继续运行。窗口不会显示加载指示器,并且可以立即关闭。
  • 如果在注册时启用了此项,工作流可以向 AI-Corporate 发送中间步骤或结束通知。
  • 如果在注册时启用了审批,用户可以直接在 AI-Corporate 中进行选择。之后 n8n 会从等待步骤继续执行。

在 AI-Corporate 中创建 n8n 工作流​

管理员按如下方式注册工作流:

  1. 前往 Assistenten。
  2. 打开 Workflow assistenten 选项卡。
  3. 在顶部卡片中点击 Nieuwe workflow,然后选择 n8n workflow。
  4. 填写工作流名称和 n8n 生产环境 URL。
  5. 使用 header name 和 secret header value 设置 Header authentication。
  6. 在 Terugmeldingen uit n8n 下,只勾选这个 n8n 工作流中实际构建的部分:进度、审批和/或工作流结束。
  7. 如有需要,添加要在 POST 请求中发送的字段。
  8. 保存工作流。

这三个回调选项默认都是关闭的。如果你之后在 n8n 中添加了回调或审批步骤,也要同步更新 AI-Corporate 中的注册信息。这样对话框就知道是只显示启动确认,还是需要继续等待后续信号。

字段​

  • 字段是可选的。
  • 每个字段有一个字段名和一个类型。
  • 支持的字段类型有短文本、长文本、数字、是/否、日期、单选和多选。
  • 对于 单选 和 多选,需要添加可用选项。单选 会以紧凑的下拉列表显示;多选 会显示复选框。所选值会作为 JSON 体发送。
  • 必填字段必须先填写,工作流才能启动。
  • 字段名会成为发送到 n8n 的 JSON 体中的 key。

在 n8n 中创建兼容工作流​

  1. 在 n8n 中创建一个新工作流。
  2. 添加一个 Webhook 节点作为第一个节点。
  3. 将该节点精确命名为 Start workflow。下面的示例表达式会使用这个名称。
  4. 将 HTTP Method 设为 POST。
  5. 选择 Authentication: Header Auth,并使用与 AI-Corporate 中相同的 header 名称和密钥值。
  6. 将 Respond 或 Response Mode 设为 Immediately。
  7. 将 Production URL 复制到 AI-Corporate 中的 n8n productie-url 字段。不要使用带有 /webhook-test/ 的测试 URL。
  8. 激活工作流。

接收到的数据位于 body 下;技术集成信息位于 body.integration 下。不要在 Edit Fields、Set 或 Code 节点中将其删除。

JSON body 示例​

如果你定义了名为 prompt、klantnaam、doelgroepen 和 datum 的字段,n8n 可能会收到如下 JSON body。AI-Corporate 会自动添加 integration 对象。

{
"prompt": "Maak een korte samenvatting van de aanvraag.",
"klantnaam": "Voorbeeldorganisatie",
"doelgroepen": ["medewerkers", "klanten"],
"datum": "2026-09-22",
"integration": {
"runId": "chat-document-id",
"tenant": "default",
"callbackUrl": "https://europe-west1-ai-corporate.cloudfunctions.net/n8nWorkflowCallback",
"callbackToken": "tijdelijk-token-voor-deze-uitvoering"
}
}

callback token 只对应一次执行。不要将其存储在日志、固定配置或其他系统中。

可选:回传进度和完成状态​

AI-Corporate 只能显示 n8n 回传的内容。只有在注册时启用了 Tussentijdse voortgang melden 和/或 Het einde van de workflow melden 时,才使用这些回调。

按如下方式设置每个回调节点:

  1. 选择 Method: POST。

  2. 在 URL 处点击 Expression 并粘贴:

    {{ $('Start workflow').first().json.body.integration.callbackUrl }}
  3. 选择 Authentication: None。

  4. 打开 Send Headers 并添加以下 headers。

  5. 打开 Send Body,并选择 Body Content Type: JSON 和 Specify Body: Using JSON。

使用以下 headers:

Authorization: Bearer {{ $('Start workflow').first().json.body.integration.callbackToken }}
Content-Type: application/json

例如,当某个步骤开始时发送如下消息:

{
"tenant": "{{ $('Start workflow').first().json.body.integration.tenant }}",
"runId": "{{ $('Start workflow').first().json.body.integration.runId }}",
"eventId": "document-maken-gestart",
"type": "progress",
"executionId": "{{ $execution.id }}",
"step": {
"id": "document_maken",
"label": "Document maken"
},
"message": "Het document wordt gemaakt."
}
  • 对同一次执行中的每个事件使用唯一的 eventId。
  • 使用清晰的荷兰语 step.label;此文本会显示在应用中。
  • 如果启用了 Het einde van de workflow melden,则在结束时始终发送 type: "completed"、type: "failed" 或 type: "rejected"。
  • 在 completed 中可选地添加一个包含结果的 output 对象。
  • 在 failed 时发送清晰的错误信息。这样执行也会在应用中停止。

可选:在应用中请求审批​

当工作流必须在某个选择之后才能继续时,使用带有 On Webhook Call 的 n8n Wait 节点。在 Wait 节点之前先发送一个 type: "approval_required" 的回调:

将 Wait 节点设置为 Resume: On Webhook Call、HTTP Method: POST 和 Authentication: Header Auth。选择与 Start workflow 相同的 Header Auth 凭据。在 Wait 节点之后添加一个 Switch 节点,并在其中检查 {{ $json.body.decision }}。

{
"tenant": "{{ $('Start workflow').first().json.body.integration.tenant }}",
"runId": "{{ $('Start workflow').first().json.body.integration.runId }}",
"eventId": "controle-document",
"type": "approval_required",
"executionId": "{{ $execution.id }}",
"step": {
"id": "controle_document",
"label": "Document controleren"
},
"approval": {
"question": "Mag de workflow doorgaan?",
"context": "Controleer eerst het gegenereerde document.",
"resumeUrl": "{{ $execution.resumeUrl }}",
"choices": [
{ "value": "approve", "label": "Goedkeuren" },
{ "value": "reject", "label": "Afwijzen" }
]
}
}

用户会在执行窗口中看到这些选项。做出选择后,Wait 节点会收到 decision 等信息。随后可使用例如 Switch 节点来决定正确的后续流程。

选项值只能包含字母、数字、_ 和 -。标签可以使用正常的可读文本。

设置生产环境 callback URL​

AI-Corporate 的生产环境 callback URL 为:

https://europe-west1-ai-corporate.cloudfunctions.net/n8nWorkflowCallback

不要把这个 URL 作为固定文本写进每个 callback 节点。请在 HTTP Request 节点的 URL 字段中选择 Expression,并使用:

{{ $('Start workflow').first().json.body.integration.callbackUrl }}

这样 AI-Corporate 会在每次启动时自动提供正确的生产环境 URL。上面的固定 URL 仅用于测试时检查该表达式是否指向 AI-Corporate,而不是 AI-School 或 AI-Public。

triggerCustomN8nWorkflow、triggerN8nWorkflow 和 resumeN8nWorkflow 这三个 callables 由应用自动调用。你无需在 n8n 中设置这些 URL。

处理错误​

使用类型为 failed 的回调返回预期错误。对于意外的节点错误,还应创建一个中心化的 Error Workflow:

  1. 创建一个带有 Error Trigger 节点的新工作流。

  2. 然后添加一个 HTTP Request 节点,并将 Method 设为 POST。

  3. 在 URL 中填入以下固定生产环境 URL:

    https://europe-west1-ai-corporate.cloudfunctions.net/n8nWorkflowExecutionFailed
  4. 选择 Authentication: None,并添加带有平台管理员默认密钥值的 n8n-handihow-name header。

  5. 选择 JSON body 并粘贴:

{
"executionId": "{{ $json.execution.id }}",
"workflowId": "{{ $json.workflow.id }}",
"workflowName": "{{ $json.workflow.name }}",
"lastNode": "{{ $json.execution.lastNodeExecuted }}",
"message": "{{ $json.execution.error.message }}"
}
  1. 激活 Error Workflow。
  2. 打开普通工作流的设置,并在 Error Workflow 中选择它。

在 Start workflow 之后立即发送至少一个包含 executionId: "{{ $execution.id }}" 的回调。只有这样,AI-Corporate 才能将意外错误关联到正确的执行。

重要限制​

  • 仅支持 webhook 触发器。
  • 仅支持生产环境 webhook URL。
  • 带有 /webhook-test/ 的测试 webhook URL 会被拒绝。
  • 仅支持 POST。
  • 仅支持通用 header authentication。
  • header value 在应用中会被视为机密。
  • callback token 和 resume URL 仅在服务端处理,用户无法直接访问。
  • tenant 会由服务器端根据已登录用户确定,而不是根据浏览器发送的值。

故障排除​

  • 404 或 webhook 未注册:在 n8n 中激活工作流并使用生产环境 URL。
  • 认证错误:检查两个系统中的 header name 和 value 是否完全一致。
  • 数据缺失:检查应用中的字段名是否与 n8n 预期的 key 一致。
  • n8n 中没有请求:检查工作流是否以 webhook trigger 开始并使用 POST。
  • 执行窗口一直转圈:如果你启用了 Het einde van de workflow melden,请检查 n8n 是否发送了最后一个 completed、failed 或 rejected 回调。如果你不预期回调,请在注册时关闭这三个选项。
  • 没有可见进度:检查注册中是否启用了 Tussentijdse voortgang melden,integration 对象是否被保留,以及每个回调是否都有唯一的 eventId。
  • 审批按钮不起作用:检查 Wait 节点、resumeUrl、header authentication,以及 choices[].value 中允许的字符。