检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“对象存储服务OBS”。 设置事件目标参数。 图1 对象存储服务OBS 表1 对象存储服务OBS参数说明 参数名称 说明 AK 请输入AK。 说明： 如何获取AK/SK，请参考如何获取访问密钥AK/SK。
创建函数”，具体详情请参见创建函数。 进入新建的函数详情页。 在“代码”页签，代码选择“上传自ZIP文件”，上传样例代码中的程序包。 在“设置 > 环境变量”页签，输入环境信息，完成后单击“保存” 表1 参数说明 参数 说明 obs_endpoint index.py文件中定义的
左上角单击，配置事件流名称和描述，完成后单击“确定”。 配置Kafka事件源。 单击“事件源”，右侧弹出“事件源”弹窗。 事件提供方选择“分布式消息服务 Kafka版”。 设置事件源参数。 图1 事件源-Kafka 表1 配置参数说明 参数名称 说明 实例 选择Kafka实例。 Topic 选择Topic。 消费组
size Integer 本页数量 最小值：0 最大值：100 items Array of ConnectionInfo objects 对象列表 数组长度：0 - 100 表5 ConnectionInfo 参数 参数类型 描述 id String 事件源ID name String
）或第三方事件流入的事件数量进行计费，具体详情请参见价格计算器。 事件网格当前提供按需计费模式，这种购买方式比较灵活，按照实际使用量付费，没有最低消费。 华为云服务事件源自身产生发布的事件（任意事件状态变化 ）免费，事件消费免费。
入门实践 当您购买了事件网格后，可通过华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格，通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件，帮助您轻松构建松耦合、分布式的事件驱动架构。 本文介绍事件网格服务的常见实践，帮助您更好的使用事件网格服务。
计费说明 计费项 事件网格根据自定义事件或三方事件流入的事件数量进行计费。具体收费介绍，请参考价格详情。 华为云服务事件源自身产生发布的事件（任意事件状态变化 ）免费，事件消费免费。 表1 EG计费项 计费项 计费说明 自定义（包含云服务租户侧事件产生 ）或三方事件流入的事件数量
flavor flavor object 规格 type String 目标连接类型。目前支持webhook：http连接；kafka：华为云官方kafka实例 枚举值： WEBHOOK KAFKA kafka_detail KafkaConnectionDetail object
flavor flavor object 规格 type String 目标连接类型。目前支持webhook：http连接；kafka：华为云官方kafka实例 枚举值： WEBHOOK KAFKA kafka_detail KafkaConnectionDetail object
size Integer 本页数量 最小值：0 最大值：100 items Array of ObsBucketInfo objects 对象列表 数组长度：0 - 100 表5 ObsBucketInfo 参数 参数类型 描述 responseHeaders Object 响应头
Refurbishobs 功能介绍 翻新obs fg触发器，创建为EG订阅 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v1/{project_id}
当通知方式选择通知组时，需要在此选择您的通知组，如您还未创建通知组，创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时，需要在此选择您的联系人和主题，若没有您想要选择的主题，创建方式可参考创建通知对象/通知组。 生效时间 该告警仅在生效时间段发送通知消息，非生效时段则在隔日生效时段发送通知消息。
生产顺序性和消费顺序性组合 生产顺序 消费顺序 顺序性效果 设置消息组，保证消息顺序发送。 顺序消费 按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。 设置消息组，保证消息顺序发送。 并发消费 并发消费，尽可能按时间顺序处理。 未设置消息组，消息乱序发送。 顺序消费 按队列存储粒度，严格顺序。
或者到组织追踪器配置的OBS桶中查看，也可以到组织追踪器配置的CTS/system日志流下面去查看。 用户通过云审计控制台只能查询最近7天的操作记录。如果需要查询超过7天的操作记录，您必须配置转储到对象存储服务(OBS)或云日志服务(LTS)，才可在OBS桶或LTS日志组里面查看
访问端点 访问端点用于用户推送自定义事件。 事件网格支持的访问端点如下： 公网访问端点：和区域相关的固定公网域名。 表1 公网访问端点 区域 主域名 备域名 华北-北京四 events.cn-north-4.myhuaweicloud.com events.cn-north-4.myhuaweicloud
变量：从CloudEvents标准事件中获取变量值，将变量值按照模板定义的格式路由到事件目标。 常量：事件只能触发事件目标，但是不会传送事件内容到事件目标，事件网格将您设置的常量路由到事件目标。 关于转换规则的更多示例信息，请参考事件内容转换。
默认为“Rocketmq实例”。 说明： 配置类型根据实例类型变更。 实例别名 请输入实例别名。 说明： 用于标识源端和目标端实例，建议同一个源端或目标端实例只设置一个别名。 区域 请选择资源所在区域。 项目 请选择项目。 Rocketmq实例 请选择Rocketmq实例。 用户名 请输入用户名。 密钥
方案概述 本文介绍如何通过事件网格服务的事件订阅和函数服务实现OBS桶的数据同步。 方案架构 本实践事件订阅架构图如下所示： 图1 事件订阅架构图 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题：
已开通事件网格服务并授权。 已开通函数服务并授权。 已开通OBS服务并授权。 已在OBS开通白名单（联系OBS服务）。 实践流程 创建事件订阅和事件路由流程如下图所示： 图1 流程图 父主题： 基于EventGrid事件订阅和Function实现OBS桶数据同步
默认为“Kafka实例”。 说明： 配置类型根据实例类型变更。 实例别名 请输入实例别名。 说明： 用于标识源端和目标端实例，建议同一个源端或目标端实例只设置一个别名。 区域 请选择资源所在区域。 项目 请选择项目。 Kafka实例 请选择Kafka实例。 接入方式 支持“明文接入”或“密文接入”。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
