tsdb:从kafka获取源链主从同步接时序数据库InfluxDB

[{"title":"（ 42 个子文件 107KB ） tsdb:从kafka获取源链主从同步接时序数据库InfluxDB","children":[{"title":"tsdb-master","children":[{"title":"data-handling","children":[{"title":".gitignore <span style='color:#111;'> 268B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.properties <span style='color:#111;'> 648B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"bici","children":[{"title":"tsdb","children":[{"title":"datahandling","children":[{"title":"handle","children":[{"title":"DataListener.java <span style='color:#111;'> 1.85KB </span>","children":null,"spread":false}],"spread":true},{"title":"DataHandlingApplication.java <span style='color:#111;'> 342B </span>","children":null,"spread":false},{"title":"service","children":[{"title":"RedisDao.java <span style='color:#111;'> 1.06KB </span>","children":null,"spread":false},{"title":"impl","children":[{"title":"RedisDaoImpl.java <span style='color:#111;'> 2.17KB </span>","children":null,"spread":false},{"title":"InfluxdbWriteServiceImpl.java <span style='color:#111;'> 2.06KB </span>","children":null,"spread":false}],"spread":false},{"title":"InfluxdbWriteService.java <span style='color:#111;'> 349B </span>","children":null,"spread":false}],"spread":true},{"title":"config","children":[{"title":"KaakaConsumerConfig.java <span style='color:#111;'> 3.61KB </span>","children":null,"spread":false},{"title":"JedisConfig.java <span style='color:#111;'> 1.28KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"bici","children":[{"title":"tsdb","children":[{"title":"datahandling","children":[{"title":"DataHandlingApplicationTests.java <span style='color:#111;'> 358B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.43KB </span>","children":null,"spread":false}],"spread":true},{"title":"query-data","children":[{"title":".gitignore <span style='color:#111;'> 268B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.properties <span style='color:#111;'> 137B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"bici","children":[{"title":"tsdb","children":[{"title":"querydata","children":[{"title":"controller","children":[{"title":"QueryController.java <span style='color:#111;'> 1.38KB </span>","children":null,"spread":false}],"spread":true},{"title":"QueryDataApplication.java <span style='color:#111;'> 333B </span>","children":null,"spread":false},{"title":"service","children":[{"title":"impl","children":[{"title":"InfluxdbReadServiceImpl.java <span style='color:#111;'> 2.88KB </span>","children":null,"spread":false}],"spread":false},{"title":"InfluxdbReadService.java <span style='color:#111;'> 432B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"bici","children":[{"title":"tsdb","children":[{"title":"querydata","children":[{"title":"QueryDataApplicationTests.java <span style='color:#111;'> 352B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 1.95KB </span>","children":null,"spread":false}],"spread":true},{"title":"temp-process","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.properties <span style='color:#111;'> 326B </span>","children":null,"spread":false},{"title":"banner.txt <span style='color:#111;'> 1.04KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"bici","children":[{"title":"tsdb","children":[{"title":"tempprocess","children":[{"title":"controller","children":[{"title":"KafkaController.java <span style='color:#111;'> 2.28KB </span>","children":null,"spread":false}],"spread":true},{"title":"TempProcessApplication.java <span style='color:#111;'> 339B </span>","children":null,"spread":false},{"title":"config","children":[{"title":"KafkaConfig.java <span style='color:#111;'> 2.21KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"bici","children":[{"title":"tsdb","children":[{"title":"tempprocess","children":[{"title":"TempProcessApplicationTests.java <span style='color:#111;'> 356B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.23KB </span>","children":null,"spread":false}],"spread":true},{"title":"refer","children":[{"title":"TSDB测试报告.docx <span style='color:#111;'> 24.01KB </span>","children":null,"spread":false},{"title":"InfluxDB拓扑图.png <span style='color:#111;'> 45.68KB </span>","children":null,"spread":false},{"title":"demo.qunee.com-editor.图形源码.json <span style='color:#111;'> 8.89KB </span>","children":null,"spread":false}],"spread":true},{"title":"README.md <span style='color:#111;'> 2.08KB </span>","children":null,"spread":false},{"title":"common","children":[{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"bici","children":[{"title":"tsdb","children":[{"title":"common","children":[{"title":"entity","children":[{"title":"Payload.java <span style='color:#111;'> 794B </span>","children":null,"spread":false},{"title":"QueryObj.java <span style='color:#111;'> 3.04KB </span>","children":null,"spread":false},{"title":"Node.java <span style='color:#111;'> 945B </span>","children":null,"spread":false},{"title":"SensorData.java <span style='color:#111;'> 735B </span>","children":null,"spread":false},{"title":"ResultDTO.java <span style='color:#111;'> 982B </span>","children":null,"spread":false}],"spread":false},{"title":"util","children":[{"title":"InfluxDBResultMapper.java <span style='color:#111;'> 12.58KB </span>","children":null,"spread":false},{"title":"StringUtil.java <span style='color:#111;'> 312B </span>","children":null,"spread":false}],"spread":false},{"title":"constant","children":[{"title":"TimeIntervalEnum.java <span style='color:#111;'> 2.06KB </span>","children":null,"spread":false},{"title":"CommonConstant.java <span style='color:#111;'> 848B </span>","children":null,"spread":false},{"title":"InfluxDBFunctionEnum.java <span style='color:#111;'> 629B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.17KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}]