...
|
...
|
@@ -170,6 +170,8 @@ public class ZabbixTask implements Callable { |
|
|
|
|
|
|
|
|
public void buildBatchPoints(Map<String, String> hostIpToIds, Map<String, List<ItemResponse.Item>> hostIdToItems, Map<String, List<HistoryResponse.HistoryItem>> historyItems) {
|
|
|
DEBUG.info("start to build zabbix batch points...");
|
|
|
|
|
|
BatchPoints pointBp = BatchPoints.database(Constants.INFLUX_DB).retentionPolicy(Constants.INFLUX_POLICY).build();
|
|
|
|
|
|
try {
|
...
|
...
|
@@ -178,7 +180,6 @@ public class ZabbixTask implements Callable { |
|
|
for (String key : keys) {
|
|
|
|
|
|
Point point = buildPoints(key, entry.getKey(), hostIdToItems.get(entry.getValue()), historyItems.get(entry.getValue()));
|
|
|
|
|
|
pointBp.point(point);
|
|
|
}
|
|
|
}
|
...
|
...
|
|