openstack/monasca-persister
Code Issues Proposed changes

Add valueMeta support for Influx DB V9

Browse Source 
Change-Id: Id517d23517bc949fb4f2ed22a973b01489b2bf5c
This commit is contained in:
Craig Bryant 2015-03-24 07:31:59 -06:00
parent cd8dc419b7
commit 3ba4356bf1
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
java/src/main/java/monasca/persister/repository/InfluxV9MetricRepo.java
View File

@ -18,6 +18,9 @@
package monasca.persister.repository;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.inject.Inject;
import org.joda.time.DateTime;
@ -42,6 +45,8 @@ public class InfluxV9MetricRepo extends InfluxMetricRepo {
private static final Logger logger = LoggerFactory.getLogger(InfluxV9MetricRepo.class);
private final ObjectMapper objectMapper = new ObjectMapper();
private final SimpleDateFormat simpleDateFormat =
new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS zzz");
@ -90,7 +95,17 @@ public class InfluxV9MetricRepo extends InfluxMetricRepo {
Map<String, Object> valueMap = new HashMap<>();
valueMap.put("value", measurement.value);
String valueMetaJson = null;
if (measurement.valueMeta != null && !measurement.valueMeta.isEmpty()) {
try {
valueMetaJson = objectMapper.writeValueAsString(measurement.valueMeta);
logger.debug("Added value for value_meta of {}", valueMetaJson);
} catch (JsonProcessingException e) {
logger.error("Unable to serialize " + measurement.valueMeta, e);
valueMetaJson = null;
}
}
valueMap.put("value_meta", valueMetaJson);
InfluxPoint influxPoint = new InfluxPoint(def.name, tagMap, dateString, valueMap);
influxPointList.add(influxPoint);