-
基于事件流实现Kafka实例之间的数据同步 - 事件网格 EG
基于事件流实现Kafka实例之间的数据同步 本文介绍如何应用事件网格EventGrid的事件流功能实现分布式消息服务Kafka版实例间的数据同步。 前提条件 背景信息 支持地域 实施及验证
-
创建自定义事件源失败的原因? - 事件网格 EG
创建自定义事件源失败的原因? 创建分布式消息服务RabbitMQ版或分布式消息服务RocketMQ版事件源其状态为“创建失败”或“异常”,可能是以下原因导致: 未创建私网访问端点。 检查是否创建所需私网访问端点,其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同,具体步骤,请参考创建私网访问端点。
-
目标连接 - 事件网格 EG
对应虚拟私有云和子网的目标连接来连接私网webhook。 支持添加分布式消息服务Kafka版作为目标连接。 Webhook就是客户端或者代理客户端提供一个webhook的url,服务器有新数据时就往url推送数据,客户端通过探测随时更新数据。 Webhook的url,需支持tls1
-
产品功能 - 事件网格 EG
事件网格作为一种Serverless的事件总线服务,支持接入多种类型的事件源和事件目标,提供事件过滤路由的能力。 事件源 事件源是事件的来源,负责生产事件。事件网格支持以下事件源: 华为云服务事件源:华为云服务作为事件源,华为云服务包含弹性云服务器、对象存储服务和云容器引擎等等。 自定义事件源:
-
前提条件 - 事件网格 EG
前提条件 已开通事件网格服务并授权。 已购买Kafka实例。 已创建分布式消息Kafka版类型的目标连接,具体方式请参考目标连接。 单条消息不超过256KB。 公测期间无商用SLA承诺。 当前暂不支持跨Region、Kafka-OBS(规划中)。 云上云下、跨云厂商需用户侧拉专线。
-
构造请求 - 事件网格 EG
对于获取用户Token接口,您可以从接口的请求部分看到所需的请求参数及参数说明。将消息体加入后的请求如下所示,加粗的斜体字段需要根据实际值填写,其中username为用户名,domainname为用户所属的账号名称,********为用户登录密码,xxxxxxxxxxxxxxxxxx为project的名称,如“
-
事件网格 EG - 事件网格 EG
事件网格(EventGrid,EG)是华为云提供的一款Serverless事件总线服务,支持华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格,通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件,帮助您轻松构建松耦合、分布式的事件驱动架构。 文档 图说ECS 立即使用 立即使用
-
创建事件路由 - 事件网格 EG
如果源端kafka和目标端kafka在不同vpc里,但是他们的broker地址存在重叠,这种情况任务也会失败,规避方式是让用户用一个新的vpc打通其中一个kafka的网络,保障源端和目标端的地址不重叠。 创建任务成功后,会生成mm2开头的Topic,此为运行任务资源所需,请勿删除,若删除此任务后,则Topic可删除。
-
分布式消息服务Kafka版 - 事件网格 EG
输入并发数,输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致,如果不一致可能会影响消息消费速率。当您选择Topic时,如果并发数为空会读取您选择的Topic的分区数作为并发数。 消费点位 选择消费点位。 最新点位:将会从消息队列的最新消息开始消费。 最早点位:将会从消息队列的最早消息开始消费。
-
云服务事件源 - 事件网格 EG
云服务事件源 本章节介绍事件网格支持的云服务事件源列表,以及查看云服务事件源预定义的事件类型的方法。 云服务事件源列表 事件网格支持的云服务事件源列表如下: 表1 云服务事件源 云应用引擎 CAE 数据库和应用迁移 UGO Classroom 内容审核 Moderation 虚拟私有云
-
移动云RocketMQ版 - 事件网格 EG
请选择公网或私网。 地址 请输入地址。 客户端SDK 请输入客户端SDK上传到OBS的地址。 说明: 客户端SDK上传到OBS的地址获取方式可参考常见问题。 消费超时时间(毫秒) 请输入1000到900000之间的整数。 消息类型 请选择普通消息。 消费线程数 请输入20到64之间的整数。 批量消费最大消息数
-
典型应用场景 - 事件网格 EG
函数触发器 场景二:云服务事件流转 事件网格作为华为云的标准事件中心,可以实现各个云服务之间的联动。 云服务作为事件源或者事件目标部署在华为云的无服务器(Serverless)应用平台上,应用推送业务实时事件到事件网格,事件网格对事件进行过滤、路由和转化,从而触发订阅事件的云服务。
-
错误码 - 事件网格 EG
00512002 agency permission required 当前账号没有创建委托的权限 请联系您的管理员为您开通创建委托的权限 403 EG.00512003 agency required 所需的委托不存在 请先创建委托 403 EG.00514003 resource quota
-
分布式消息服务RabbitMQ版 - 事件网格 EG
消息队列RabbitMQ版中的实例名称。 用户名 RabbitMQ实例的用户名。 密码 RabbitMQ实例的密码。 Vhost RabbitMQ实例的虚拟主机。 Queue RabbitMQ实例的队列。 单击“确定”,完成自定义事件源的创建。 创建成功后,在“自定义事件源”页签,查看创建的事件源。
-
社区版RocketMQ - 事件网格 EG
当消费点位选择自定义时,需要配置日期时间。 消费超时时间(毫秒) 请输入1000到900000之间的整数。 消息类型 默认为普通消息。 消费线程数 请输入20到64之间的整数。 批量消费最大消息数 请输入1到32之间的整数。 单击“下一步”,进入规则配置页面,规则配置可参考过滤规则参数说明。 图3
-
获取API版本列表 - 事件网格 EG
Array of links objects url地址 version String 若该版本API支持微版本,则为支持的最大微版本号,如果不支持微版本,则为空 min_version String 若该版本API支持微版本,则为支持的最小微版本号,如果不支持微版本,则为空 status
-
创建FG函数 - 事件网格 EG
py文件中定义的存放输出图片的OBS桶参数值your-bucket-output, 创建OBS桶中创建的存放输出图片OBS桶。 添加依赖包。 示例代码依赖pillow包,需要通过依赖包的形式进行引入,步骤如下: 进入创建的函数的详情页,在“代码”页签,单击页面最底部的“添加依赖包”。
-
分布式消息服务RocketMQ版 - 事件网格 EG
单击“确定”,完成自定义事件源的创建。 创建成功后,在“自定义事件源”页签,查看创建的事件源。 如果需要修改自定义事件源的描述信息,单击待修改事件源后的“编辑”,在弹出的对话框中编辑描述及相关参数信息。 如果需要查看自定义事件源的信息,单击待查看信息的事件源名称,在弹出的对话框中查看自定义事件源信息。
-
创建事件流 - 事件网格 EG
String 实例名称,仅dms的rockectMq需要该字段 最大长度:128 instance_id 否 String 实例ID,仅dms的rockectMq需要该字段 最大长度:128 addr 是 String rockectMq连接地址 group 是 String 消费组
-
查询事件流列表 - 事件网格 EG
instance_name String 实例名称,仅dms的rockectMq需要该字段 最大长度:128 instance_id String 实例ID,仅dms的rockectMq需要该字段 最大长度:128 addr String rockectMq连接地址 group String 消费组 最小长度:3