diff --git a/CHANGES.rst b/CHANGES.rst index b8ee29ce..2921270d 100644 --- a/CHANGES.rst +++ b/CHANGES.rst @@ -5,7 +5,14 @@ Changelog in progress =========== + + +.. _kotori-0.24.0: + +2020-01-15 0.24.0 +================= - Adjust packaging for Debian stretch vs. buster +- InfluxDB adapter: Interpret "latitude/longitude" fields as tags .. _kotori-0.23.0: diff --git a/kotori/daq/storage/influx.py b/kotori/daq/storage/influx.py index bcbdd72f..6a8d9267 100644 --- a/kotori/daq/storage/influx.py +++ b/kotori/daq/storage/influx.py @@ -184,6 +184,12 @@ def format_chunk(self, meta, data): chunk["tags"]["geohash"] = data["geohash"] del data['geohash'] + if "latitude" in data and "longitude" in data: + chunk["tags"]["latitude"] = data["latitude"] + chunk["tags"]["longitude"] = data["longitude"] + del data['latitude'] + del data['longitude'] + # Extract more information specific to luftdaten.info for field in ['location', 'location_id', 'location_name', 'sensor_id', 'sensor_type']: if field in data: