Erlang clickhouse async bulk inserter
Rebar3: Add eclickhouse to deps in your rebar.config file. Add eclickhouse to applications in your .app.src file.
Start conn example:
start_clickhouse() ->
Name = click, %% Conn name unique atom()
Conf = #{
enabled_fields => [ts, id, value, a], %% (drop field not in enabled_fields) of all
bulk_size => 1000, %% size bulk inserts to save
write_period => 3, % Sec max time to save small bulk
db => #{url => "http://localhost:8123/?database=test_db",
table => test_table}
},
ok = eclickhouse:start_conn(Name, Conf).Insert example:
eclickhouse:insert(click, #{id => 2, a => 1}).
eclickhouse:insert(click, [#{id => 3, a => 1}, #{id => 4, value => 5}]).Sync insert (for debug and testing)
eclickhouse:insert(click, #{id => 2, a => 1}, #{mode => sync}).Get conn info and statistics example:
eclickhouse:get_state(click).Stop connection
eclickhouse:stop_conn(click)