结合EG事件通知自动处理OBS桶中的图片

桶是OBS中用于存储对象的容器。本示例中，上传的图片存储在源桶，添加水印后的图片存储在目标桶。如果您已有源桶和目标桶，请跳至步骤二：创建函数。

由于归档存储和深度归档存储类别的桶，需要先手动恢复才能下载和通过URL访问对象，因此本实践暂不支持使用归档存储和深度归档存储类别的桶。

1. 登录控制台，进入创建桶页面。
2. 在创建桶页面，按照下表说明配置相关参数，其他参数保持默认。表中“示例”仅供参考，您也可以根据业务实际情况自行设置。
   关于更多参数配置请参见创建桶。

   参数	示例	描述
   区域	华北-北京四	桶所属区域。请选择靠近您业务的区域，以降低网络时延，提高访问速度。 桶创建成功后，不支持变更区域，请谨慎选择。 须知： 目标桶和源桶必须在同一区域。
   桶名称	piccomp	桶的名称。桶创建成功后，不支持修改名称。 桶名称命名规则如下： 全局唯一，不能与已有的任何桶（包含其他账号创建的桶）名称重复。删除桶后，需等待30分钟才能创建同名桶或并行文件系统。 长度范围为3到63个字符，支持小写字母、数字、中划线（-）、英文句号（.）。 禁止两个英文句号（.）相邻，禁止英文句号（.）和中划线（-）相邻，禁止以英文句号（.）和中划线（-）开头或结尾。 禁止使用IP地址。
   数据冗余存储策略	多AZ存储	选择数据存储在多个可用区或单个可用区。 多AZ存储：数据存储至同区域内的多个可用区（AZ），可靠性更高，同时存储成本相对更高。 桶创建成功后，不支持更改数据冗余存储策略。 多AZ存储桶不支持为桶设置归档存储类别和深度归档存储类别。
   存储类别	标准存储	桶的存储类别。不同的存储类别可以满足客户业务对存储性能、成本的不同诉求。 标准存储：适用于有大量热点文件或小文件，且需要频繁访问（平均一个月多次）并快速获取数据的业务场景。 更多存储类别详情请参见存储类别。
   桶策略	私有	桶的读写权限控制。 私有：除桶ACL授权外的其他用户无桶的访问权限。
   企业项目	default	将桶加入到企业项目中统一管理。如无特殊的企业项目划分和管理需求，此处可直接选择默认企业项目“default”。 如果您想要了解更多关于如何通过企业项目管理OBS桶，具体请参见创建桶中的“企业项目”参数说明。

3. 单击页面右下角的“立即创建”，并确认提示信息。

   创建完成后，将会出现创建成功弹窗，确认后在桶列表页即可看到已创建的桶。

4. 按照以上步骤再创建目标桶piccomp-output。

在OBS源桶中上传图片后，通过EG事件订阅触发函数执行，因此需要创建图片打水印函数。

1. 单击页面左上角的，选择“计算 > 函数工作流 Function Graph”，进入函数工作流控制台。
2. 在左侧导航栏选择“函数 > 函数列表”。
3. 单击“创建函数”。
4. 在“创建函数”页面，按照如下设置参数，其他参数保持默认。

   关于更多参数配置请参见创建函数。

   表3 函数参数说明

   参数	示例	描述
   选择创建方式	创建空白函数	选择创建函数的方式。 此处选择“创建空白函数”，即从头开始自定义创建函数。
   函数类型	事件函数	选择触发函数执行的方式。 事件函数，即通过触发器来触发函数执行。
   区域	华北-北京四	选择要部署函数代码的区域。 此处请选择和源桶、目标桶均相同的区域。
   函数名称	FG_Test	函数名称，命名规则如下： 可包含字母、数字、下划线和中划线。 以大/小写字母开头，以字母或数字结尾。 长度不超过60个字符。
   企业项目	default	将函数加入到企业项目中统一管理。 如无特殊的企业项目划分和管理需求，此处可直接选择默认企业项目“default”。关于企业项目的使用，具体请参见使用企业项目。
   委托名称	OBS_Agency	用于委托函数工作流服务去访问其他其他云服务。 此处需要为函数工作流服务授予OBS的管理员权限（OBS Administrator），授权范围选择“所有资源”。 创建委托请参见委托其他云服务管理资源。
   运行时	Python 3.9	选择用来编写函数的语言。

   图3 创建函数
   

