首页 > 其他分享 >【Azure Event Hub】关于Event Hub指标 ConsumerLag 的解释

【Azure Event Hub】关于Event Hub指标 ConsumerLag 的解释

时间:2024-09-25 21:52:00浏览次数:10  
标签:Outgoing 消费 Incoming Hub Azure Message Event

问题描述

在使用Azure Event Hub的过程中,需要监控消费端是否正常消费数据?而常规的指标只有 Incoming Message, Outgoing Message,是否指标能表明当前Event Hub消费滞后,即 Incoming 数量远远大于 Outgoing呢?

  • IncomingMessages :发布到事件中心的消息数。
  • OutgoingMessages :从事件中心使用的消息数。

常规思路是用 Incoming  - Outgoing, 但如果Event Hub有多个消费组消费的时候(比如5个),那么 Outgoing 会是 Incoming的5倍。而且消费一条消息的时候,可能会出现重复多次消费的情况,所以Outgoing 会远远大于Incoming。

【Azure Event Hub】关于Event Hub指标 ConsumerLag 的解释_Azure

问题解答

通过查看资料,发现在"高级"和“专用”的Event Hub中,有一个ConsumerLag指标,就是表示Incoming和Outgoing之间的延迟。但是,它有两种情况为0的时候:

1)如果当时没有消费的consumer和event hub连接的话,它的值是0。

2)如果消息被及时消费,没有积压数据,值为0。

第一种情况的0为异常状态,第二种情况的0为正常状态。

所以如果使用0作为一个指标条件,则会出现误判。

但是在根据 Incoming Message > 0 或  Outgoing  Message = 0 条件结合,则可以满足 Event Hub是否有滞后的判断。

 

参考资料

Azure 事件中心的监视数据参考 : https://learn.microsoft.com/zh-cn/azure/event-hubs/monitor-event-hubs-reference#application-metrics-logs

 


当在复杂的环境中面临问题,格物之道需:浊而静之徐清,安以动之徐生。 云中,恰是如此!

标签:Outgoing,消费,Incoming,Hub,Azure,Message,Event
From: https://blog.51cto.com/u_13773780/12112025

相关文章

  • Vulnhub靶机:Depth: 1
    0x01项目地址Depth:10x02靶机描述Manytimeswhileconductingapentest,Ineedtoscriptsomethinguptomakemylifeeasierortoquicklytestanattackideaorvector.RecentlyIcameacrossaninterestingcommandinjectionvectoronawebapplicatio......
  • Vulnhub靶机:The Ether: EvilScience
    0x01项目地址TheEther:EvilScience(v1.0.1)0x02靶机描述ThegoalistofindoutwhatTheEtherisupto.Youwillberequiredtobreakintotheirserver,rootthemachine,andretrievetheflag.目标是找出TheEther的意图。你需要侵入他们的服务器,获取ro......
  • 【Azure Event Hub】关于Event Hub指标 ConsumerLag 的解释
    问题描述在使用AzureEventHub的过程中,需要监控消费端是否正常消费数据?而常规的指标只有IncomingMessage,OutgoingMessage,是否指标能表明当前EventHub消费滞后,即Incoming数量远远大于Outgoing呢?IncomingMessages:发布到事件中心的消息数。OutgoingMessages:从事件中心......
  • Server-Sent Events (SSE) Koa2 & Nginx & React 实践
    Server-SentEvents(SSE)Koa2&Nginx&React实践得鹿梦鱼前端+node全栈,骑马找马中,有兴趣可私聊​关注他 在现代Web应用中,实时数据传输变得越来越重要。Server-SentEvents(SSE)是一种轻量级的技术,允许服务器向客户端主动发送更新。本文将详细介......
  • fetchEventSource使用+源码解析
    fetchEventSource使用+源码解析nonhana杭电大三学生,喜欢搞前端。​关注他创作声明:包含AI辅助创作12人赞同了该文章前言最近由于一些乱七八糟的原因,接触到了国内开发的一些类ChatGPT的API的前端调用与功能集成。概括的来说,就是有一......
  • Server-Sent Events 教程
    Server-SentEvents教程作者: 阮一峰日期: 2017年5月27日服务器向浏览器推送信息,除了 WebSocket,还有一种方法:Server-SentEvents(以下简称SSE)。本文介绍它的用法。一、SSE的本质严格地说,HTTP协议无法做到服务器主动推送信息。但是,有一种变通方法,就是服务器向客户端声......
  • GitHub上图像超分开源项目推荐【持续更新】
    SRCNN介绍:SRCNN(Super-ResolutionConvolutionalNeuralNetwork)是一种用于图像超分辨率的卷积神经网络。它由Dong等人在2014年提出,是早期的深度学习方法之一,用于提高图像的分辨率。SRCNN通过学习低分辨率(LR)图像到高分辨率(HR)图像的映射关系,来重建高分辨率图像。GitHub星数:2......
  • 【Azure Policy】在Azure Policy的规则中实现数组对数组的规则校验
    问题描述在之前的博文“ 【AzurePolicy】添加策略用于审计Azure网络安全组(NSG)规则--只能特定的IP地址允许3389/22端口访问 ”中,介绍了对固定IP地址,端口的审计规则。只是在实际使用中,发现端口和IP都可以输入多个值,并且以“,”号分割,最终在Azure的NSG资源中,显示为数组格......
  • cnblogs的GitHub同步markdown文件的blog如何识别文章的唯一性(身份ID如何判定)
    本篇blog是写在GitHub的对应的仓库中的。cnblogs会给终身用户提供一个把GitHub仓库中的markdown文件同步到cnblogs上的一个服务,本文就是使用这个服务同步到个人blog地址的:https://cnblogs.com/xyz问题1:何时触发blogs的同步?当仓库中的markdown文件有更新时,cnblogs会自动同......
  • github pages使用cloudflare加速自定义域名概要
    首先,整个操作涉及三个管理方githubpagescloudflare的DNS解析设置自定义域名的解析设置其次,你需要知悉这些内容DNS及CNAME解析githubpages的基本部署域名的基础管理cloudflare的基本域名添加及解析管理概要步骤githubpages部分在githubpages页面,先启用部署(Build......