使用RabbitMQ觸發器
更新時間 2025-01-13 16:37:13
最近更新時間: 2025-01-13 16:37:13
分享文章
本章介紹函數工作流如何使用RabbitMQ觸發器。
前提條件
-
已經創建函數。
-
創建RabbitMQ觸發器,必須開啟函數工作流VPC訪問。
-
已經創建RabbitMQ實例。
-
確認實例安全組規則是否配置正確。
- 在RabbitMQ實例詳情頁面的“基本信息 > 網絡”,單擊安全組名稱,跳轉到安全組頁面。
- 選擇“入方向規則”,查看安全組入方向規則。
- 實例未開啟SSL開關
- 如果是VPC內訪問,實例安全組入方向規則,需要允許端口5672的訪問。
- 如果是公網訪問,需要允許端口15672的訪問。
- 實例已開啟SSL開關
- 如果是VPC內訪問,實例安全組入方向規則,需要允許端口5671的訪問。
- 如果是公網訪問,需要運行端口15671的訪問。
- 實例未開啟SSL開關
創建RabbitMQ觸發器
- 登錄函數工作流控制臺,在左側的導航欄選擇“函數 > 函數列表”。
- 選擇待配置的函數,單擊進入函數詳情頁。
- 選擇“設置 > 觸發器”,單擊“創建觸發器”,彈出“創建觸發器”對話框。
- 設置以下信息。
- 觸發器類型:選擇“分布式消息服務RabbitMQ版 (RABBITMQ)”。
- 實例:選擇已創建RabbitMQ實例。
- 交換機名稱:填寫用戶需要使用的交換機名稱。
- 密碼:填寫創建RabbitMQ實例的密碼。
- 虛擬機名稱:填寫用戶自定義的vhost。
- 批處理大小:每次從Topic消費的消息數量。
- 單擊“確定”,完成RabbitMQ觸發器的創建。
說明開啟函數流VPC訪問后,需要在RabbitMQ服務安全組配置對應子網的權限。
配置RabbitMQ事件觸發函數
- 返回函數工作流控制臺,在左側的導航欄選擇“函數 > 函數列表”。
- 選擇待配置的函數,單擊進入函數詳情頁。
- 在函數詳情頁,選擇函數版本。
- 在“代碼”頁簽下,單擊“測試”,彈出“配置測試事件”對話框。
- 填寫如表所示測試信息后,單擊“保存”。
表 測試信息
| 參數 | 說明 |
|---|---|
| 配置測試事件 | 可創建新的測試事件也可編輯已有的測試事件。選擇默認值:“創建新的測試事件”。 |
| 事件模板 | 選擇“rabbitmq-event-template模板”,使用系統內置RabbitMQ事件模板。 |
| 事件名稱 | 事件名稱必須以大寫或小寫字母開頭,支持字母(大寫或小寫),數字和下劃線“_”(或中劃線“-”),并以字母或數字結尾,長度為1-25個字符,例如kafka-123test。 |
| 測試事件 | 自動加載系統內置RabbitMQ事件模板,本例不做修改。 |
- 單擊“測試”,可以得到函數運行結果,函數會返回輸入RabbitMQ消息數據。