5. 单击“创建函数”，完成函数的创建。
6. 在函数列表中，单击函数名称，进入函数详情页。
7. 上传代码文件。本示例中使用的样例代码文件请参见使用函数为图片添加水印。
   1. 单击“代码”页签右侧的“上传自”，选择“Zip文件”。
   2. 在“上传Zip文件”弹窗，单击“添加文件”，选择下载的样例代码文件“watermark.zip”，并单击“确定”。

      在代码区域产生了一个index.py文件，index.py为函数执行的入口文件。文件中的关键参数说明如下：

      • obs_output_bucket：添加水印后的图片存放的OBS桶（本示例中的目标桶）。
      • obs_region：目标桶所在的区域编号。

8. 添加代码依赖包。样例代码依赖pillow包，需要通过依赖包的形式进行引入。
   1. 在“代码”页签底部，单击“添加依赖包”。
   2. 在右侧的“选择依赖包”弹窗，添加公共依赖包“pillow-7.1.2”，并单击“确定”。

9. 设置环境变量。用来配置图片添加水印后存放的目标桶信息。
   1. 切换至“设置”页签，单击左侧导航列表的“环境变量”。
   2. 单击“编辑环境变量”，在右侧弹窗单击“添加环境变量”。
   3. 添加以下环境变量，并单击右下角的“确定”。

      表4 环境变量

      键	值	说明
      obs_output_bucket	piccomp-output	添加水印后的图片存放的OBS目标桶。 值为步骤一：创建OBS源桶和目标桶中创建的目标桶名称。
      obs_region	cn-north-4	目标桶所在的区域编号。 更多区域编号请参见地区和终端节点。

      

      键“obs_output_bucket”和“obs_region”为7中样例代码里面目标桶的关键参数。

      图4 设置环境变量
      

使用EG通知来作为事件触发器，触发函数执行。即创建EG事件订阅，将事件源、通道和事件目标绑定在一起，事件源（OBS事件）通过通道触发事件目标（函数）执行。

1. 单击页面左上角的，选择“存储 > 对象存储服务 OBS”，进入桶列表页面。
2. 单击源桶名称，进入对象列表页。
3. 在左侧导航栏选择“数据管理 > 事件通知”。
4. 在“EG通知”页签，单击“创建”，进入EG事件订阅详情页。
5. 修改订阅名称。

   单击上方订阅名称旁的，在“修改订阅”弹窗，修改订阅名称后单击“确定”。本示例中订阅名称修改为“subscription-obs”。

6. 配置事件源。
   1. 单击“事件源”，按照如下设置参数，其他参数保持默认。
      关于更多参数配置请参见创建事件订阅。

      表5 事件源参数说明

      参数	示例	描述
      选择提供方	云服务	选择事件源提供方。 云服务，即华为云服务作为事件源提供方。
      事件源	OBS应用事件源	选择云服务事件源。 OBS应用事件源，即通过操作OBS桶内对象的特定行为来产生事件源。
      桶	piccomp	选择产生事件源的OBS桶，即本示例中的源桶。
      事件类型	OBS:DWR:ObjectCreated:PUT OBS:DWR:ObjectCreated:POST OBS:DWR:ObjectCreated:COPY OBS:DWR:ObjectCreated:CompleteMultipartUpload	选择产生事件源的OBS操作。 OBS:DWR:ObjectCreated:PUT：通过页面或Put请求创建或覆盖桶对象。 OBS:DWR:ObjectCreated:POST：使用Post请求创建或覆盖桶对象。 OBS:DWR:ObjectCreated:COPY：使用Copy请求创建或覆盖桶对象。 OBS:DWR:ObjectCreated:CompleteMultipartUpload：通过页面或API请求合并分段任务。

      图5 设置事件源
      
   2. 单击“确定”，完成事件源配置。

