检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
的所有事件流事件数据。 您也可以根据需要选择“近1小时”“近3小时”“近12小时”“近24小时”“近7天”“近30天”,分别查看不同时段的事件流事件数据。 图1 事件流监控 事件流监控支持自定义时间跨度,可自定义选择查询的时间区间。 开启“自动刷新”后,指标数据会每5s刷新一次。
所有接入事件数据。 您也可以根据需要选择“近1小时”“近3小时”“近12小时”“近24小时”“近7天”“近30天”,分别查看不同时段的接入事件数据。 图1 事件通道监控 事件通道监控支持自定义时间跨度,单击,可自定义选择查询的时间区间。 开启“自动刷新”后,指标数据会每5s刷新一次。
控,如不选择,则查看全部监控指标。 开启“自动刷新”后,指标数据会每5s刷新一次。 点击“查看更多指标详情”,可跳转至云监控CES界面。 当“周期”选择为原始值时,监控数据为原始数据;当“周期”选择为具体时间时,监控数据可选择“平均值”、“最大值”、“最小值”、“求和值”、“方差值”的聚合算法。
在“事件订阅”页面,单击订阅名称所在行的“监控”,查看事件投递监控数据。 支持查看单个事件目标的监控数据。 支持查看最近1小时、最近4小时、最近24小时、最近7天和自定义时间的监控数据。 支持选择周期(1分钟、5分钟、20分钟)和方法(平均值、最大值、最小值)查看监控数据。 在“事件通道”页面,单击通道名称所在行的“监控”,查看事件接入监控数据。
在OBS目标桶查看对象是否已完成同步 该数据同步功能默认同步后路径一致,在目标桶桶目录下查看文件是否同步成功: 图1 目标桶目录 父主题: 实施步骤
单击“下一步:源和目标对象配置”,进入“源和目标对象配置”页面。 “源数据”和“目标数据”中选择好Kafka实例后,单击“测试连通性”,检查通过后,进入步骤6。 图1 源数据和目标数据配置 表2 源数据和目标数据配置参数说明 参数 说明 配置类型 默认为“Kafka实例”。 说明:
基于Serverless版事件流实现Kafka实例之间的数据同步 本文介绍如何应用事件网格EventGrid的Serverless版事件流功能实现分布式消息服务Kafka版实例间的数据同步。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
参考图1,设置桶参数。关于桶参数的详细介绍,请参考创建桶。 区域:与事件网格所在区域保持一致 桶名称:输入示例如“eg-obs” 默认存储类别:选择“标准存储” 桶策略:选择“私有” 默认加密:不勾选 归档数据直读:选择“关闭” 企业项目:选择“default” 图1 创建桶 配置完成后,
String 指标数据统计方式 缺省值:AVG 枚举值: AVG MIN MAX period 否 Integer 指标数据统计周期(单位minute) 缺省值:1 start_time 是 Long 获取指标数据起始时间 end_time 否 Long 获取指标数据结束时间 channel_id
String 指标数据统计方式 缺省值:AVG 枚举值: AVG MIN MAX period 否 Integer 指标数据统计周期(单位minute) 缺省值:1 start_time 是 Long 获取指标数据起始时间 end_time 否 Long 获取指标数据结束时间 subscription_id
设置桶参数。关于桶参数的详细介绍,请参考创建桶。 表1 桶参数配置 参数 说明 区域 事件网格与所在区域保持一致。 桶名称 输入示例如“eg-test”。 默认存储类别 按需选择。 桶策略 按需选择。 默认加密 按需选择。 归档数据直读 按需选择。 企业项目 按需选择。 配置完成后,单击“立即创建”,根据提示信息完成桶的创建。
产品优势 稳定运行保障 高性能、高可靠。 数据一致性 预校验、一致性校验。 立体化监测无忧运维 监控定位、故障恢复。 数据处理 ETL,边同步边处理。 降低成本 规格丰富,按需计费。 降低开发成本 开箱即用,生态丰富,无码对接。 父主题: 专业版事件流
选择“消息查询”,分别查看源端topic和目标端topic的“消息体”。 图3 目标端消息 图4 源端消息 如消息一致,则Kafka实例间的数据同步成功。 父主题: 基于Serverless版事件流实现Kafka实例之间的数据同步
对话机器人服务 CBS 关系型数据库 RDS 云解析服务的Region级 DNS 存储容灾服务 SDRS 语音通话 VoiceCall 应用性能管理 APM 应用编排服务 AOS 数据接入服务 DIS 数据库安全服务 DBSS 慧眼HiLens HiLens 云数据迁移 CDM 多活高可用服务
基于EventGrid事件订阅和Function实现OBS桶数据同步 方案概述 操作流程 实施步骤
表3 生产顺序性和消费顺序性组合 生产顺序 消费顺序 顺序性效果 设置消息组,保证消息顺序发送。 顺序消费 按照消息组粒度,严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。 设置消息组,保证消息顺序发送。 并发消费 并发消费,尽可能按时间顺序处理。 未设置消息组,消息乱序发送。
件都符合。 创建事件订阅时,如果选择的OBS桶有被其他事件订阅调用,请确保当前桶的对象名前缀和后缀与其他事件订阅中配置的对象名前缀和后缀不一致。否则,保存事件订阅时,会报“OBS桶对象名前缀或后缀冲突”错误。 步骤 登录事件网格控制台。 在左侧导航栏选择“事件订阅”,进入“事件订阅”页面。
buffer并认为已经发送,没有任何保障可以保证此种情况下server已经成功接收数据。 Leader Only:表示至少要等待leader已经成功将数据写入本地log,但是并没有等待所有follower是否成功写入,如果follower没有成功备份数据,而此时leader又无法提供服务,则消息会丢失。
方案概述 本文介绍如何通过事件网格服务的事件订阅和函数服务实现OBS桶的数据同步。 方案架构 本实践事件订阅架构图如下所示: 图1 事件订阅架构图 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题:
None 操作指导 事件网格 EG 介绍怎样创建华为云服务事件订阅 03:08 创建华为云服务事件订阅 事件网格 EG 介绍怎样创建自定义事件订阅 02:59 创建自定义事件订阅 事件网格EG 介绍怎样实现跨账号事件发送 05:07 跨账号事件发送演示 应用实践 事件网格 EG 创建自定义事件源到https链路