erlang-influxdb

InfluxDB client library for Erlang.

Building

$ rebar3 compile

Interactive session

The output has been reformatted for readability.

Erlang/OTP 19 [erts-8.0.2] [source] [64-bit] [smp:8:8] [async-threads:0] [hipe] [kernel-poll:false] [dtrace]

Eshell V8.0.2  (abort with ^G)
1> application:ensure_all_started(influxdb).
{ok, [jsone, influxdb]}
2> Config = influxdb_config:new(#{host => "localhost", username => "root", password => "root"}).
#{host => "localhost", password => "root", port => 8086, username => "root"}
3> influxdb:query(Config, "show databases").
{ok,[[#{name => <<"databases">>,
        columns => [<<"name">>],
        rows => [{<<"_internal">>}]}]]}
4> influxdb:query(Config, "create database test").
ok
5> influxdb:query(Config, "show databases").
{ok,[[#{name => <<"databases">>,
        columns => [<<"name">>],
        rows => [{<<"_internal">>}, {<<"test">>}]}]]}
6> influxdb:write(Config#{database => "test"}, [{"cpu_load_short",
    #{"region" => "af-west", "host" => "server01"},
    #{"value" => 0.64}}]).
ok
7> influxdb:write(Config#{database => "test"}, [{"cpu_load_short",
    #{"region" => "af-west", "host" => "server02"},
    #{"value" => 0.67}}]).
ok
8> influxdb:query(Config#{database => "test"}, "select * from cpu_load_short").
{ok,[[#{name => <<"cpu_load_short">>,
        columns => [<<"time">>, <<"host">>, <<"region">>, <<"value">>],
        rows => [
            {1474124935934979502, <<"server01">>, <<"af-west">>, 0.64},
            {1474124961985106195, <<"server02">>, <<"af-west">>, 0.67}]}]]}
9> influxdb:query(Config#{database => "test"}, "select * from cpu_load_short group by host").
{ok,[[#{name => <<"cpu_load_short">>,
        tags => #{<<"host">> => <<"server01">>},
        columns => [<<"time">>, <<"region">>, <<"value">>],
        rows => [{1474124935934979502, <<"af-west">>, 0.64}]},
      #{name => <<"cpu_load_short">>,
        tags => #{<<"host">> => <<"server02">>},
        columns => [<<"time">>, <<"region">>, <<"value">>],
        rows => [{1474124961985106195, <<"af-west">>, 0.67}]}]]}
10> influxdb:query(Config#{database => "test"}, "select * from cpu_load_short group by host; select * from cpu_load_short").
{ok,[[#{name => <<"cpu_load_short">>,
        tags => #{<<"host">> => <<"server01">>},
        columns => [<<"time">>, <<"region">>, <<"value">>],
        rows => [{1474124935934979502, <<"af-west">>, 0.64}]},
      #{name => <<"cpu_load_short">>,
        tags => #{<<"host">> => <<"server02">>},
        columns => [<<"time">>, <<"region">>, <<"value">>],
        rows => [{1474124961985106195, <<"af-west">>, 0.67}]}],
     [#{name => <<"cpu_load_short">>,
        columns => [<<"time">>, <<"host">>, <<"region">>, <<"value">>],
        rows => [
            {1474124935934979502, <<"server01">>, <<"af-west">>, 0.64},
            {1474124961985106195, <<"server02">>, <<"af-west">>, 0.67}]}]]}