检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
则事件不通。 如果当前通道没有关联订阅，发布到该通道的消息将无法消费，所以需要新增订阅，下游事件订阅的事件源和上游订阅的事件源名称保持一致，且下游的事件源必须是自定义事件源。 委托 委托 请选择委托。（请确保您选择的委托被授权的权限包含eg:channels:putEvents。）
事件网格服务对事件源中的信息是明文处理，如事件源中的事件包含敏感信息，请自行对敏感信息进行加密处理，做好敏感信息防护。 父主题： 事件源
”。详细操作，请参考添加安全组规则。 入方向规则需要放通的协议端口最小集需要包括： ICMP: 全部 TCP: 5672 TCP: 15672（从RabbitMQ实例的“基本信息”页面的“连接信息”页签中可以获取需要放通的TCP端口。） 图1 RabbitMQ入方向规则 配置分布
事件网格（EventGrid，EG）是华为云提供的一款Serverless事件总线服务，支持华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格，通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件，帮助您轻松构建松耦合、分布式的事件驱动架构。 文档 图说ECS
创建自定义事件模型 事件模型（Schema）用于定义事件的结构。事件网格支持的事件模型如下： 云服务事件模型：事件网格为华为云服务事件源产生的事件提供Schema。每个华为云服务事件源的事件类型对应一个云服务事件模型。 自定义事件模型：针对发送到自定义通道的事件，您可以自定义Schema，也可以通
事件网格（EventGrid，简称EG）专业版事件流作为易用、稳定、高效的数据同步管道连接不同的系统与服务，支持中间件数据在线实时同步。事件流围绕云中间件，降低了中间件之间数据流通的复杂性，有效地帮助您减少数据传输的成本。适用于上云、跨云、云内跨地域中间件数据搬迁和备份容灾等场景，为
返回结果 状态码 请求发送以后，您会收到响应，包含状态码、响应消息头和消息体。 状态码是一组从1xx到5xx的数字代码，状态码表示了请求响应的状态，完整的状态码列表请参见状态码。 对于获取用户Token接口，如果调用后返回状态码为“201”，则表示请求成功。 响应消息头 对应请求
实施步骤 创建OBS源桶和目标桶 创建FG函数 创建EG事件订阅 发送OBS事件 在事件追踪中查看事件投递信息 在函数服务的监控中查看代码执行详情 在OBS目标桶查看对象是否已完成同步 父主题： 基于EventGrid事件订阅和Function实现OBS桶数据同步
归档数据直读：选择“关闭” 企业项目：选择“default” 图1 创建桶 配置完成后，单击“立即创建”，根据提示信息完成桶的创建。 父主题： 实施步骤
按需选择。 默认加密 按需选择。 归档数据直读 按需选择。 企业项目 按需选择。 配置完成后，单击“立即创建”，根据提示信息完成桶的创建。 以上述流程构建源桶与目标桶。 父主题： 实施步骤
置Topic的消息类型是其它类型时，则该消息类型的Topic消息将不会被同步。 前提条件 业务有自己的源RocketMQ和目标RocketMQ。 源RocketMQ和目标RocketMQ实例支持的版本：4.x、5.x。 源RocketMQ和目标RocketMQ实例的规格、Broker数量、存储空间需保持一致。
预检查是创建事件流作业流程中的一环，用来检查用户填写的配置信息是否符合要求。预检查包含多个检查项，详情请参考表1，且每项检查独立执行，检查结果分成功、失败和告警三种类型。 表1 检查项目介绍 项目 内容 源端和目标端实例版本检查 检查源端实例和目标端实例的版本是否匹配。 源端连通性检查
登录事件网格控制台。 在左侧导航栏选择“事件流”，进入“事件流”页面。 单击“创建事件流”。 在弹窗中输入事件流名称和描述，单击“确定”，完成事件流名称和描述信息输入。 配置事件源。 单击“事件源”，右侧弹出“事件源”弹窗。 选择事件源提供方。 设置事件源参数。 完成后单击“下一步”。 配置规则。 单击“规则”，右侧弹出“规则”弹窗。
返回专业版事件流作业列表，单击刚才创建的事件流名称，进入“基本信息”页面，选择“作业管理”，可以查看“同步进展详情”。 图4 Kafka事件流同步进展详情 表4 参数说明 参数名称 说明 Topic名称 创建Kafka实例时的Topic。 分区数 创建Topic时设置的分区数，分区数越大消费的并发度越大。
网络配置。 虚拟私有云：选择已创建的虚拟私有云，如何创建请参见创建虚拟私有云和子网。 子网：选择已创建的子网，如何创建请参见为虚拟私有云创建新的子网。 请确保事件流集群配置的虚拟私有云、子网与Kafka或RocketMQ的源端实例、目标端实例配置的虚拟私有云、子网的网络互通，否则连通性测试不通过。
channel_id String 事件源归属的事件通道ID channel_name String 事件源归属的事件通道名称 type String 事件源类型 detail Object json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机v
事件网格持续增加新的功能，将不可避免对现有接口有所调整，比如增加响应参数。为了减少接口变更带来的影响，除了事件网格自身尽量做到接口向下兼容的同时，用户在使用过程中，应当接受出现返回内容（JSON格式）含有未使用的参数和值的现象，即能够正常忽略未使用的参数和值。 您能创建的事件网格资源的数量与
channel_id String 事件源归属的事件通道ID channel_name String 事件源归属的事件通道名称 type String 事件源类型 detail Object json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机v
事件 事件是符合特定规范的数据。事件源发布到事件网格的事件必须符合CloudEvents规范。 事件网格支持的事件如下。 华为云服务事件：华为云服务事件源产生的事件。 自定义事件：您自定义的事件源接入事件网格产生的事件。您需要自行使用SDK接入事件网格。 约束与限制 单事件大小限制：64K。
触发器”，单击“创建触发器”，弹出“创建触发器”对话框。 图3 创建触发器 设置以下信息。 触发器类型：选择“分布式消息服务（Kafka）”。 实例：选择与死信队列相同的Kafka实例。 主题：选择与死信队列相同的Topic。 批处理大小：每次从Topic消费的消息数量，建议设置为10。 用户名：Kafka实例开
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
