InfluxDB

This publisher transport persists processed events to a configured InfluxDB organisation bucket as a time series database. Tags and measurements are configured independently which are aligned to the final pipeline processed event.

This transport is idea for time series offline use case analytics, device monitoring and alerting.

Driver details

com.influxdb:influxdb-client-java:6.5.0

Example configuration

influxdb:
  url: http://localhost:8086
  authToken: 1d892e1ab6f70b3b9b3d619899a847957033e76385c231e02892ebfa59f1791f
  organisation: banking
  bucket: nasdaqBaseAnalytics
  retentionTime: 10800
  enableGzip: true
  logLevel: BASIC
  formatter:
    useEventTime: true
    tags:
      - symbol
    measurements:
      ask_upper_BollingerBand: DOUBLE
      ask_middle_BollingerBand: DOUBLE
      ask_lower_BollingerBand: DOUBLE

Core Attributes

Configuration parameters available for the InfluxDB publisher transport. The parameters are organized by order of importance, ranked from high to low.

Attribute	Description	Data Type	Required
url	InfluxDB server address	http://<ip-address>:port
authToken	InfluxDB UI / CLI Authentication access token	String
username password	Authentication access details for v1.x InfluxDB. Note: Only required if authToken has not been provided.	String
organisation	InfluxDB UI / CLI organisation token	String
bucket	Bucket where event measurements are persisted	String
formatter	See Formatter section below	See Formatter section below
enableGzip	Compress batched data to improve I/O transfer for large data loads	Boolean Default: true
retentionTime	Number of seconds to retain measurements	Seconds as a integer value Default: 3600 seconds
loglevel	InfluxDB logging level	Options: NONE, BASIC, BODY, HEADERS Default: BASIC

Formatter Attributes

This topic provides configuration parameters available for the formatter attribute. The parameters are organized by order of importance, ranked from high to low.

Attribute	Description	Data Type	Required
measurements	Map of event measurements to persist mapped to data type	Map String -> DOUBLE, FLOAT, LONG, INTEGER, SHORT, BYTE, BOOLEAN, STRING
tags	List of record tags for enable aggregate query processing	String list
useEventTime	Specifies which event timestamp to persist	Boolean: Default: true True: eventTimestamp False: ingestionTimestamp

Further details

Further details on InfluxDB please follow the link.