检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
分布式消息服务RocketMQ版 本章节介绍在事件流里添加分布式消息服务RocketMQ版事件源的方法。 前提条件 已在分布式消息服务RocketMQ版中购买RocketMQ实例。 当源端为分布式消息服务RocketMQ版时，目标端只支持选择FunctionGraph（函数计算）。
分布式消息服务RocketMQ版 本章节介绍在控制台添加分布式消息服务RocketMQ版自定义事件源的方法。 前提条件 （可选）创建自定义事件源前，需要先创建自定义事件通道。 已购买分布式消息服务RocketMQ版实例，实例中已创建Topic，且实例状态处于“运行中”。具体步骤，请参考购买实例。
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码： 200 表4 响应Body参数
基于Serverless版事件流实现RocketMQ推送事件至函数工作流服务 本文介绍如何通过事件网格服务的事件流功能将RocketMQ产生的事件推送至函数工作流服务。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
分布式消息服务RabbitMQ版 本章节介绍在控制台添加分布式消息服务RabbitMQ版自定义事件源的方法。 分布式消息服务RabbitMQ版当前支持局点：上海一、上海二、北京四、华北-乌兰察布一、华南-广州。 前提条件 （可选）创建自定义事件源前，需要先创建自定义事件通道。 已
支持CloudEvents SDK和API。 高并发&高可用 支持千万级事件并发。 服务可用性99.99%，采用分布式集群化部署，具备极强的容灾能力。 安全可靠 对接统一身份认证服务、云日志服务、云监控服务和云审计服务等安全管理服务，全方位保护事件的存储与访问。 持久化数据支持磁盘和用户指定密钥加密，进一步提高数据的安全性。
事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下： 云服务事件通道：由事件网格自动创建、且不可修改的一条默认的云服务事件通道，用于接收云服务事件源产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定义事件通道：您自行创建的事件通道，用于接收自定义事件源产生的事件。
当通知方式选择通知组时，需要在此选择您的通知组，如您还未创建通知组，创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时，需要在此选择您的联系人和主题，若没有您想要选择的主题，创建方式可参考创建通知对象/通知组。 生效时间 该告警仅在生效时间段发送通知消息，非生效时段则在隔日生效时段发送通知消息。
当通知方式选择通知组时，需要在此选择您的通知组，如您还未创建通知组，创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时，需要在此选择您的联系人和主题，若没有您想要选择的主题，创建方式可参考创建通知对象/通知组。 生效时间 该告警仅在生效时间段发送通知消息，非生效时段则在隔日生效时段发送通知消息。
解决方式：返回配置专业版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为源端实例。 原因二：目标端RocketMQ实例版本不支持，请选择符合要求的实例。 解决方式：返回配置专业版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选
终端节点 终端节点即调用API的请求地址，不同服务不同区域的终端节点不同，您可以从地区和终端节点中查询服务的终端节点。 父主题： 使用前必读
选择已创建的集群，如未创建，请参见专业版事件流集群。 作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。 图1 源数据和目标数据配置 表2 源数据和目标数据配置参数说明 参数 说明 配置类型 默认为“Rocketmq实例”。
请选择认证机制为“SCRAM-SHA-512”或“PLAIN”。 用户名 请输入用户名。 密码 请输入密码。 配置“任务对象配置”。 图4 任务对象配置 表3 任务对象配置参数说明 参数 说明 Topics 选择“正则表达式”或“输入/选择”。 说明： 当选择“正则表达式”时需在下方输入表达式。
选择已创建的集群，如未创建，请参见专业版事件流集群。 作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。 “源数据”和“目标数据”中选择好Kafka实例后，单击“测试连通性”，检查通过后，进入步骤6。 图1 源数据和目标数据配置
支持地域 支持在分布式消息服务Kafka版之间创建事件流的地域有：华东-上海一、华东-上海二、华北-北京四、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题： 基于Serverless版事件流实现Kafka实例之间的数据同步
创建自定义事件源失败的原因？ 创建分布式消息服务RabbitMQ版或分布式消息服务RocketMQ版事件源其状态为“创建失败”或“异常”，可能是以下原因导致： 未创建私网访问端点。 检查是否创建所需私网访问端点，其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同，具体步骤，请参考创建私网访问端点。
也可以通过对应虚拟私有云和子网的目标连接来连接私网webhook。 支持添加分布式消息服务Kafka版作为目标连接。 Webhook就是客户端或者代理客户端提供一个webhook的url，服务器有新数据时就往url推送数据，客户端通过探测随时更新数据。 Webhook的url，需支持tls1
事件网格实际费用是由事件流入的数量构成，具体内容如表1所示。 如您需要快速了解EG服务的具体价格，请参见EG价格详情。 表1 事件网格计费项 计费项 计费项说明 适用的计费模式 计费公式 自定义（包含云服务租户侧事件产生 ）或三方事件流入的事件数量 根据事件流入的数量按量计费，价格计算可参考EG价格详情。
事件网格计费模式概述 事件网格采用按需付费方式，无最低费用，即总费用 = 请求次数费用 *请求次数（单位：百万）。 如您需要快速了解EG服务的具体价格，请参见EG价格详情。 父主题： 计费模式
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
