前提條件

• 開通事件總線EventBridge并委托授權

• 對象儲存打開事件上報開關，詳細步驟如下：

  • Python調用OpenAPI示例

  • 結合上述示例，執行如下代碼，打開指定存儲桶的事件上報開關

    def main():
        params = {
            "regionID": "bb9fdb42056f11eda1610242ac110002", # 華東1地域ID
            "bucket": "您的桶名稱",
            "bucketEventBridgeEnabled": True
        }
        result=post("//zos-global.ctapi.daliqc.cn/v4/oss/put-bucket-event-bridge","", params)
        print(result)
    
    if __name__ == "__main__":
        main()
    

  • 接口返回以下內容即可

    {"message": "SUCCESS", "description": "成功", "statusCode": 800}

步驟一：創建事件規則

1. 在左側導航欄，單擊事件總線。

2. 在事件總線頁面，單擊云服務專用總線default。

3. 在左側導航欄，單擊事件規則。

4. 在事件規則頁面，單擊添加創建規則。

5. 在創建規則頁面，完成以下操作：

     a.在配置基本信息配置向導，在事件規則名稱文本框輸入規則名稱，在描述文本框輸入規則的描述，然后單擊下一步。

     b.在配置事件模式配置向導，匹配模式選擇匹配所有事件，然后單擊下一步。

     c.在配置事件目標配置向導，服務類型選擇分布式消息服務Kafka，選擇對應Kafka實例，選擇主題，消息體選擇完整事件，消息鍵值選擇空，然后單擊創建。

步驟二：產生對象存儲事件

1. 登錄對象存儲管理控制臺。

2. 單擊前提條件中您已打開的桶名，點擊文件管理，點擊上傳文件，等待文件上傳完成，如圖1。

   

   圖1 在對象存儲管理控制臺上傳文件

步驟三：查看官方事件源事件示例

1. 登陸事件總線EventBridge管理控制臺。

2. 點擊default總線，進入云服務專用事件總線詳情頁，單擊左側事件源按鈕。

3. 單擊名為ctyun.zos的事件源，查看事件示例，如圖2。

   

   圖2 查看對象存儲官方事件源的事件列表

步驟四：結果驗證

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

2. 在左側導航欄，單擊實例列表，選擇目標實例。

3. 在左側導航欄點擊消息查詢頁面，點擊按位點查詢，查看事件內容與步驟三中查看的示例是否相符。

   

   圖3 查看分布式消息服務Kafka管理控制臺中的消息詳情