本文介绍如何在事件总线EventBridge控制台为事件源微消息队列MQTT版创建连接器。

前提条件

注意事项

事件总线EventBridge不支持直接从微消息队列MQTT版的Topic拉取事件。您可以通过微消息队列MQTT版的数据流出功能,将数据流转到消息队列RocketMQ版的Topic中,并通过事件总线EventBridge消息队列RocketMQ版连接器实现与微消息队列MQTT版的集成。

步骤一:创建数据流出规则

  1. 在左侧导航栏,选择规则管理 > 创建规则
  2. 创建规则面板,单击数据流出页签。
  3. 数据流出页签,按提示填写以下参数,单击确定
    参数 取值示例 说明
    规则ID 111111 规则的全局唯一标识,说明如下:
    • 只能包含字母、数字、横划线(-)和下划线(_),至少包含一个字母或数字。
    • 名称长度限制在3~64字符之间,长于64字符将被自动截取。
    • 创建后无法更新。
    规则描述 migrate to rocketmq 对规则的描述。
    状态 启用 是否启用当前规则,取值说明如下:
    • 启用
    • 禁用
    数据源
    Topic TopicA 指定您需导出数据的源Topic。
    流转目标
    说明 当前仅支持消息队列RocketMQ版
    云产品 消息队列RocketMQ 指定您需将源Topic的数据转发至的目标云产品。
    实例ID MQ_INST_13801563067*****_BbyOD2jQ 指定的目标云产品的实例ID。
    Topic Topic_test 指定的目标云产品的资源键值,即消息队列RocketMQ版的Topic。源Topic的数据将流转至Topic_test。
    您可以在规则管理的规则列表查看到刚创建的数据流出规则。

步骤二:创建消息队列RocketMQ版连接器

  1. 登录事件总线EventBridge控制台
  2. 在左侧导航栏,单击自定义总线
  3. 在顶部菜单栏,选择地域。
  4. 自定义总线页面,找到目标总线,在其右侧操作列单击连接器管理
  5. 连接器页面,单击创建连接器
  6. 单击消息队列RocketMQ版,完成以下操作,然后单击创建并启动
    • 名称:输入连接器名称。
    • RocketMQ实例:选择已创建的消息队列RocketMQ版实例。
    • Topic:选择已创建的Topic。
    • 可选:Tag:输入过滤标签。
    • 消费位点:选择消费位点。默认为最新位点。

事件示例

{
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"acs:mq",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:123456789098****:MQ_INST_123456789098****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunpublishtime":"2021-04-08T06:01:20.725Z",
    "aliyuneventbusname":"BusName",
    "data":{
        "topic":"TopicName",
        "systemProperties":{

        },
        "userProperties":{

        },
        "body":"TEST"
    }
}

CloudEvents规范中定义的参数解释,请参见事件概述