路由到雲訊息佇列 RabbitMQ 版
本文介紹如何在事件匯流排EventBridge控制台添加雲訊息佇列 RabbitMQ 版作為事件流中的服務類型。
前提條件
-
您已購買並部署雲訊息佇列 RabbitMQ 版執行個體，且執行個體處於服务中狀態。具體步驟，請參見步驟二：建立資源。
建立事件流
- 登入事件匯流排EventBridge控制台，在左側導覽列，單擊事件流。
- 在頂部功能表列，選擇地區，然後單擊建立事件流。
-
在创建事件流面板，設定任务名称和描述，配置以下參數，然後單擊保存。
-
任務建立
-
在Source（源）、Filtering（过滤）、Transform（转换）設定精靈，設定事件過濾、轉換規則，單擊下一步。事件轉換的配置說明，請參見使用Function Compute實現訊息資料清洗。
-
在Sink（目标）設定精靈，選擇服务类型為訊息佇列RabbitMQ版，配置以下參數。
參數
說明
樣本
实例ID
選擇已建立的雲訊息佇列 RabbitMQ 版執行個體。
amqp-cn-zvp2pny6****
Vhost
選擇已建立的Vhost。
test
目标类型
-
Exchange：生產者將訊息發送到Exchange，由Exchange將訊息路由到一個或多個Queue中。
-
Queue：每個訊息都會被投入到一個或多個Queue裡。
Queue 模式
Exchange
當目标类型為Exchange時，選擇雲訊息佇列 RabbitMQ 版中的Exchange。
exchange
Queue
當目标类型為Queue時，選擇雲訊息佇列 RabbitMQ 版中的選擇接收訊息的隊列。
queue
消息路由规则（Routing Key）
事件匯流排EventBridge通過JSONPath提取事件中的資料，將指定的事件內容路由到事件目標。當目标类型為Exchange時需要配置。
部分事件
$.data.key消息体（body）
事件匯流排EventBridge通過JSONPath提取事件中的資料，將指定的事件內容路由到事件目標。
部分事件
$.data.bodyMessageId
事件匯流排EventBridge通過JSONPath提取事件中的資料，將指定的事件內容路由到事件目標。
部分事件
$.data.props.messageId自定义属性（Properties）
事件匯流排EventBridge通過JSONPath提取事件中的資料，將指定的事件內容路由到事件目標。
部分事件
$.data.props -
-
-
任務屬性
設定事件流的重試策略及無效信件佇列。更多資訊，請參見重試和死信。
-
-
返回事件流頁面，找到建立好的事件流，在其右側操作欄，單擊啟用。
啟用事件流後，會有30秒~60秒的延遲時間，您可以在事件流頁面的状态欄查看啟動進度。
結果驗證
-
登入雲訊息佇列 RabbitMQ 版控制台，在概览頁面的资源分布地區，選擇地區。
-
在实例列表頁面，單擊目標執行個體名稱。
-
在实例详情頁面的基本信息地區，單擊消息查询。
-
在消息查询頁面，選擇查询方式：為按 Queue 查询所有消息，設定时间范围，然後單擊查询。
查詢結果中顯示一條訊息記錄，表明訊息發送成功。