jolie-influxdb

This is the Jolie language influx connector

Installation

jpm add @jolie/influxdb

Usage

from @jolie.influxdb.jolie-influxdb import InfluxDBConnector

Operations

interface InfluxDBInterface{
RequestResponse:
  connect (ConnectRequest)(ConnectResponse),
  write(WriteRequest)(WriteResponse),
  query(QueryRequest)(QueryResponse)
}

connect

This operation allows your service to connect to the to your instance of InfluxDB

type ConnectRequest:void{
 token:string
 org:string
 url:string
 bucket:string
}

example

   connect@influxdb({
       token = "I0kn4_sybERDjvNrG44LWsDax6ozSNsDvcVewqyIn3WlEJ1c6K37pUOGK7K6d7EJHhZh8iQEcpBFWJzz5O1fqg=="
       org = "org"
       url = "http://localhost:8086"
       bucket = "test"
   })()

write

This operation allows the user to write on InfluxDB

type WriteRequest:void {
measurement:string
values*:void{
  time?:long
  fields:undefined
}
}

example

   write@influxdb({
       measurement = "example"
       values.fields.sensor1= 100
       values.fields.sensor2= 2.0
   })()

the time can be express as long epoc value if not present like in the example the connector with assign the current in time

query

type QueryRequest:void{
 .query:string
}

the query uses influxDB query format example

query@influxdb({
          query = "from(bucket: \"test\") |> range(start: -1h) |> filter(fn: (r) => r[\"_measurement\"] == \"example\")" 
        })(responseQuery)

the response type is

type QueryResponse:void{
  tables*:void{
      values*:void{
        time?:long
        field:undefined
      }
  }
}