taosdata/TDengine

数据订阅 拉取耗时太长

Open

#33.524 aperta il 10 nov 2025

Vedi su GitHub
 (3 commenti) (0 reazioni) (0 assegnatari)C (5002 fork)batch import
help wantedquestion

Metriche repository

Star
 (24.849 star)
Metriche merge PR
 (Merge medio 1g 1h) (4 PR mergiate in 30 g)

Descrizione

网络也正常

社区版 3.3.8.1

目前的架构是 6台服务器,其中5台tdengine server,第6台服务器 从其他5台通过数据订阅拉取数据, 每台服务器拉取开了5个线程,一共25个线程, 参数: properties.setProperty(TMQConstants.CONNECT_TYPE, "ws"); properties.setProperty(TMQConstants.CONNECT_USER, "root"); properties.setProperty(TMQConstants.CONNECT_PASS, "taosdata"); properties.setProperty(TMQConstants.AUTO_OFFSET_RESET, "latest"); properties.setProperty(TMQConstants.MSG_WITH_TABLE_NAME, "true"); properties.setProperty(TMQConstants.ENABLE_AUTO_COMMIT, "true"); properties.setProperty(TMQConstants.AUTO_COMMIT_INTERVAL, "1000");

5台服务器的数据库创建语句 CREATE DATABASE tpih PRECISION 'ns' KEEP 150 VGROUPS 10 CACHEMODEL 'both' DURATION 24h BUFFER 16;

Guida contributor