检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
SOURCE：即事件源名称，修改为步骤四：创建事件订阅中配置事件源时记录的“Filter”中“values”值。 TIME：修改事件产生的时间。 DATA：根据实际情况修改，事件内容遵循CloudEvents 1.0规范。 运行发布事件的main函数。 步骤六：查看结果 登录函数工作流控制台。 在左侧导航栏选择“函数
项目和企业项目 项目 IAM中的项目用于将OpenStack的资源（计算资源、存储资源和网络资源）进行分组和隔离。用户拥有的资源必须挂载在项目下，项目可以是一个部门或者项目组。一个账户中可以创建多个项目。 企业项目 企业管理中的企业项目是对多个资源进行分组和管理，在目标区域中同一
acks=0：表示producer不需要等待任何确认收到的信息，副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据，同时重试配置不会发生作用（因为客户端不知道是否失败）回馈的offset会总是设置为-1。 acks=1：这
</dependency> “cloudevents.version”使用最新版本2.2.0。 发布事件 发布事件的示例代码如下（以下加粗内容需要请根据实际情况替换）： import com.alibaba.fastjson.JSONObject; import io.cloudevents.CloudEvent;
cident”，只可选择其中一项。 normal：表示操作成功。 warning：表示操作失败。 incident：表示比操作失败更严重的情况，例如引起其他故障等。 企业项目ID：输入企业项目ID。 访问密钥ID：输入访问密钥ID（包含临时访问凭证和永久访问密钥）。 时间范围：可
操作流程 前提条件 进行本实践操作需要提前完成的事项： 已开通事件网格服务并授权。 已创建虚拟私有云和子网。 已创建安全组。 实践流程 创建事件订阅和事件路由流程如下图所示： 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
Kafka同步Kafka 当前仅支持华南-广州、华东-上海一。 前提条件 业务有自己的源Kafka和目标Kafka。 源Kafka和目标Kafka实例支持的版本：目前支持2.7及以上，后续支持版本会持续更新。 源Kafka和目标Kafka实例的规格、存储空间需保持一致。 确保vpc、子网、kafka等资源充足。
应用场景 迁移 支持通过多种网络链路，实现跨云平台数据同步、云下数据同步上云或云上跨Region的数据同步等多种业务场景。适用于业务割接期数据的整体搬迁上云，支持短期单向同步。 特点：通过增量同步技术，业务运行中可以完成数据库同步，同步不影响业务。 同步 实现数据源之间的数据实时同步
云服务事件源 本章节介绍事件网格支持的云服务事件源列表，以及查看云服务事件源预定义的事件类型的方法。 约束与限制 目前只支持写事件，不支持读事件。 目前只支持云服务事件模型列表中的六个场景，除此以外的点开暂无示例。 云服务事件源列表 事件网格支持的云服务事件源列表如下： 表1 云服务事件源
产品优势 开放兼容 兼容CloudEvents 1.0协议和OpenSchema 1.0协议。 支持CloudEvents SDK和API。 高并发&高可用 支持千万级事件并发。 服务可用性99.99%，采用分布式集群化部署，具备极强的容灾能力。 安全可靠 对接统一身份认证服务、
认证鉴权 调用接口有如下两种认证方式，您可以选择其中一种进行认证鉴权。 Token认证：通过Token认证调用请求。 AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。
分布式消息服务RocketMQ版 本章节介绍在控制台添加分布式消息服务RocketMQ版自定义事件源的方法。 前提条件 （可选）创建自定义事件源前，需要先创建自定义事件通道。 已购买分布式消息服务RocketMQ版实例，实例中已创建Topic，且实例状态处于“运行中”。具体步骤，请参考购买实例。
创建用户并授权使用EG 如果您需要对您所拥有的EG服务进行精细的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），通过IAM，您可以： 根据企业的业务组织，在您的华为云账号中，给企业中不同职能部门的员工创建IAM用户
使用前必读 欢迎使用事件网格服务。 事件网格（EventGrid，简称EG）是华为云提供的一款Serverless事件总线服务，支持华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格，通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件，帮助
授权委托 事件网格服务提供的部分功能需要用到服务权限申请与用户创建委托授权，具体功能请参考表1。 表1 授权委托信息 委托名称 委托方 被委托方 委托服务和权限 涉及服务功能 EG_TARGET_AGENCY 用户 EventGrid EG：EG Publisher 事件网格服务
Kafka预检查 源端和目标端实例版本检查 检查源端和目标端实例的版本是否符合要求，当前要求Kafka实例版本在 3.x和2.7 中，版本不在匹配名单中则提示告警。 原因一：源端Kafka实例版本不支持，请选择符合要求的实例。 解决方式：返回配置专业版事件流作业的第二步，即“源和
成长地图 | 华为云 事件网格 事件网格（EventGrid，EG）是华为云提供的一款Serverless事件总线服务，支持华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格，通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件，帮助您轻松构建松耦合、分布式的事件驱动架构。
RocketMQ预检查 源端和目标端实例版本检查 检查源端和目标端RocketMQ实例的版本是否符合要求，当前要求RocketMQ实例版本在5.x和4.8.0中，版本不在匹配名单中则提示告警。 原因一：源端RocketMQ实例版本不支持，请选择符合要求的实例。 解决方式：返回配置
创建自定义事件源失败的原因？ 创建分布式消息服务RabbitMQ版或分布式消息服务RocketMQ版事件源其状态为“创建失败”或“异常”，可能是以下原因导致： 未创建私网访问端点。 检查是否创建所需私网访问端点，其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同，具体步骤，请参考创建私网访问端点。
专业版事件流集群 当前仅支持华南-广州、华东-上海一。 登录事件网格控制台。 左侧导航栏选择“事件流 > 专业版事件流集群”，进入“专业版事件流集群”页面。 右上角单击“购买集群”，进入配置页面，配置信息介绍如下： 基本配置。 计费模式：默认按需计费。 集群名称：用户自定义。 描述：用户自定义。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
