Processing InfluxDB tags¶
I already have data in my InfluxDB, but without tags. How could I add tags like
Is the feature of adding tags to the InfluxDB database not implemented yet?
It well is - kind of. But you will have to resort to make changes to the code if the behavior here does not cover your needs already. Currently, the following ingress field names are automatically processed as InfluxDB tags:
tag_fields_main = ['geohash', 'latitude', 'longitude'] tag_fields_more = ['location', 'location_id', 'location_name', 'sensor_id', 'sensor_type']
If this doesn’t fit, you might want to amend some code within
kotori.daq.storage.influx.format_chunk according to your needs.
The whole file is about the data acquisition path where you will
get an insight how data is actually written into the InfluxDB database.
Inside this method, you will find references to
which is a dictionary where you can stuff tags into.
There’s already a section for transforming the “geohash” telemetry field to an InfluxDB tag:
# Extract geohash from data. # TODO: Also precompute geohash with 3-4 different zoomlevels and add them as tags. if "geohash" in data: chunk["tags"]["geohash"] = data["geohash"] del data['geohash']
A mechanism to declare a set of static tags per channel by defining them inside the Kotori configuration file would be nice. Please let us know if you see other mechanisms for injecting tags into the record here.
So I can just add additional tags within influx.py#L145?
Correct, you can fill key/value pairs into
chunk["tags"] anywhere within this method.
Whether you statically insert them right there using a hacked version of
if you want to derive the tag fields from the data ingress payload itself like seen with
sensor_type is really up to you.
I can’t find and edit the
influx.pyscript on my machine.
When installing Kotori from the Debian package,
it will unfold at
Please note when making changes to the files within this directory, they will be overwritten when installing a new version of Kotori from the package repositories.
So, take care of your amendments or better send them upstream to us in order to become part of the software.