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 触发器一致