Newegg的事件中心之Event Hub

发表于 2021-02-04 更新于 2024-11-04 分类于技术分享本文字数： 1.4k 阅读时长 ≈ 5 分钟

Newegg的事件中心之Event Hub

万事皆事件

事件是信息的一种承载媒介，描述特定对象某一瞬间的非持续性变化，与唯一时刻和唯一对象关联。例如：某台计算机从运行状态变更为关机，程序运行开始和结束，办公大楼停电等。事件是对象在两个不同状态中的变更瞬间的记录。

对于事件，我们关注时间点，什么事件，什么状态。在企业中存在大量的事件，系统事件，监控事件，业务事件等，通过对事件的治理和挖掘，能够发现很多价值，解决切实的痛点。基于以上思考，我们构建了Event Hub。

Event Hub简介

Event Hub是一个高度可缩放、分布式、基于时间序列的事件中心，能够实时的处理流式事件并进行告警和提醒。

Event Hub作为Newegg事件信息中枢，产品化新蛋各产品资源及平台底层基础设施服务生命周期与运转中的重要事件信息，并构建完善的事件消费渠道与流程，支撑线上监控与运维。

Event Hub产品化提供的事件信息，由Newegg内部各产品模块与底层基础设施服务获取，经过聚合，判定和收敛再最终呈现。信息源来自各模块底层的系统日志与监控项，保障客户透传客户的信息准确性与价值。

目前应用场景

企业级监控/告警平台

在Event Hub之前公司监控存在一些问题：

告警不可追溯
告警不可指派
状态可变更很弱
监控信息可视化很弱
没有更好的统计报表

为了解决以上问题，治理企业级监控问题，我们在Event Hub中基于现存的问题，构建了企业级监控平台。俗话说，先挑软柿子捏。

作为企业级监控平台，Event Hub 立足于能够助力发现、定位、解决问题，保障系统与服务整体的稳定与性能。引入事件作为监控的信息载体，能更准确与直接描述资源与底层基础设施服务的运行状态，助力更高效发现、定位从而解决问题。致力于提交信息描述准确性，减少延迟，传递更多的信息，完善监控信息维度，使用通用事件引擎对告警类信息加工处理，尽而告警。

1611048694361

不仅仅是一个告警，而是所有的告警

Event Hub不仅能够接入来自底层基础设施服务例如：Syslog, SNMP, Prometheus, Nagios, Zabbix, Sensu 和 netdata。任何监控工具和系统都可以很容易通过URL方式将告警信息的集成。接入成本几乎为零，降低各个系统接入的难度，统一一个平台，在一个平台上管理很查看不同的告警。

灵活的警报格式。记录对你重要的事情

大多数的监控系统强制你按照它的格式去做，但是Event Hub不同，你可以自由发送任何值的警报。单个警报可以与多个服务关联，具有任何格式的任意数量的“标签”，并且允许任意数量的自定义属性。

{
  "severity": "major",
  "eventId": "714f866ba2ec43775cd6bbda65ff65bd6091bc3a26e9f9f61045014e7746dc09",
  "resource": "5XX Error",
  "origin": "API Gateway",
  "eventType": "alert",
  "type": "apigatewayAlert",
  "environment": "EC",
  "createTime": "2021-01-20T01:44:10.894Z",
  "service": [
    "Desktop-Shopping"
  ],
  "postDate": 1611107052262,
  "attributes": {
    "apiName": "Desktop-Shopping",
    "owner-email": "........",
    "categoryName": "Website API (PCI)",
    "moreInfo": "<a href=\"https://xxxxxxxxx/xxxxxxx/apis/xxxxxxxxxxxx/monitor?env=prd&location=e4\">API Gateway Monitor</a>",
    "apiId": "xxxxxxxxxxxxxxx",
    "categoryId": "xxxxxxxxxxxxxxxxxxxxxxxx"
  },
  "location": "E4",
  "text": "51 5XX calls in the past 5 minutes. ",
  "event": "API (Desktop-Shopping) Has 5XX Issue in prd e4",
  "value": 51,
  "status": "open",
  "timestamp": 1611107050996
}