Influx

An async client for Influx DB. If there's anything I've missed please get in touch. Internally this client uses http-kit for async requests. Use the @ operator to block requests. See http-kit for more info.

InfluxDB has a really simple HTTP API an so this client tries to adhere to that simplicity as much as possible.

Usage

Getting Started

(ns my-ns
  (:require [influx.core :as influx]))

All requests require configuration which is just a map of information needed to connect to InfluxDB

(def local-conf
  { :host "http://192.168.99.100"
    :port 8086
    :user nil
    :password nil
  })

Queries

Running simple "raw" queries is straightforward.

@(influx/query local-conf "SHOW DATABASES")

An example REPL session showing the difference between blocking and non blocking requests.

(query local-conf show-databases-query)
;; #promise[{:status :pending, :val nil} 0xa50d47c]

@(query local-conf show-databases-query)
;; {:status 200,
;;  :body {:results [{:series [{:name "databases", :columns ["name"], :values [["_internal"]]}]}]}}

Writing Data

If you want to write a single line of data to influx

(influx/write-metric local-conf "mydb" "cpu_load_short,host=server02 value=0.67")

Or a batch of data

(def sample-data
  [ "cpu_load_short,host=server02 value=0.67"
    "cpu_load_short,host=server02,region=us-west value=0.55 1422568543702900257"
    "cpu_load_short,direction=in,host=server01,region=us-west value=2.0 1422568543702900257" ])

(influx/write-batch-metrics local-conf "mydb" sample-data)

License

Copyright © 2016 Owain Lewis

Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.