fawney19
203cd5a9d5
fix(redis): 按事件循环隔离 Redis 连接，防止子线程 asyncio.run 导致连接泄漏
RedisClientManager 新增 _redis_by_loop 字典，按 event loop id 维护独立连接，
避免 usage consumer 在 asyncio.to_thread + asyncio.run 场景下复用主循环连接。
同步重构 consumer_streams 的写库路径：_apply_record_event 统一走
record_usage_batch，_apply_streaming_event 改为 to_thread 执行同步 DB 操作，
移除冗余的 session 传递和手动 rollback 逻辑。
2026-03-18 17:56:48 +08:00
..
2026-02-16 11:00:48 +08:00
2026-03-09 18:26:53 +08:00
2026-02-28 11:45:04 +08:00
2026-02-04 02:04:54 +08:00
2025-12-18 02:20:53 +08:00
2026-03-12 17:11:14 +08:00
2026-03-17 16:34:09 +08:00
2026-02-16 11:00:48 +08:00
2026-03-03 17:24:22 +08:00
2026-03-14 11:59:07 +08:00
2026-03-14 01:33:08 +08:00
2026-02-09 11:37:41 +08:00
2026-03-09 14:54:45 +08:00
2026-02-27 13:54:46 +08:00
2026-03-07 15:33:29 +08:00
2026-02-27 13:54:46 +08:00
2026-03-15 00:23:19 +08:00
2026-03-15 00:23:19 +08:00
2026-02-06 16:37:06 +08:00
2026-03-18 12:35:57 +08:00
2026-02-05 15:59:41 +08:00
2026-03-05 15:15:26 +08:00
2026-03-07 15:33:29 +08:00
2026-02-16 11:00:48 +08:00
2026-03-14 11:59:07 +08:00
2026-03-10 23:14:05 +08:00
2026-03-10 10:40:50 +08:00
2026-02-01 17:28:00 +08:00
2026-03-09 22:57:23 +08:00
2026-03-10 12:47:50 +08:00
2026-03-17 16:34:09 +08:00
2026-03-18 12:35:57 +08:00
2026-03-08 00:05:48 +08:00
2026-03-16 01:12:35 +08:00
2026-03-10 10:40:50 +08:00
2026-03-10 10:40:50 +08:00
2026-02-27 13:58:58 +08:00
2026-03-04 22:06:19 +08:00
2026-03-05 09:53:23 +08:00
2026-03-10 10:40:50 +08:00
2026-03-04 22:06:19 +08:00
2026-03-14 11:59:07 +08:00
2026-03-05 09:53:23 +08:00
2026-03-05 15:15:26 +08:00
2026-03-04 22:06:19 +08:00
2026-03-04 22:51:02 +08:00
2026-02-27 13:58:58 +08:00
2026-03-04 22:06:19 +08:00
2026-03-15 16:56:58 +08:00
2026-03-12 01:11:35 +08:00
2026-03-12 01:11:35 +08:00
2026-03-05 02:07:34 +08:00
2026-02-28 16:54:37 +08:00
2026-03-10 14:55:48 +08:00
2026-03-14 01:33:08 +08:00
2026-02-28 14:12:08 +08:00
2026-03-03 09:22:20 +08:00
2026-03-16 01:12:35 +08:00
2026-03-10 10:40:50 +08:00
2026-03-02 12:27:51 +08:00
2026-03-03 09:22:20 +08:00
2026-02-27 13:54:46 +08:00
2026-03-15 23:13:11 +08:00
2026-02-07 02:59:02 +08:00
2026-02-27 13:54:46 +08:00
2026-03-01 23:55:26 +08:00
2026-02-01 17:28:00 +08:00
2026-03-14 11:59:07 +08:00
2026-02-07 02:59:02 +08:00
2026-03-17 02:57:36 +08:00
2026-03-15 23:46:01 +08:00
2026-03-09 22:57:23 +08:00
2026-03-18 13:43:39 +08:00
2026-03-18 13:43:39 +08:00
2026-03-07 15:33:29 +08:00
2026-03-18 13:43:39 +08:00
2026-01-22 14:23:33 +08:00
2026-02-06 16:37:06 +08:00
2026-03-01 23:32:48 +08:00
2026-03-01 23:55:26 +08:00
2026-03-14 11:59:07 +08:00
2026-03-18 17:56:48 +08:00
2026-03-11 16:12:36 +08:00
2026-03-09 22:57:23 +08:00
2026-03-11 15:11:33 +08:00
2026-03-08 14:31:15 +08:00
2026-03-15 14:22:59 +08:00
2026-03-10 14:42:33 +08:00
2026-03-08 00:05:48 +08:00
2026-03-11 15:11:33 +08:00
2026-03-07 15:33:29 +08:00
2026-03-11 15:11:33 +08:00
2026-03-09 22:57:23 +08:00