对象存储与函数计算集成后，对象存储事件能触发相关工作流执行，实现对对象存储中的数据的自定义处理。

背景信息

对象存储和工作流通过对象存储触发器实现无缝集成，可以编排工作流对对象存储事件进行自定义处理，当对象存储捕获到指定类型的事件后，对象存储事件触发相应的工作流执行。例如，可以设置工作流来处理PutObject事件，当上传图片到对象存储后，相关联的工作流会自动被触发来处理该图片。

对象存储和工作流集成后，可以自由地调用各种工作流处理图像或音频数据，再把结果写回到多种存储服务中。整个架构中，只需要专注于工作流逻辑的编写，系统将以实时的、可靠的、大规模并行的方式处理海量的数据。

前提条件

创建事件总线类触发器前，需要先确认开通事件总线对工作流的服务委托，赋予事件总线调用工作流的权限。

对象存储事件定义

当对象存储系统捕获到相关事件后，会将事件信息编码为JSON字符串，传递给事件处理函数。

已支持的对象存储事件定义如下表所示。

触发器触发规则

避免循环触发

使用对象存储触发器时，请注意避免循环触发。例如，一个典型的循环触发场景是对象存储的某个bucket上传文件事件触发工作流执行，此工作流执行完成后又生成了一个或多个文件再写回到对象存储的bucket里，这个写入动作又触发了工作流执行，形成了链状循环。

为了避免循环触发工作流产生不必要的费用，建议配置文件前缀或文件后缀，例如将触发工作流的文件的文件前缀设置为 src，工作流执行完成后生成文件的文件前缀设置为 dst，生成的文件将不会再次触发工作流。如果不设置文件前缀和文件后缀，表示匹配任意文件前缀和文件后缀。

操作步骤

1. 登录工作流控制台，点击目标工作流，进入工作流详情详情。

2. 在配置选项卡中，选择左边的 工作流调度 选项卡。

3. 点击 创建工作流调度，在弹出的右抽屉中选择 对象存储触发器，配置参数解释如下表。

配置项说明如下。

开通事件上报

并非所有Bucket都会主动上报事件，需要通过对象存储产品的Openapi打开指定Bucket的事件上报，方法步骤如下：

1. Python调用openapi示例

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

   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()
    

3. 接口返回以下内容即可

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

触发工作流的入口参数

对象存储触发器事件源会以CloudEvents模板作为输入参数传递给工作流。

参数具体格式如下所示。

{
    "id": "1723530386.250878.3f7f5c***",
    "source": "ctyun.zos",
    "specversion": "1.0",
    "type": "s3:ObjectCreated:Post",
    "subject": "ctyun.zos:b342b77ef26b11e***:5d4ce56a08db4a***:bucket-***:abc.txt",
    "time": "2024-03-05T13:52:18.374Z",
    "data": {
        "userIdentity": {
            "principalId": "testuser_sub1"
        },
        "responseElements": {
            "x-amz-request-id": "ec2906f5-e72t-494f-9aa1-f621108***",
            "x-amz-id-2": "1286b9-zone2-zon***"
        },
        "s3": {
            "bucket": {
                "name": "bucket-***",
                "ownerIdentity": {
                    "principalId": "testuser"
                },
                "arn": "arn:aws:s3:::bucket-***",
                "id": "ec2906f5-e72f-494f-9aa1-f6211***"
            },
            "object": {
                "key": "abc.txt",
                "size": 417791,
                "etag": "3f7f 5c925b10c789e3e1389***",
                "versionId": "",
                "sequencer": "92FCBA66FA6***",
                "metadata": []
            }
        }
    },
    "datacontenttype": "application/json;charset=utf-8",
    "ctyunaccountid": "5d4ce56a08db4ac19***",
    "ctyunuserid": "usertest-userid",
    "ctyunresourceid": "",
    "ctyuneventbusname": "default",
    "ctyunregion": "b342b77ef26b11ecb0***"
}
 

Event参数中不同属性字段的解释如下表所示。