检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
自定义应用事件源 本章节介绍在控制台创建自定义应用事件源的方法。 前提条件 （可选）创建自定义应用事件源前，需要先创建自定义事件通道。 创建自定义应用事件源 登录事件网格控制台。 在左侧导航栏选择“事件源”，进入“事件源”页面。 单击“自定义事件源”，弹出“创建自定义事件源”对话框。
检查事件流集群创建页面中配置的vpc和子网是否与源端Kafka实例网络畅通。 检查配置专业版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端Kafka实例的用户名和密码是否正确。 目标端连通性检查 检查事件流作业所在运行时机器是否能正常连接到目标端Kafka实例。 原因一：无法连接目标端Kafka实例，请检查网络配置是否正确。
的要求，不需要创建独立的IAM用户，您可以跳过本章节，不影响您使用事件网格服务的其它功能。 默认情况下，新建的IAM用户没有任何权限，您需要将其加入用户组，并给用户组授予策略或角色，才能使用户组中的用户获得相应的权限，这一过程称为授权。授权后，用户就可以基于已有权限对云服务进行操作。
用场景的操作实践，为每个实践提供详细的方案描述和操作指导，帮助用户轻松构建基于EG的业务。 表1 EG最佳实践一览表 最佳实践 说明 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 本章节介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。
/v1/{project_id}/subscriptions/operation 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。
client.execute(httpPost); } } 参数说明： NAME：IAM用户名。 PASSWORD：IAM 用户密码。 DOMAIN_NAME：IAM domain用户名。 IAM_ENDPOINT：IAM的终端节点，您可以从地区和终端节点中查询服务的终端节点。
items Array of SubscriptionInfo objects 对象列表 数组长度：0 - 100 表5 SubscriptionInfo 参数 参数类型 描述 id String 订阅ID name String 订阅名称 description String 订阅描述 type
租户项目ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数
C 请求参数 表3 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码：
used Array of SubscriptionUsedInfo objects 标签信息 sources Array of SubscriptionSourceInfo objects 订阅源列表 targets Array of SubscriptionTargetInfo objects
X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型 描述 description 否 String 目标连接描述
items Array of SubscriptionInfo objects 对象列表 数组长度：0 - 100 表5 SubscriptionInfo 参数 参数类型 描述 id String 订阅ID name String 订阅名称 description String 订阅描述 type
基于Serverless版事件流实现Kafka实例之间的数据同步 本文介绍如何应用事件网格EventGrid的Serverless版事件流功能实现分布式消息服务Kafka版实例间的数据同步。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
items Array of SubscriptionInfo objects 对象列表 数组长度：0 - 100 表5 SubscriptionInfo 参数 参数类型 描述 id String 订阅ID name String 订阅名称 description String 订阅描述 type
used Array of SubscriptionUsedInfo objects 标签信息 sources Array of SubscriptionSourceInfo objects 订阅源列表 targets Array of SubscriptionTargetInfo objects
SDK 常见问题 了解更多常见问题、案例和解决方案 热门案例 事件网格如何收费？ 事件发布失败的原因？ 事件目标未被触发的原因？ 能否将自定义事件推送到EventGrid？ 如何过滤最终传输到事件目标的事件？ 如何将自定义的事件内容传输到事件目标？ 更多 远程登录 应用容器化改造介绍
域。 在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。 选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。 单击“搜索”，查询消息。 单击“查看消息正文”，弹出“查看消息正文”对话框，查看消息的具体内容。
创建OBS源桶和目标桶 登录OBS控制台。 单击“创建桶”，进入“创建桶”页面。 设置桶参数。关于桶参数的详细介绍，请参考创建桶。 表1 桶参数配置 参数 说明 区域 事件网格与所在区域保持一致。 桶名称 输入示例如“eg-test”。 默认存储类别 按需选择。 桶策略 按需选择。
租户项目ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数
指定查询的目标连接ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码：
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
