n8n 工作流
AI-Corporate 可以通过生产环境 webhook 启动 n8n 工作流。当你想在 AI-Corporate 之外启动自动化流程时,这很有用,例如创建任务、更新 CRM 记录、启动报告流程,或将表单数据转发到其他系统。
示例:公司网站上的新闻文章
假设组织已经创建了一个 n8n 工作流,用于在公司的 WordPress 网站上发布新闻文章。在 AI-Corporate 中,你只需填写一小段文本,例如关于客户案例、活动或内部里程碑的几句话。然后用这段文本启动 n8n 中的工作流。
n8n 工作流之后可以例如:
- 使用 LLM 节点和适合组织语气的提示词,将简短文本整理成一段正式的草稿。
- 使用第二个 LLM 节点生成合适的插图,例如采用品牌色和易于识别的插画风格。
- 将文本和图片作为博客文章准备好或直接发布到 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 工作流
管理员按如下方式注册工作流:
- 前往 Assistenten。
- 打开 Workflow assistenten 选项卡。
- 在顶部卡片中点击 Nieuwe workflow,然后选择 n8n workflow。
- 填写工作流名称和 n8n 生产环境 URL。
- 使用 header name 和 secret header value 设置 Header authentication。
- 在 Terugmeldingen uit n8n 下,只勾选这个 n8n 工作流中实际构建的部分:进度、审批和/或工作流结束。
- 如有需要,添加要在 POST 请求中发送的字段。
- 保存工作流。
这三个回调选项默认都是关闭的。如果你之后在 n8n 中添加了回调或审批步骤,也要同步更新 AI-Corporate 中的注册信息。这样对话框就知道是只显示启动确认,还是需要继续等待后续信号。
字段
- 字段是可选的。
- 每个字段有一个字段名和一个类型。
- 支持的字段类型有短文本、长文本、数字、是/否、日期、单选和多选。
- 对于 单选 和 多选,需要添加可用选项。单选 会以紧凑的下拉列表显示;多选 会显示复选框。所选值会作为 JSON 体发送。
- 必填字段必须先填写,工作流才能启动。
- 字段名会成为发送到 n8n 的 JSON 体中的 key。
在 n8n 中创建兼容工作流
- 在 n8n 中创建一个新工作流。
- 添加一个 Webhook 节点作为第一个节点。
- 将该节点精确命名为 Start workflow。下面的示例表达式会使用这个名称。
- 将 HTTP Method 设为 POST。
- 选择 Authentication: Header Auth,并使用与 AI-Corporate 中相同的 header 名称和密钥值。
- 将 Respond 或 Response Mode 设为 Immediately。
- 将 Production URL 复制到 AI-Corporate 中的 n8n productie-url 字段。不要使用带有
/webhook-test/的测试 URL。 - 激活工作流。
接收到的数据位于 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 时,才使用这些回调。
按如下方式设置每个回调节点:
-
选择 Method: POST。
-
在 URL 处点击 Expression 并粘贴:
{{ $('Start workflow').first().json.body.integration.callbackUrl }} -
选择 Authentication: None。
-
打开 Send Headers 并添加以下 headers。
-
打开 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:
-
创建一个带有 Error Trigger 节点的新工作流。
-
然后添加一个 HTTP Request 节点,并将 Method 设为 POST。
-
在 URL 中填入以下固定生产环境 URL:
https://europe-west1-ai-corporate.cloudfunctions.net/n8nWorkflowExecutionFailed -
选择 Authentication: None,并添加带有平台管理员默认密钥值的
n8n-handihow-nameheader。 -
选择 JSON body 并粘贴:
{
"executionId": "{{ $json.execution.id }}",
"workflowId": "{{ $json.workflow.id }}",
"workflowName": "{{ $json.workflow.name }}",
"lastNode": "{{ $json.execution.lastNodeExecuted }}",
"message": "{{ $json.execution.error.message }}"
}
- 激活 Error Workflow。
- 打开普通工作流的设置,并在 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中允许的字符。