路由到雲訊息佇列RocketMQ版
本文介紹如何在事件匯流排EventBridge控制台添加雲訊息佇列 RocketMQ 版作為事件流中的服務類型。
前提條件
建立事件流
-
登入事件匯流排EventBridge控制台，在左側導覽列，單擊事件流。
-
在頂部功能表列，選擇地區，然後單擊建立事件流。
-
在创建事件流面板，設定任务名称和描述，配置以下參數，然後單擊保存。
-
任務建立
-
在Source（源）、Filtering（过滤）、Transform（转换）設定精靈，設定事件過濾、轉換規則，單擊下一步。事件轉換的配置說明，請參見使用Function Compute實現訊息資料清洗。
-
在Sink（目标）設定精靈，選擇服务类型為訊息佇列RocketMQ版，配置以下參數。
參數
說明
樣本
版本
擇RocketMQ執行個體版本。支援以下兩個版本：
-
RocketMQ 4.x
-
RocketMQ 5.x
RocketMQ 5.x
实例ID
選擇已建立的雲訊息佇列 RocketMQ 版執行個體。
rmq-cn-77845****
Topic
選擇已建立的Topic。
test
Vpc
為RocketMQ執行個體的VPC ID，系統會自動選擇，無需您手動選擇。
vpc-****
交换机
為RocketMQ執行個體的交換器ID，系統會自動選擇，無需您手動選擇。
vsw-****
安全性群組
支援以下兩種方案。
-
快速创建：推薦方案，如果您選擇此種方案，會自動建立以eb-毫秒時間戳記-security_group命名的安全性群組。
-
使用已有：如果您選擇此種方案，需要選擇該VPC下的安全性群組，推薦使用預設安全性群組策略。
快速建立
消息体（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詳情頁面，單擊消息查询頁簽，配置查询方式：和时间范围，單擊查询。
查詢結果以列表形式展示訊息記錄，包含 Message ID、Tag、Key、產生時間、儲存時間 等欄位。在 操作 列可單擊 訊息軌跡 查看詳情。若列表中成功返回訊息記錄，則表示訊息發送成功。