02 用死信队列处理遥测失败消息
本文聚焦于上行链路中最前面的两个上下文access 和 telemetry,以及一个具体问题:遥测消息处理失败时,为什么不直接用 Kafka 自带的死信topic,而要再做一层数据库死信聚合呢? 项目地址:https://github.com/Liyuwen85/iot-alarm-copilot 目录 access 和 telemetry 的关系 Kafka 死信 ...
本文聚焦于上行链路中最前面的两个上下文access 和 telemetry,以及一个具体问题:遥测消息处理失败时,为什么不直接用 Kafka 自带的死信topic,而要再做一层数据库死信聚合呢? 项目地址:https://github.com/Liyuwen85/iot-alarm-copilot 目录 access 和 telemetry 的关系 Kafka 死信 ...
iot-alaram-copilot 项目是笔者在学习IoT平台后端开发过程中,开源的样板示例工程;目标是切近生产环境,掌握IoT平台的业务设计和架构。项目实现从“设备模拟上报”、“Broker转发”、到“Kafka缓冲队列”、再到“后端接入层处理”、“热点时序数据分层存储”、“规则处理”、和“告警处置”等各环节功能,形成一条最小化的、相对完整的“上行”处理链路,加深学习与理解。 项...