检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
事件网格如何收费? 事件网格根据自定义(包含云服务租户侧事件产生 )或第三方事件流入的事件数量进行计费,具体详情请参见价格计算器。 事件网格当前提供按需计费模式,这种购买方式比较灵活,按照实际使用量付费,没有最低消费。 华为云服务事件源自身产生发布的事件(任意事件状态变化 )免费,事件消费免费。
安全组:default,此处选择前提条件中已准备好的安全组default “更多配置”中配置如下参数: Kafka SASL_SSL:开启 kafka安全协议:SASL_SSL SASL PLAIN 机制:开启 用户名:kafka-name 密码:填写密码 默认密码:确认密码 单击“立即购买”,完成Kafka实例的创建。
死信队列 概述 启用死信队列后EG会把处理失败的事件发送到配置的队列中,若不启用则处理失败的事件将被丢弃。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件订阅”,进入“事件订阅”页面。 单击“创建事件订阅”。 单击“事件目标”。 在弹窗中选择“事件目标”。 启用“死信队列”,并配置参数。
4b26115b-778e-*******-833e-cf74af 事件ID。标识事件的唯一值。 specversion String 是 1.0 CloudEvents协议版本。 source String 是 HC.OBS 事件源。标明事件的来源。 type String 是 object:put 事件类型。标明与事件源相关的事件类型。
错误码 当您调用API时,如果遇到“APIGW”开头的错误码,请参见API网关错误码进行处理。 状态码 错误码 错误信息 描述 处理措施 400 EG.00513000 invalid parameters 参数错误 请检查参数是否正确 400 EG.00513001 name duplicated
如何获取分布式消息服务Kafka实例的SASL证书地址? 用户在创建事件流,配置事件源为分布式消息服务Kafka版实例时,当Kafka实例开启SASL SSL时,需要输入SASL证书地址。 本章节介绍如何获取Kafka实例的SASL证书地址。 操作步骤 下载Kafka实例的SSL证书。
如何在创建事件源为移动云 RocketMQ版的事件流时,获取客户端SDK地址? 用户在创建事件流时,配置事件源为移动云 RocketMQ版实例时,需要配置客户端SDK地址。 本章节介绍如何获取客户端SDK地址。 操作步骤 下载移动云RocketMQ的客户端。 https://ecloud
分布式消息服务Kafka版 本章节介绍在创建事件流时,如何配置分布式消息服务Kafka版实例为事件源。 前提条件 已在分布式消息服务Kafka版中购买Kafka实例,详情请参见购买Kafka实例。 Kafka实例中的安全组在“入方向规则”中放开Kafka实例的子网网段和端口,详情
创建FG函数 本章节提供实现图片压缩功能的程序包,使用空白模板创建函数,样例代码请参见使用函数压缩图片。 创建函数(创建函数的时候,必须选择包含OBS访问权限的委托,否则不能使用OBS服务)。 登录函数工作流控制台,在左侧导航栏选择“函数 > 函数列表”,进入函数列表界面。 单击“创建函数”,进入创建函数流程。
API 事件订阅管理 事件通道管理 事件管理 事件源管理 事件目标分类管理 事件模型管理 目标连接管理 服务委托管理 配额管理 API版本管理 触发器管理 访问端点管理 obs桶管理 监控指标管理 事件流管理 事件示例管理
创建事件订阅 约束与限制 对象名前缀、对象名后缀填写时,对象文件格式必须都符合才能触发事件,当前后缀为空时,任意对象文件都符合。 因目前OBS只对白名单用户开放,请在创建事件订阅前添加OBS白名单。 创建事件订阅时,如果选择的OBS桶有被其他事件订阅调用,请确保当前桶的对象名前缀
实施及验证 约束与限制 事件目标kafka不支持自定义证书。 单消息需保持大小在2M以下。 源端配置操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,右上角单击“创建Serverless版事件流”。 左上角单击,配置事件流名称和描述,完成后单击“确定”。
路由到对象存储服务OBS 本章节介绍在创建事件流时如何配置对象存储服务OBS为事件目标。 前提条件 已开通对象存储服务OBS作为事件目标。 事件源选择为“分布式消息服务 Kafka版”。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”
路由到分布式消息服务Kafka版 本章节介绍在创建事件流时如何配置分布式消息Kafka为事件目标。 约束与限制 事件目标kafka不支持自定义证书。 前提条件 已开通分布式消息Kafka作为事件目标。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverle
查询单个函数的EG触发器 功能介绍 查询触发器,支持指定函数urn,一个以函数urn为目标的订阅为一个触发器。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET
路由到函数工作流 本章节介绍在创建事件流时如何配置函数工作流 FunctionGraph为事件目标。 前提条件 已开通FunctionGraph并创建函数作为事件目标。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进入“Serverless版事件流”页面。
查询单个函数流的EG触发器 功能介绍 查询触发器,支持指定函数流id,一个以函数流id为目标的订阅为一个触发器。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET
按需计费 按需计费是一种先使用再付费的计费模式,适用于无需任何预付款或长期承诺的用户。本文将介绍按需计费EG的计费规则。 适用场景 按需计费适用于事件网格对事件进行过滤、路由和转化。 适用计费项 事件网格实际费用是由事件流入的数量构成,计费项按需计费说明请参见表1。 表1 计费项说明
instance_name String kafka实例名称 最小长度:4 最大长度:64 security_protocol String 安全协议 instance_id String kafka实例ID 最小长度:1 最大长度:256 topic String kafka topic名称
instance_name String kafka实例名称 最小长度:4 最大长度:64 security_protocol String 安全协议 instance_id String kafka实例ID 最小长度:1 最大长度:256 topic String kafka topic名称