RocketMQ触发器

RocketMQ触发器可以订阅分布式消息服务RocketMQ并根据消息触发关联的工作流，借此能力，使得工作流可以消费指定topic的消息，执行自定义处理逻辑。

注意事项

RocketMQ触发器订阅的RocketMQ实例必须和工作流在相同地域。

前提条件

•  已创建工作流。

•  开通分布式消息服务RocketMQ实例（RocketMQ引擎类型），详情请参考开通RocketMQ实例。

•  创建Topic和GroupID。

•  创建用户，且默认Topic权限设置为：PUB|SUB，默认消费组权限为SUB。详情请参考创建用户。

触发消息格式

有两种消息格式：RawData和CloudEvent格式，可在触发器配置里选择。

CloudEvent格式：

[
    {
        "id": "21000777109E05EF04B574B8A1DF0001",
        "source": "ctyun.faas.trigger.rocketmq",
        "specversion": "1.0",
        "type": "rocketmq:topic:send-message",
        "datacontenttype": "application/json",
        "subject": ":mq-func-hckzeddbxj-rocket-test:test-for-faas",
        "time": "57361-07-03T16:18:39Z",
        "data": {
            "topic": "test-for-faas",
            "properties": {
                "CLUSTER": "1dafcb4049ba42df96d80b7dd2f99c5e",
                "CONSUME_START_TIME": "1747987057130",
                "KEYS": "webtest",
                "MAX_OFFSET": "2",
                "MIN_OFFSET": "0",
                "TAGS": "1747987057097_0",
                "UNIQ_KEY": "21000777109E05EF04B574B8A1DF0001"
            },
            "data": "WebTestTools_174798gjkS"
        }
    }
]

RawData格式 是CloudEvent格式的子集，只包含原始rabbitmq消息的信息，消息结构相当于CloudEvent的data字段，具体如下：

[
    {
        "topic": "test-for-faas",
        "properties": {
            "CLUSTER": "1dafcb4049ba42df96d80b7dd2f99c5e",
            "CONSUME_START_TIME": "1747987204637",
            "KEYS": "webtest",
            "MAX_OFFSET": "3",
            "MIN_OFFSET": "0",
            "TAGS": "1747987204605_0",
            "UNIQ_KEY": "2100077510A605EF04B574BAE2080001"
        },
        "data": "WebTestTools_17v6fg0J"
    }
]

操作步骤

1. 登录工作流控制台，点击目标工作流，进入工作流详情详情。

2. 在配置选项卡中，选择左边的 工作流调度 选项卡。

3. 点击 创建工作流调度，在弹出的右抽屉中选择 RocketMQ触发器，配置参数解释如下表。