本文介紹如何在事件總線EventBridge管理控制臺接入自定義事件。
前提條件
開通分布式消息服務Kafka并創建主題。
步驟一:添加自定義事件源
登錄事件總線EventBridge管理控制臺,在左側導航欄,單擊事件總線。
在左側導航欄,單擊對應自定義事件總線的事件源,或點擊右上角快速創建按鈕創建自定義事件總線。
單擊添加事件源,在添加自定義事件源面板,輸入名稱和描述,事件提供方選擇自定義應用,然后單擊確定。
步驟二:創建事件規則
在左側導航欄,單擊事件總線。
在事件總線頁面,單擊步驟一中選中的事件總線,單擊目標總線名稱。
在左側導航欄,單擊事件規則。
在事件規則頁面,單擊添加創建規則。
在創建規則頁面,完成以下操作,詳見圖1:
a.在配置基本信息配置向導,在事件規則名稱文本框輸入規則名稱,在描述文本框輸入規則的描述,然后單擊下一步。
b.在配置事件模式配置向導,匹配模式選擇匹配所有事件,然后單擊下一步。
c.在配置事件目標配置向導,服務類型選擇分布式消息服務Kafka,選擇對應Kafka實例,選擇主題,消息體選擇完整事件,消息鍵值選擇空,然后單擊創建。
圖1 創建事件規則
步驟三:在控制臺中發布事件
登錄事件總線EventBridge管理控制臺,在左側導航欄,單擊事件總線。
在事件總線頁面,找到步驟一中選中的總線,在其右側操作列單擊發布事件。
在發送事件面板,事件源下拉列表選擇已創建的自定義事件源,在事件體代碼框輸入事件內容,然后單擊確定。事件包含的參數規范,請參見事件概述。
(可選項)亦可選擇通過SDK發送事件,詳見SDK概述。
注意 僅自定義事件總線支持通過管理控制臺發布事件。
步驟四:結果驗證
登錄分布式消息服務Kafka管理控制臺。
在左側導航欄,單擊實例列表,選擇目標實例。
在左側導航欄點擊消息查詢頁面,點擊按位點查詢,驗證主題剛才收到的消息是否與步驟三發送的事件內容一致,詳見圖2。
圖2 在分布式消息Kafka管理控制臺消息查詢頁面查詢消息