【TDengine 使用环境】 测试环境
【TDengine 版本】3.4.1
【操作系统以及版本】centos7.9
【部署方式】容器/非容器部署 非容器
【集群节点数】单机
【资源配置】内存32g
先简单说一下我们这边入库流程:数据经过采集程序发送到kafka队列 经过一些业务逻辑处理之后 发送到kafka的入库队列 进行数据入库
如下是在每秒推送相同的数据量的情况下
1.以下为websocket写入入库部分代码及测试结果 从kafka监控软件看入库队列堆积持续且持续增长
2.原生连接,使用一次入库多个普通表方式 kafka工具看入库lag数量保持稳定且不增长
综上:目前看原生写入效率远超stmt模式 请看下这边哪些stmt有问题呢 我看官方一直建议的是用此方式写入