本文介紹如何應用事件總線EventBridge的事件流功能實現消息路由至函數計算。

前提條件

• 開通事件總線EventBridge并授權。

• 開通函數計算并創建對應函數。

• 開通分布式消息服務Kafka并創建最少兩個主題。

背景信息

事件流作為更輕量、實時端到端的流式事件通道，提供輕量級的流式數據的過濾和轉換的能力，在不同的數據倉庫之間、數據處理程序之間、數據分析和處理系統之間進行數據同步。源端分布式消息服務Kafka生產的消息可以通過事件流這個通道被路由到目標端的函數計算，并觸發函數。

步驟一：創建事件流

1. 登錄事件總線EventBridge控制臺。

2. 在左側導航欄，單擊事件流。

3. 在事件流頁面，單擊創建事件流。

4. 在創建事件流面板，設置任務名稱和描述，配置以下參數，然后單擊保存。

   a.在Source（源）配置向導，選擇數據提供方為分布式消息服務Kafka ，設置以下參數，然后單擊下一步。

   參數	說明	示例
   Kafka實例	選擇Kafka實例。	instance-xxx
   Kafka Topic	選擇Kafka topic。	topic-xxx
   Group	選擇消費組。	快速創建
   消費位點	選擇消費位點。	最新位點

   b.在Filtering（過濾）配置向導，設置事件過濾規則，單擊下一步。

   c.在Sink（目標）配置向導，選擇服務類型為函數計算，配置以下參數，單擊保存。

   參數	說明	示例
   函數	選擇函數。	fun-xxx
   函數版本或別名	選擇函數版本或別名。	版本/LATEST
   執行方式	選擇執行函數的方式：同步或異步。	同步
   事件	選擇調用到函數的事件內容，更多內容請參考事件內容轉換。	完整事件

5. 創建事件流后，會有30秒~60秒的延遲時間，您可以在事件流頁面的狀態欄查看啟動進度。

步驟二：測試驗證

1. 登錄分布式消息服務Kafka控制臺。

2. 在左側導航欄，單擊實例列表，選擇事件流的源實例。

3. 在主題管理頁面，選擇源的目標主題，操作列點擊更多，然后點擊生產消息。

4. 在生產消息對話框輸入想要發送的消息，然后點擊發送消息。

5. 發送消息后，登錄函數計算管理控制臺。

6. 在函數頁面，單擊目標函數名稱。 

7. 在目標函數詳情頁面，單擊監控頁簽，查看函數是否被觸發以及調用時延，如圖1所示。

   

   圖1 在函數計算管理控制臺中查看函數監控指標