From ef8c6ff4b4984ee8ec6720c4e5df52c14e46805f Mon Sep 17 00:00:00 2001
From: Andreas Motl <andreas@getkotori.org>
Date: Wed, 15 Jan 2020 04:26:41 +0100
Subject: [PATCH] InfluxDB adapter: Interpret "latitude/longitude" fields as
 tags

---
 CHANGES.rst                  | 7 +++++++
 kotori/daq/storage/influx.py | 6 ++++++
 2 files changed, 13 insertions(+)

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: