路由到分布式消息服務RocketMQ
更新時間 2025-06-18 17:55:23
最近更新時間: 2025-06-18 17:55:23
分享文章
本文介紹如何在事件總線EventBridge管理控制臺添加分布式消息服務RocketMQ作為事件流中的服務類型。
前提條件
開通分布式消息服務RocketMQ,并創建實例。
創建事件流
登錄事件總線EventBridge管理控制臺,在左側導航欄,單擊事件流。
在創建事件流面板,設置任務名稱和描述,配置以下參數,然后單擊創建。
在Source(源)、Filtering(過濾)、Transform(轉換)配置向導,設置數據提供方、事件過濾、轉換規則,單擊下一步。事件轉換的配置說明,請參見使用函數計算實現消息數據清洗。
在Sink(目標)配置向導,選擇服務類型分布式消息服務RocketMQ,配置以下參數,如圖1所示。
圖1 創建事件流時選擇目標服務類型為分布式消息服務RocketMQ
創建事件流后,會有30秒~60秒的延遲時間,您可以在事件流頁面的狀態欄查看啟動進度。
參數說明
| 參數 | 說明 | 示例 |
|---|---|---|
| 實例 | 選擇分布式消息服務RocketMQ實例。 | instance-xxx |
| Topic | 選擇RocketMQ實例的Topic。 | topic1 |
| 消息體 | 選擇消息體(Body)的內容,更多內容請參考事件內容轉換。 | 完整事件 |
| 自定義屬性 | 選擇自定義屬性(Properties)的內容,請參考事件內容轉換。 | 空 |
| 索引 | 選擇索引(Keys)的內容,更多的內容,請參考事件內容轉換。 | 空 |
| 標簽 | 選擇標簽(Tags)的內容,更多的內容,請參考事件內容轉換。 | 空 |
結果驗證
使用事件源觸發一個事件事件。
您可以在分布式消息服務RocketMQ管理控制臺確認是否接收到事件。
登錄分布式消息服務RocketMQ管理控制臺,然后在左側導航欄選擇實例列表。
在實例列表頁面單擊目標實例名稱。
在消息查詢頁面,按時間查詢即可查看消息內容,如圖2所示。
圖2 在分布式消息服務RocketMQ管理控制臺中查看消息詳情