前提条件

• 开通事件总线EventBridge并委托授权

• 对象储存打开事件上报开关，详细步骤如下：

  • Python调用OpenAPI示例

  • 结合上述示例，执行如下代码，打开指定存储桶的事件上报开关

    def main():
        params = {
            "regionID": "bb9fdb42056f11eda1610242ac110002", # 华东1地域ID
            "bucket": "您的桶名称",
            "bucketEventBridgeEnabled": True
        }
        result=post("https://zos-global.ctapi.ctyun.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管理控制台中的消息详情