本文介紹如何在事件總線EventBridge控制臺添加云消息隊列 RocketMQ 版作為事件流中的服務類型。
前提條件
您已購買并部署云消息隊列 RocketMQ 版實例，且實例處于服務中狀態。具體步驟，請參見創建實例。
創建事件流
- 登錄事件總線EventBridge控制臺，在左側導航欄，單擊事件流。
- 在頂部菜單欄，選擇地域，然后單擊創建事件流。
在創建事件流面板，設置任務名稱和描述，配置以下參數，然后單擊保存。
任務創建
在Source（源）、Filtering（過濾）、Transform（轉換）配置向導，設置事件過濾、轉換規則，單擊下一步。事件轉換的配置說明，請參見使用函數計算實現消息數據清洗。
在Sink（目標）配置向導，選擇服務類型為消息隊列RocketMQ版，配置以下參數。
參數
說明
示例
版本
選擇云消息隊列 RocketMQ 版實例版本。
RocketMQ 4.x
實例ID
選擇已創建的云消息隊列 RocketMQ 版實例。
test
Topic
選擇已創建的Topic。
test
消息體（body）
事件總線EventBridge通過JSONPath提取事件中的數據，將指定的事件內容路由到事件目標。
部分事件
$.data.body自定義屬性（Properties）
選擇模板。您可以自定義一個模板，定義模板里需要的變量，事件總線EventBridge可以提取事件中的字段，按照模板定義的形式進行轉換。
說明如果需要全量傳遞源端的RocketMQ消息的屬性，推薦使用示例中的配置。
變量：
{ "userProperties":"$.data.userProperties", "msgId":"$.data.systemProperties.UNIQ_KEY" }模板：
{ "EB_SYS_EMBED_OBJECT":"${userProperties}", "UNIQ_KEY":"${msgId}" }消息索引（Keys）
事件總線EventBridge通過JSONPath提取事件中的數據，將指定的事件內容路由到事件目標。
部分事件
$.data.systemProperties.KEYS消息標簽（Tags）
事件總線EventBridge通過JSONPath提取事件中的數據，將指定的事件內容路由到事件目標。
部分事件
$.data.systemProperties.TAGS
任務屬性
設置事件流的重試策略及死信隊列。更多信息，請參見重試和死信。
返回事件流頁面，找到創建好的事件流，在其右側操作欄，單擊啟用。
啟用事件流后，會有30秒~60秒的延遲時間，您可以在事件流頁面的狀態欄查看啟動進度。
結果驗證
登錄云消息隊列 RocketMQ 版控制臺，在頂部菜單欄，選擇地域。
在左側導航欄，單擊實例列表。
在實例列表頁面，找到目標實例，在其操作列，單擊詳情。
在左側導航欄，單擊Topic 管理，然后單擊目標Topic名稱。
在Topic詳情頁面，單擊消息查詢頁簽，配置查詢方式和時間范圍，單擊查詢。
