检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
移动云RocketMQ版 本章节介绍在事件流里添加移动云 RocketMQ版事件源的方法。 目前支持region:上海二 前提条件 已在移动云购买RocketMQ实例。 当源端为移动云RocketMQ时,目标端只支持选择FunctionGraph(函数计算)。 创建移动云 RocketMQ版事件源
云服务事件源:华为云服务作为事件源,通过预定义的事件类型和事件通道发布事件到事件网格,事件规则对事件进行过滤,然后将过滤后的事件路由到事件目标。华为云支持的云服务事件源列表,请参见云服务事件源。 自定义事件源 您自定义的应用作为事件源,通过自定义的事件通道发布事件到事件网格,事件规则对事件
创建社区版RocketMQ事件源 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进入“Serverless版事件流”页面。 单击“创建Serverless版事件流”,然后单击左上角图标,输入事件流名称和描述,完成后单击“确定”。 单击“事件源”,弹出“配置事件源”对话框。
单击待修改事件源参数的订阅名称,进入订阅详情页。 单击已有事件源模块,弹出“事件源”对话框。 修改事件源配置参数。 已创建的订阅,无法修改事件源提供方。 当提供方为“华为云”时,设置如表1所示参数。 表1 云服务事件源参数说明 参数名称 说明 事件源 选择云服务事件源。 事件类型(可选) 选择事件网格预定义的事件类型。
包括查询单个函数的EG触发器、查询单个函数流的EG触发器。 访问端点管理 包括更新访问端点、删除访问端点、创建访问端点、查询访问端点。 obs桶管理 包括获取obs桶列表。 监控指标管理 包括查询事件通道监控指标数据、查询事件订阅监控指标数据。 事件流管理 包括创建事件流、查询事件流列表、更新事件流、查询事件流详情、删除事件流、操作事件流。
事件网格如何收费? 事件网格根据自定义(包含云服务租户侧事件产生 )或第三方事件流入的事件数量进行计费,具体详情请参见价格计算器。 事件网格当前提供按需计费模式,这种购买方式比较灵活,按照实际使用量付费,没有最低消费。 华为云服务事件源自身产生发布的事件(任意事件状态变化 )免费,事件消费免费。
触发器管理 查询单个函数的EG触发器 查询单个函数流的EG触发器 父主题: API
个Topic。 单击“确定”,完成死信配置。 处理死信队列数据 当数据发送到死信队列后,您可以参考以下方法,来处理死信数据。 登录函数工作流控制台,在左侧的导航栏选择“函数 > 函数列表”。 单击右上方的“创建函数”,进入“创建函数”页面,具体创建步骤请参考创建事件函数。 图2 函数列表
1。 表1 计费项说明 计费项 说明 请求次数 在您使用事件网格的过程中会产生请求次数费用,请求次数是所有事件的请求总数。 计费周期 华为云事件网格EG按照实际使用量付费,没有最低消费。计费模式采用累计分档计费,按天结算,即每日3点后对前一日使用量进行扣费。例如,2023-05-11
规则。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进入“Serverless版事件流”页面。 单击“创建Serverless版事件流”,然后单击左上角图标,输入事件流名称和描述,完成后单击“确定”。 配置Kafka事件源。 单击“事件源”,右侧弹出“事件源”弹窗。
创建分布式消息服务RocketMQ版事件源 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进入“Serverless版事件流”页面。 单击“创建Serverless版事件流”,然后单击左上角图标,输入事件流名称和描述,完成后单击“确定”。 单击“事件源”,弹出“配置事件源”对话框。
将自定义事件源产生的自定义事件发送到事件网格,事件规则对自定义事件进行过滤和转换,通过转换后的事件触发事件目标(即函数工作流服务中的函数)。 前提条件 已开通事件网格服务并授权。 已获取函数工作流的权限。 步骤一:创建自定义通道 登录事件网格控制台。 在左侧导航栏选择“事件通道”,进入“事件通道”页面。
新增查询事件通道监控指标数据接口。 新增查询事件订阅监控指标数据接口。 更新查询事件订阅列表接口名称为查询单个函数的EG触发器接口。 新增查询单个函数流的EG触发器接口。 新增EG.00513002、EG.00513003、EG.00513006、EG.00512002、EG.00512003错误码。
本实践涉及到的资源和成本规划,如下表所示。 表1 资源和成本规划 资源 资源说明 数量 费用(元) 虚拟私有云VPC 创建一个虚拟私有云VPC。 1 00.00 虚拟私有云子网 创建一个虚拟私有云子网。 1 00.00 安全组 创建一个安全组。 1 00.00 对象存储服务OBS 创建一个OBS桶。
单击“事件源”,如图2所示,弹出“事件源”对话框。 图2 配置事件源 选择事件源提供方。 华为云:华为云服务事件源作为事件源提供方。 自定义:您自定义的事件源作为事件源提供方。 设置事件源参数。 当提供方为“华为云”时,设置如表1所示参数。 表1 云服务事件源参数说明 参数名称 说明 事件源 选择云服务事件源。
"data": { "name": "test01", "state": "enable" } }] } 变量 事件流不支持将源端消息内容中的字段进行转换。 从CloudEvents标准事件中获取变量值,将变量值按照模板定义的格式路由到事件目标。示例如下: 转换前的事件
如何在创建事件源为移动云 RocketMQ版的事件流时,获取客户端SDK地址? 用户在创建事件流时,配置事件源为移动云 RocketMQ版实例时,需要配置客户端SDK地址。 本章节介绍如何获取客户端SDK地址。 操作步骤 下载移动云RocketMQ的客户端。 https://ecloud
事件源 分布式消息服务Kafka版 移动云RocketMQ版 社区版RocketMQ 分布式消息服务RocketMQ版 父主题: 事件流
公测期间无商用SLA承诺。 当前暂不支持跨Region、Kafka-OBS(规划中)。 云上云下、跨云厂商需用户侧拉专线。 相关监控指标 2023年9月30日上线。 父主题: 基于Serverless版事件流实现Kafka实例之间的数据同步
String 事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 最小长度:1 最大长度:128 description String 事件流描述 最大长度:255 source EventStreamingSource object 事件源,一个事件流中事件源只有一个