雲訊息佇列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
        批量推送间隔（单位：秒）	調用函數的間隔時間，系統每到間隔時間點會將訊息彙總後發送給Function Compute，取值範圍為[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欄位包含的參數解釋如下表所示。