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