|
|
c98b83635d
|
fix: 优化指标报告格式,简化日志输出
|
2026-03-02 11:49:02 +08:00 |
|
|
|
e7658dd3bd
|
fix: 修复hotel_id越界问题并更正项目名称
在构建数据库行时,添加了对hotel_id的边界检查,确保其值在PostgreSQL smallint类型允许的范围内(-32768 到 32767)。对于超出范围或非数字的值,现将其设置为0以防止数据库插入错误。同时,将package-lock.json中的项目名称从“bls-rcu-action-backend”更正为“bls-onoffline-backend”。
|
2026-02-26 11:17:26 +08:00 |
|
|
|
8337c60f98
|
feat: 实现Kafka批量消费与写入以提升吞吐量
引入批量处理机制,将消息缓冲并按批次写入数据库,显著提高消费性能。调整Kafka配置参数,优化消费者并发与提交策略。新增分区索引自动创建功能,并重构处理器以支持批量操作。添加降级写入逻辑以处理数据错误,同时增强指标收集以监控批量处理效果。
|
2026-02-09 10:50:56 +08:00 |
|
|
|
a8c7cf74e6
|
feat: 初始化 bls-onoffline-backend 项目基础结构
添加 Kafka 消费者、数据库写入、Redis 集成等核心模块,实现设备上下线事件处理
- 创建项目基础目录结构与配置文件
- 实现 Kafka 消费逻辑与手动提交偏移量
- 添加 PostgreSQL 数据库连接与分区表管理
- 集成 Redis 用于错误队列和项目心跳
- 包含数据处理逻辑,区分重启与非重启数据
- 提供数据库初始化脚本与分区创建工具
- 添加单元测试与代码校验脚本
|
2026-02-04 17:52:22 +08:00 |
|