|
|
@@ -92,7 +92,7 @@ public class DataCollector {
|
|
|
}).flatMap(Collection::stream).collect(Collectors.toList());
|
|
|
|
|
|
//构建influxdb
|
|
|
- List<Point> points = dates.parallelStream().map(d -> d.toPoint(devices)).collect(Collectors.toList());
|
|
|
+ List<Point> points = dates.parallelStream().map(d -> d.toPoint(devices)).filter(Objects::nonNull).collect(Collectors.toList());
|
|
|
//写入influxDb
|
|
|
influxDbUtil.write(points);
|
|
|
|