examples

InfluxDB Client Examples

This directory contains Java, Kotlin and Scala examples.

Java

• WriteDataEverySecond.java - Write data every second

• ParameterizedQuery.java - How to use Parameterized Queries

• InfluxQLExample.java - How to use queries with the old influxQL dialect

  The InfluxQL can be used with /query compatibility endpoint which uses the database and retention policy specified in the query request to map the request to an InfluxDB bucket. For more information, see:

  • /query 1.x compatibility API
  • Database and retention policy mapping

Others

• InvokableScripts.java - How to use Invokable scripts Cloud API to create custom endpoints that query data
• InfluxDBEnterpriseExample.java - How to use consistency parameter for InfluxDB Enterprise
• RecordRowExample.java - How to use FluxRecord.getRow() (List) instead of FluxRecord.getValues() (Map), in case of duplicity column names
• WriteHttpExceptionHandled - How to work with HTTP Exceptions for debugging and recovery.

Kotlin

Query

• KotlinQuery.kt - How to query data into a stream of FluxRecord and filter them by Flow operators
• KotlinQueryRaw.kt - How to query data into a stream of String
• KotlinQueryDSL.kt - How to use the FluxDSL to query data

Writes

• KotlinWriteApi.kt - How to ingest data by DataPoint, LineProtocol or Data class
• KotlinWriteBatchingByFlow.kt - How to use Flow operators to prepare batches for synchronous write into InfluxDB

Scala

Query

• ScalaQuery.scala - How to query data into a stream of FluxRecord and filter them by Flow operators
• ScalaQueryRaw.scala - How to query data into a stream of String
• ScalaQueryDSL.scala - How to use the FluxDSL to query data

Writes

• ScalaWriteApi.scala - How to ingest data by DataPoint, LineProtocol or POJO