diff options
| -rw-r--r-- | src/plugins/influxdb.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/plugins/influxdb.c b/src/plugins/influxdb.c index 4c69e98..c2fe118 100644 --- a/src/plugins/influxdb.c +++ b/src/plugins/influxdb.c @@ -159,7 +159,8 @@ void unpacking_from_api(void *s, json_object *valueJ, const char *key) if(strcasecmp("name", key) == 0) serie->name = json_object_get_string(valueJ); else if(strcasecmp("timestamp", key) == 0) - serie->timestamp = get_ts(); + serie->timestamp = (json_object_is_type(valueJ, json_type_int)) ? + json_object_get_int64(valueJ) : 0; else if(strcasecmp("metadata", key) == 0) wrap_json_object_for_all(valueJ, unpack_metadata, (void*)&serie->serie_columns.tags); else if(strcasecmp("value", key) == 0 || strcasecmp("values", key) == 0) @@ -178,8 +179,9 @@ int unpack_metric_from_api(json_object *m, struct series_t *serie) { wrap_json_object_for_all(m, unpacking_from_api, serie); - if(!serie->timestamp) + if(! serie->timestamp) { serie->timestamp = get_ts(); + } return 0; } |