Skip to main content

MQ 触发器

MQ 触发器用于从消息队列中消费消息并触发工作流，适合事件驱动架构中对接订单事件、日志流、异步任务等场景。

配置字段​

在 TriggerDef 中，MQ 类型相关字段包括：

  • mqDriver：消息驱动类型，例如 kafka、rabbitmq（具体可用值由后端实现决定）
  • mqQueue：队列或 Topic 名称，用于指定消费来源

这些字段共同决定了 MQ 触发器订阅哪一个消息通道以及使用何种客户端驱动。

创建与更新行为​

当触发器类型为 MQ 时：

  • 创建：通过 POST /linker/workflows/<workflowId>/triggers 创建时，将 type 设置为 MQ 并提供 mqDriver、mqQueue
  • 更新：通过 PUT /linker/triggers/<triggerId> 调整消息来源，例如修改队列名称或驱动类型

根据现有实现：

  • 可更新字段包括 mqDriver 与 mqQueue
  • 其他通用字段（如 enabled、name、workflowApiKey）与 Webhook/Cron 触发器一致