466 Commits

Author SHA1 Message Date
245c91c9e3 添加测试下发 2025-05-08 11:25:08 +08:00
ChenYi
db7384ae74 完善增量源码生成器 2025-05-08 11:17:43 +08:00
ChenYi
edecbc386e 完善数据通道数据处理,解决数据丢失的问题。 2025-05-08 10:28:23 +08:00
a5ed0a37a0 修改代码 2025-05-08 09:29:31 +08:00
7a18dc4df9 统一字段名称 2025-05-08 09:25:41 +08:00
0de5177472 统一解析字段名称 2025-05-08 09:25:17 +08:00
ChenYi
ac226110cd 合并代码 2025-05-08 08:48:09 +08:00
ChenYi
f71ce3bacb 完善增量源码生成器 2025-05-08 08:43:37 +08:00
ChenYi
c47ee94469 修改代码 2025-05-07 17:27:37 +08:00
ChenYi
ff517664fe 复杂类型增量源生成器 2025-05-07 17:20:10 +08:00
0328aa08d9 提交代码 2025-05-07 17:10:02 +08:00
ChenYi
6b012d9303 完善复杂类型增量源码生成器 2025-05-07 16:37:26 +08:00
cdcf078e5a 优化消费流程 2025-05-07 15:17:54 +08:00
1ae875606f 优化代码 2025-05-07 11:55:26 +08:00
34d4bc0b8f 优化376.1协议插件解析 2025-05-07 11:53:50 +08:00
ChenYi
bca7202558 优化复杂类型增量源生成器 2025-05-07 10:15:45 +08:00
1718a0afa7 调整代码 2025-05-07 08:37:57 +08:00
ChenYi
53e6bb252a 修复15分钟任务Kafka主题异常的问题,新增增量源码工厂类 2025-05-06 23:46:12 +08:00
be4c25519d 优化解析,移除不必要的DTO 2025-05-06 19:25:15 +08:00
1e85f894a8 优化kafka发布消息 2025-05-06 18:41:23 +08:00
c4335aa3b7 修改代码 2025-05-06 15:28:00 +08:00
f96eb27353 修改代码 2025-05-06 15:21:31 +08:00
09de209a7c Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-05-06 14:35:17 +08:00
ChenYi
01264dd3ec 优化数据通道读取速度,并推送Kafka 2025-05-06 14:33:49 +08:00
94f36cfa62 调整透明转发解析 2025-05-06 14:33:12 +08:00
53fa6f503c Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-30 17:26:27 +08:00
9ccd016bc0 Merge branch 'zhy_feat_cev_v7' into dev 2025-04-30 17:26:04 +08:00
e1e6398348 统一时标类型 2025-04-30 17:25:35 +08:00
ChenYi
0d2bfdc33c 优化数据通道管理 2025-04-30 17:11:09 +08:00
ChenYi
fd9e3e5af3 Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-30 15:58:08 +08:00
ChenYi
ede7c8f1bb 实现IoTDB平均每分钟写入120万数据。 2025-04-30 15:57:14 +08:00
318dd2dcbe Merge branch 'zhy_feat_cev_v7' into dev 2025-04-30 15:18:05 +08:00
92b9cb37c1 修改代码 2025-04-30 15:17:51 +08:00
4bde9be137 Merge branch 'zhy_feat_cev_v7' into dev 2025-04-30 15:14:46 +08:00
a70cf4b7ce kafka优化异常重试 2025-04-30 15:14:23 +08:00
ChenYi
5ba1325204 Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-30 12:37:01 +08:00
ChenYi
f63cf8abe8 任务数据构建改为通道实现 2025-04-30 12:36:54 +08:00
a97421a00e kafka 订阅验证分区数 2025-04-30 10:35:26 +08:00
0c51c0d854 Merge branch 'zhy_feat_cev_v7' into dev 2025-04-30 09:51:37 +08:00
4e30cc13f1 修复kafka基准测试 2025-04-30 09:50:50 +08:00
ChenYi
8bfc6fa6df 新增数据通道管理服务 2025-04-29 23:55:53 +08:00
ChenYi
5890b16570 Merge branch 'dev' of https://310.jisheyun.com/daizan/JiShe.CollectBus into dev 2025-04-29 23:48:57 +08:00
ChenYi
52a7da69e9 优化任务数据创建逻辑,改为上一个任务时间为待采集点 2025-04-29 23:48:47 +08:00
b0bbf67f87 Merge branch 'zhy_feat_cev_v7' into dev 2025-04-29 11:44:50 +08:00
f020d456d5 优化返回消息体都增加消息ID 2025-04-29 11:43:16 +08:00
ChenYi
d97e38439a 修复问题 2025-04-29 10:12:09 +08:00
ChenYi
cc8465ec77 合并 2025-04-29 10:03:59 +08:00
ChenYi
f457e140f6 日志添加类型 2025-04-29 10:02:10 +08:00
981d948255 修改代码 2025-04-29 09:42:45 +08:00
0937490f05 代码合并 2025-04-29 09:19:46 +08:00