|
|
|
@ -198,6 +198,7 @@ public class DeviceDataService { |
|
|
|
oldInfluxDBClient = InfluxDBClientFactory.create(oldurl, oldtoken.toCharArray(), oldorg); |
|
|
|
} |
|
|
|
List<FluxTable> tables = oldInfluxDBClient.getQueryApi().query(query.toString()); |
|
|
|
System.out.println("查询历史数据结果==========:" + tables.size()); |
|
|
|
List<DeviceDataInfluxData> rerurnList = new ArrayList<>(); |
|
|
|
for (FluxTable fluxTable : tables) { |
|
|
|
List<FluxRecord> records = fluxTable.getRecords(); |
|
|
|
|