7. 配置事件目标。
   1. 单击“事件目标”，按照如下设置参数，其他参数保持默认。

      关于更多参数配置请参见创建事件订阅。

      表6 事件目标参数说明

      参数	示例	描述
      选择提供方	云服务	选择事件目标提供方。 云服务，即华为云服务作为事件目标提供方。
      事件目标	FunctionGraph（函数计算）	选择云服务事件目标。 FunctionGraph（函数计算），即由函数工作流服务执行特定操作。
      函数	FG-Test	选择要执行的函数。 本示例中选择已创建的为图片添加水印的函数FG-Test。
      委托	EG_TARGET_AGENCY	用于委托事件网格服务EG去访问其他云服务。 本示例中需要委托EG去访问函数工作流服务。如无委托，可单击旁边的“创建委托”，将会自动创建名为“EG_TARGET_AGENCY”的委托。
      类型	变量	事件网格EG对事件参数进行转换，通过JSONPath从事件中提取参数，然后把这些参数路由到事件目标。
      参数	如下所示。	需要转换的参数。
      模板	如下所示。	自定义一个包含所需变量的模板，事件网格EG按照模板定义的形式进行转换。

      本示例中，“参数”请填写如下内容：

      {
        "eventVersion": "$.data.eventVersion",
        "eventTime": "$.data.eventTime",
        "requestParameters": "$.data.requestParameters.sourceIPAddress",
        "configurationId": "$.data.obs.configurationId",
        "eTag": "$.data.obs.object.eTag",
        "sequencer": "$.data.obs.object.sequencer",
        "key": "$.data.obs.object.key",
        "size": "$.data.obs.object.size",
        "arn": "$.data.obs.bucket.arn",
        "name": "$.data.obs.bucket.name",
        "ownerIdentity": "$.data.obs.bucket.ownerIdentity.ID",
        "awsRegion": "$.data.eventRegion",
        "eventName": "$.type",
        "userIdentity": "$.data.userIdentity.ID"
      }

      本示例中，“模板”请填写如下内容：

      {
          "Records": [
              {
                  "eventVersion": "${eventVersion}",
                  "eventTime": "${eventTime}",
                  "requestParameters": {
                      "sourceIPAddress": "${requestParameters}"
                  },
                  "s3": {
                      "configurationId": "${configurationId}",
                      "object": {
                          "eTag": "${eTag}",
                          "sequencer": "${sequencer}",
                          "key": "${key}",
                          "size": "${size}"
                      },
                      "bucket": {
                          "arn": "${arn}",
                          "name": "${name}",
                          "ownerIdentity": {
                              "PrincipalId": "${ownerIdentity}"
                          }
                      }
                  },
                  "awsRegion": "${awsRegion}",
                  "eventName": "${eventName}",
                  "userIdentity": {
                      "principalId": "${userIdentity}"
                  }
              }
          ]
      }

      图6 设置事件目标
      
   2. 单击“确定”，完成事件目标配置。

8. 单击页面右上角的“保存”。

向已创建的OBS源桶中上传一张图片，产生OBS事件，使得EG通知去触发函数执行：为上传的图片添加水印，并将处理后的图片存储至已创建的目标桶中。

1. 单击页面左上角的，选择“存储 > 对象存储服务 OBS”，进入桶列表页面。
2. 单击源桶名称，进入对象列表页。
3. 单击搜索框上方的“上传对象”。
4. 在“上传对象”弹窗，单击“添加文件”，选择要上传的图片，其他参数保持默认即可。

   关于更多参数配置请参见上传对象。

5. 单击“上传”。

   在对象列表页可以看到已上传对象，表示上传成功。

   图7 上传对象成功
   

在目标桶中查看图片是否已添加水印。

1. 在桶列表页，单击目标桶名称。
2. 在对象列表页，单击添加水印后的图片名称。
3. 切换至“图片预览”页签，查看图片已添加水印。
   图8 查看水印图片