云消息队列RocketMQ版（位点数据）

前提条件

• 开通事件总线EventBridge并授权。

• 创建云消息队列RocketMQ 5.x系列实例或云消息队列RocketMQ 4.x系列实例。

• 创建云消息队列RocketMQ 5.x系列实例的Topic或4.x系列实例的Topic。

操作步骤

1. 登录事件总线EventBridge控制台，在左侧导航栏，单击事件流。
2. 在顶部菜单栏，选择地域，然后单击创建事件流。

3. 在创建事件流面板，设置任务名称和描述，配置以下参数，然后单击保存。

   • 任务创建

     1. 在Source（源）配置向导，选择数据提供方为消息队列 RocketMQ 版（位点数据），设置以下参数，然后单击下一步。

        参数	说明	示例
        地域	选择消息队列RocketMQ版源实例所在的地域。	华东1（杭州）
        版本	选择RocketMQ实例版本。支持以下两个版本： RocketMQ 4.x RocketMQ 5.x	RocketMQ 5.x
        RocketMQ实例	选择生产消息的源云消息队列 RocketMQ版实例。	rmq-cn-jte3w5i****
        Topic	选择生产消息队列RocketMQ版消息的Topic。	topic
        批量推送条数	一次调用函数发送的最大批量消息条数，当积压的消息数量到达设定值时才会发送请求，取值范围为 [1,10000]。	100
        批量推送间隔（单位：秒）	调用函数的间隔时间，系统每到间隔时间点会将消息聚合后发送给函数计算，取值范围为[0,15]，单位为秒。0秒表示无等待时间，直接投递。	3

     2. 在Filtering（过滤）、Transform（转换）及Sink（目标）配置向导，设置事件过滤、转换规则及事件目标。

   • 任务属性

     设置事件流的重试策略和死信队列。

4. 返回事件流页面，找到创建好的事件流，在其右侧操作栏，单击启用。

   启用事件流后，会有30秒~60秒的延迟时间，您可以在事件流页面的状态栏查看启动进度。

事件示例

{
    "datacontenttype": "application/json;charset=utf-8",
    "aliyunaccountid": "1******6789",
    "data": {
        "systemProperties": {
            "BORN_TIMESTAMP": "1713756930836",
            "MSG_REGION": "cn-hangzhou",
            "UNIQ_KEY": "123F486466E118B4AAC26EA24F13****",
            "TAGS": "tagA"
        },
        "userProperties": {
            "demoPropertyKey": "demoPropertyValue"
        },
        "msgId": "123F486466E118B4AAC26EA24F13****",
        "topic": "test-topic",
        "body": {
            "number": 100,
            "name": "EventBridge"
        }
    },
    "subject": "acs:mq:cn-hangzhou:1******6789:rmq-cn-123456abc%test-topic",
    "aliyunoriginalaccountid": "1******6789",
    "source": "RocketMQSource",
    "type": "mq:Topic:SendMessage",
    "aliyunpublishtime": "2024-04-22T03:35:31.315Z",
    "specversion": "1.0",
    "aliyuneventbusname": "DemoBus",
    "id": "123F486466E118B4AAC26EA24F13****",
    "time": "2024-04-22T03:35:30.836Z",
    "aliyunregionid": "cn-hangzhou",
    "aliyunpublishaddr": "172.20.11.11"
}

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

data字段包含的参数解释如下表所示。