检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
EventStreamingSource 参数 参数类型 描述 source_kafka SourceKafkaMQParameters object 华为云DMS版kafka类型事件源 source_mobile_rocketmq SourceMobileMQParameters object
EventStreamingSource 参数 是否必选 参数类型 描述 source_kafka 否 SourceKafkaMQParameters object 华为云DMS版kafka类型事件源 source_mobile_rocketmq 否 SourceMobileMQParameters object
图4 配置事件源参数 单击“确定”，完成事件源的配置。 配置事件目标。 单击“事件目标”，参考图5，设置事件目标参数。 选择提供方：选择“华为云” 事件目标：选择“FunctionGraph（函数计算）” 函数：选择步骤三中创建的“test”函数 版本：选择“latest” 类型：选择“透传”
EventStreamingSource 参数 是否必选 参数类型 描述 source_kafka 否 SourceKafkaMQParameters object 华为云DMS版kafka类型事件源 source_mobile_rocketmq 否 SourceMobileMQParameters object
当通知方式选择通知组时，需要在此选择您的通知组，如您还未创建通知组，创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时，需要在此选择您的联系人和主题，若没有您想要选择的主题，创建方式可参考创建通知对象/通知组。 生效时间 该告警仅在生效时间段发送通知消息，非生效时段则在隔日生效时段发送通知消息。
解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为源端实例。 原因二：目标端RocketMQ实例版本不支持，请选择符合要求的实例。 解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。
创建事件路由 事件路由概述 事件路由基于SmartConnect实现能力同步数据的同步。 前提条件 业务有自己的源kafka和目标kafka。 需要给EG授权，第一次进入EG时，会自动为用户创建名为EG_EVENT_ROUTER_AGENCY的授权。 确保vpc、子网、kafka等资源充足。
社区版RocketMQ 本章节介绍在事件流里添加社区版RocketMQ事件源的方法。 目前支持RocketMQ的开源版本：4.9.7/5.1.4。 前提条件 已有社区版RocketMQ集群实例。 当源端为社区版RocketMQ时，目标端只支持选择FunctionGraph（函数计算）。
专享版事件流集群 当前仅支持华南-广州。 登录事件网格控制台。 左侧导航栏选择“事件流 > 专享版事件流集群”，进入“专享版事件流集群”页面。 右上角单击“购买集群”，进入配置页面，配置信息介绍如下： 基本配置。 计费模式：默认按需计费。 集群名称：用户自定义。 描述：用户自定义。
"$.data.obs.configurationId", "eTag": "$.data.obs.object.eTag", "sequencer": "$.data.obs.object.sequencer", "key": "$.data.obs.object.key"
选择已创建的集群，如未创建，请参见专享版事件流集群。 作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。 “源数据”和“目标数据”中选择好Kafka实例后，单击“测试连通性”，检查通过后，进入步骤6。 图3 源数据和目标数据配置
用户轻松构建基于EG的业务。 表1 EG最佳实践一览表 最佳实践 说明 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 本章节介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。 基于Serverless版事件流实现Kafka实例之间的数据同步
在实例“基本信息>连接信息”页面，单击SSL证书旁的“下载”。 SSL证书将会下载到本地电脑，名字为“kafka-certs.zip”的文件。 参考创建桶，创建一个OBS桶，桶的区域与Kafka实例区域保持一致，其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文件，在
制台提供的“监控”页面来检索事件通道产生的监控指标和告警信息。 监控指标 表1 监控指标说明 指标ID 指标名称 指标含义 取值范围 测量对象 监控周期（原始值） pub_num 接入事件数量 该指标为单位时间通道接入事件数量 ≥ 0 事件通道 1分钟 pub_success_num
控制台提供的“监控”页面来检索事件流产生的监控指标和告警信息。 监控指标 表1 监控指标说明 指标ID 指标名称 指标含义 取值范围 测量对象 监控周期（原始值） streaming_process_num 处理事件数量 该指标为单位时间处理事件数量 ≥ 0 事件流 1分钟 streaming_success_num
管理项目和企业项目 创建项目并授权 创建项目 进入管理控制台页面，单击右上方的用户名，在下拉列表中选择“统一身份认证”，进入统一身份认证服务页面。选择左侧导航中的“项目”，单击“创建项目”，选择区域并输入项目名称。 授权 通过为用户组授予权限（包括资源集和操作集），实现项目和用户
基本概念 账号 用户注册账号时，账号对其所拥有的资源及云服务具有完全的访问权限，可以重置用户密码、分配用户权限等。由于账号是付费主体，为了确保账号安全，建议您不要直接使用账号进行日常管理工作，而是创建用户进行日常管理工作。 用户 由账号在IAM中创建的用户，是云服务的使用人员，具有身份凭证（密码和访问密钥）。
包括查询单个函数的EG触发器、查询单个函数流的EG触发器。 访问端点管理 包括更新访问端点、删除访问端点、创建访问端点、查询访问端点。 obs桶管理 包括获取obs桶列表。 监控指标管理 包括查询事件通道监控指标数据、查询事件订阅监控指标数据。 事件流管理 包括创建事件流、查询事件流列表、
参考https://tools.ietf.org/html/rfc3339 subject 否 String 事件发生的主题或对象，用以标识哪个具体对象发生了当前事件 响应参数 状态码： 200 表5 响应Header参数 参数 参数类型 描述 X-Request-Id String
参考https://tools.ietf.org/html/rfc3339 subject 否 String 事件发生的主题或对象，用以标识哪个具体对象发生了当前事件 响应参数 状态码： 200 表5 响应Header参数 参数 参数类型 描述 X-Request-Id String
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
