雲訊息佇列 RocketMQ 版

操作步驟

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
        Tag	配置源執行個體中用於過濾訊息的Tag。	test
        Group ID	RocketMQ消費組名稱。 快速创建：推薦方案。如果您選擇自動建立，系統將自動建立以 GID_EVENTBRIDGE_xxx 命名的 Group ID。 使用已有：如果您選擇使用已建立的Group，請選擇獨立的 Group ID，不要和已有的業務混用，以免影響已有的訊息收發。	快速建立
        消费位点	選擇開始消費訊息的位點。 最新位點：從最新位點開始消費。 最早位點：從最初位點開始消費。 指定時間戳記：從指定時間開始消費。	指定時間戳記
        消费时间点	選擇消費時間點。僅當消費點位配置為指定時間戳記時需配置此參數。	2025-03-10 17:27:01
        VPC	為RocketMQ執行個體的VPC ID，系統會自動選擇，無需您手動選擇。	vpc-****
        交换机	為RocketMQ執行個體的交換器ID，系統會自動選擇，無需您手動選擇。	vsw-****
        安全组	支援以下兩種方案。 快速创建：推薦方案，如果您選擇此種方案，會自動建立以eb-毫秒時間戳記-security_group命名的安全性群組。 使用已有：如果您選擇此種方案，需要選擇該VPC下的安全性群組，推薦使用預設安全性群組策略。	快速建立
        資料格式（Body）	資料格式是針對支援二進位傳遞的資料來源端推出的指定內容格式的編碼能力。支援多種資料格式編碼，如無特殊編碼訴求可將格式設定為Json。 Json（預設Json格式編碼，位元據按照utf-8 編碼為Json格式放入Payload。） Text（文字格式設定編碼，位元據按照utf-8編碼為字串放入Payload。） Binary（二進位格式編碼，位元據按照Base64編碼為字串放入Payload。）	Json
        批量推送条数	一次調用函數發送的最大批量訊息條數，當積壓的訊息數量到達設定值時才會發送請求，取值範圍為 [1,10000]。	100
        批量推送间隔（单位：秒）	調用函數的間隔時間，系統每到間隔時間點會將訊息彙總後發送給Function Compute，取值範圍為[0,15]，單位為秒。0秒錶示無等待時間，直接投遞。	3

     2. 在Filtering（过滤）、Transform（转换）及Sink（目标）設定精靈，設定事件過濾、轉換規則及事件目標。事件轉換的配置說明，請參見使用Function Compute實現訊息資料清洗。

   • 任務屬性

     設定事件流的重試策略及無效信件佇列。更多資訊，請參見重試和死信。

4. 返回事件流頁面，找到建立好的事件流，在其右側操作欄，單擊啟用。

   啟用事件流後，會有30秒~60秒的延遲時間，您可以在事件流頁面的状态欄查看啟動進度。

事件樣本

{
    "specversion":"1.0",
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"acs:mq",
    "type":"mq:Topic:SendMessage",
    "subject":"acs:mq:cn-hangzhou:123456789098****:MQ_INST_123456789098****_BXhFHryi%TopicName",
    "datacontenttype":"application/json; charset=utf-8",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunpublishtime":"2021-04-08T06:01:20.725Z",
    "aliyuneventbusname":"BusName",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "UNIQ_KEY":"AC14C305069E1B28CDFA3181CDA2****",
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_123456789098****_BXhFHryi"
        },
        "userProperties":{
        },
        "body":"TEST"
    }
}

CloudEvents規範中定義的參數解釋，請參見事件概述。

data欄位包含的參數解釋如下表所示。