检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
认证机制,比PLAIN机制安全性更高。 SASL证书地址 当Kafka实例开启SASL SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M;
事件目标 事件目标是事件的处理终端,负责消费事件。 事件网格支持的事件目标如下: 云服务事件目标:已对接事件网格的华为云服务。 自定义事件目标:您自定义的处理事件的服务。
标。 当事件源和事件目标都配置完成后,单击右上角“保存”,完成事件流的创建。 发送到目标端失败时,将重试整批事件,直到处理成功或源端消息过期为止,目标端需支持处理重复事件。 父主题: 事件源
错误码 当您调用API时,如果遇到“APIGW”开头的错误码,请参见API网关错误码进行处理。 状态码 错误码 错误信息 描述 处理措施 400 EG.00513000 invalid parameters 参数错误 请检查参数是否正确 400 EG.00513001 name duplicated
产品优势 稳定运行保障 高性能、高可靠。 数据一致性 预校验、一致性校验。 立体化监测无忧运维 监控定位、故障恢复。 数据处理 ETL,边同步边处理。 降低成本 规格丰富,按需计费。 降低开发成本 开箱即用,生态丰富,无码对接。 父主题: 专业版事件流
事件网格提供了REST(Representational State Transfer)风格API,支持您通过HTTPS请求调用,调用方法请参见如何调用API。 父主题: 使用前必读
到事件目标。 如果需要了解更多转换类型的信息,请参考事件内容转换。 启用死信队列:默认不启用。启用死信队列后EG会把处理失败的事件发送到配置的队列中,若不启用则处理失败的事件将被丢弃。了解更多详情请参考死信队列。 图8 自定义事件目标配置参数 单击“确定”,完成事件目标的配置。 单击“保存”,完成订阅的配置。
设置事件目标参数。 图1 对象存储服务OBS 表1 对象存储服务OBS参数说明 参数名称 说明 AK 请输入AK。 说明: 如何获取AK/SK,请参考如何获取访问密钥AK/SK。 SK 请输入SK。 桶 请选择/输入OBS桶名称。 转储目录 请输入转储目录。 说明: OBS桶中对象的目录,多级目录用“/”分隔。
Serverless版事件流概述 事件流对事件源产生的事件实时拉取、过滤及转换,并路由至事件目标,是一种更为实时、轻量和高效的端到端的流式数据处理场景。 图1 事件流示意图 EG事件流目前处于公测阶段,欢迎您试用和体验相关的功能。 父主题: 事件流
删除自定义事件通道 本章节介绍在事件网格控制台如何删除自定义事件通道。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件通道”,进入“事件通道”页面。 在待删除的自定义事件通道后,单击“删除”,弹出“删除事件通道”对话框。 已关联自定义事件源,或事件订阅的事件通道,无法删除
云服务事件模型 事件模型概述 本文介绍如何在事件网格EventGrid控制台管理Schema,包含创建、查看和删除Schema等操作。 前提条件 云产品官方事件源的事件对应的Schema只支持在控制台上查看Schema详情和Schema版本详情,不支持创建、修改和删除。 操作步骤
相关概念 事件 状态发生改变的数据记录。 事件源 事件的来源,负责生产事件。 事件目标 事件的处理终端,负责消费事件。 事件通道 事件的中转站,负责接收来自事件源的事件。 事件规则 事件发送到事件网格后,会根据事件规则进行过滤,满足规则的事件才会被路由发送到对应的事件目标。
streaming_process_num 处理事件数量 该指标为单位时间处理事件数量 ≥ 0 事件流 1分钟 streaming_success_num 处理成功事件数量 该指标为单位时间处理成功事件数量 ≥ 0 事件流 1分钟 streaming_success_rate 处理事件成功率 该指标为单位时间处理事件成功率
SDK发布事件。 前提条件 获取并安装IntelliJ IDEA,如果未安装,请至IntelliJ IDEA官方网站下载。 在pom.xml中加入依赖。如何在Java环境中集成API请求签名的SDK请参考AK/SK签名认证操作指导。 <dependency> <groupId>io
路由到函数工作流 本章节介绍在创建事件流时如何配置函数工作流 FunctionGraph为事件目标。 前提条件 已开通FunctionGraph并创建函数作为事件目标。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进入“Serverless版事件流”页面。
和高效的端到端的流式数据处理场景。 资源管理 事件网格提供以下资源管理能力: 管理自定义事件源 管理事件通道 管理事件订阅 管理目标连接 管理访问端点 管理事件模型 事件处理 事件网格提供以下事件处理能力: 传输事件 过滤事件 路由事件 事件网格独立处理每个事件。这意味着事件的顺
由于请求的实体过大,服务器无法处理,因此拒绝请求。为防止客户端的连续请求,服务器可能会关闭连接。如果只是服务器暂时无法处理,则会包含一个Retry-After的响应信息。 414 Request-URI Too Large 请求的URI过长(URI通常为网址),服务器无法处理。 415 Unsupported
方案概述 本文介绍如何通过事件网格服务的事件订阅和函数服务实现OBS桶的数据同步。 方案架构 本实践事件订阅架构图如下所示: 图1 事件订阅架构图 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题:
背景信息 事件流作为一种更为实时、轻量和高效的端到端的流式数据处理通道,对事件源产生的事件实时拉取、过滤及转换,并路由至事件目标。源端分布式消息Kafka版生产的消息可以通过事件流这个通道被路由到目标端的分布式消息Kafka版,无需定义事件网格。详情请参见事件流概述。 父主题:
该指标用于统计事件投递的调用成功数量。 单位:个 ≥ 0 counts 事件订阅 1分钟 process_time 处理时间 该指标用于统计事件投递的周期内平均总处理时间。 单位:毫秒 ≥ 0 ms 事件订阅 1分钟 fail_num 失败数量 该指标用于统计事件投递失败且无需重试的事件数量。