创建事件订阅时，如果选择的OBS桶有被其他事件订阅调用，请确保当前桶的对象名前缀和后缀与其他事件订阅中配置的对象名前缀和后缀不一致。否则，保存事件订阅时，会报“OBS桶对象名前缀或后缀冲突”错误。 步骤 登录事件网格控制台。 在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。
实施步骤 创建OBS源桶和目标桶 创建FG函数 创建EG事件订阅 发送OBS事件 在事件追踪中查看事件投递信息 在函数服务的监控中查看代码执行详情 在OBS目标桶查看对象是否已完成同步 父主题： 基于EventGrid事件订阅和FunctionGraph实现OBS桶数据同步
选择提供方：选择“云服务”。 事件源：选择“OBS应用事件源”。 桶：选择创建OBS桶步骤中创建的桶。 事件类型：下拉框中事件类型根据用户需求勾选。 对象名前缀：若填写，符合规范才能触发事件。默认不填写，表示全匹配。 对象名后缀：若填写，符合规范才能触发事件。
1 00.00 对象存储服务OBS 创建一个OBS桶。 说明： 创建OBS桶免费，使用阶段请参考OBS计费说明。 1 00.00 分布式消息服务 Kafka版 购买一个Kafka实例，按需计费。
配置如下事件目标参数： 选择提供方：华为云 事件目标：分布式消息服务 Kafka版 目标连接：选择“kafka-connect” Topic：选择“topic-eg” 启用消息Key：关闭 规则配置类型：透传。配置转换规则请参考事件内容转换 单击“保存”，完成订阅的配置。
实施步骤 创建VPC、子网和安全组 购买ECS服务器 创建OBS桶 创建目标连接 创建事件订阅 发送OBS事件 在ECS服务器中查看事件消息 父主题： 基于事件订阅将OBS应用事件源消息路由至自定义目标连接
实施步骤 创建OBS桶 购买Kafka实例 创建Kafka目标连接 创建事件订阅 发送OBS事件 查看事件消息 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
在事件追踪中查看事件投递信息 在EG控制台界面，单击“事件通道”中对应的事件通道的“事件轨迹”可以看到该事件的投递详情和事件详情： 界面入口： 图1 界面入口 事件详情： 图2 事件详情 父主题： 实施步骤
创建目标连接 登录事件网格控制台。 左侧导航栏选择“网络管理 > 目标连接”，右上角单击“创建目标连接”。更多关于目标连接的详情请参考目标连接。 类型：选择“WEBHOOK”。 名称：自定义。 描述：自定义。 虚拟私有云：选择创建VPC、子网和安全组步骤中创建的VPC。 子网：选择创建
购买ECS服务器 登录弹性云服务器控制台。 左侧导航栏选择“弹性云服务器”，右上角单击“购买弹性云服务器”，具体配置详情请参考快速购买和使用ECS。虚拟私有云和安全组请选择创建VPC、子网和安全组步骤中创建VPC、子网和安全组。
查看事件消息 登录分布式消息服务Kafka版，选择Kafka实例所在的区域。 在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。 选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。
在函数服务的监控中查看代码执行详情 在“函数列表”中找到进行数据同步的函数。 图1 函数列表 单击监控中对应的请求查看代码日志。 图2 代码日志 父主题： 实施步骤
购买Kafka实例 购买实例 登录分布式消息服务Kafka版，单击页面右上方的“购买Kafka实例”。 配置如下实例参数。更多购买实例参数的详细介绍，请参考购买Kafka实例。
类型：选择“分布式消息服务 Kafka版” 名称：kafka-connect 实例：选择“eg-kafka” SASL_SSL 认证机制：SCRAM-SHA-512 用户名：kafka实例的用户名“kafka-name”， 密码：输入kafka实例密码 确认模式：Leader Only
创建VPC、子网和安全组 登录虚拟私有云控制台。 左侧导航栏选择“我的VPC”，单击右上角“创建虚拟私有云”，具体配置详情请参考创建虚拟私有云和子网。 左侧导航栏选择“安全组”，单击右上角“创建安全组”，具体配置详情请参考创建安全组。同时，在“入方向规则”中请配置一条允许访问8000
在ECS服务器中查看事件消息 返回购买ECS服务器步骤中已打开的CloudShell终端控制台页面。 由于httpsserver.py已启动，此时CloudShell会打印出事件信息。 图1 事件消息 父主题： 实施步骤
华为云对象存储服务（Object Storage Service，简称OBS）作为云服务事件源将产生的云服务事件发送到事件网格，事件规则对云服务事件进行过滤和转换，通过转换后的事件触发事件目标（即函数工作流服务中的函数）。 前提条件 已开通事件网格服务并授权。
通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。
scene_type 是 String 场景类型，DISASTER_BACKUP：同步任务 source_config 否 EventRouterJobSource object 专业版事件流作业源端配置 sink_config 否 EventRouterJobSink object
通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。
