Returns a function which accepts an event and sends it to clickhouse.

Usage:

(batch 10000 5 (clickhouse {:host “play.clickhouse.com”}))

Options:

• :scheme ClickHouse URL Scheme (default: “http://”)
• :host ClickHouse Server IP (default: “localhost”)
• :port ClickHouse Server Port (default: 8123)
• :database ClickHouse Database Name (default: “default”)
• :table ClickHouse Table Name (default: “riemann”)
• :username ClickHouse User Name (default: “default”)
• :password ClickHouse Password (default: "")

It will create the clickhouse table using the following query:

CREATE TABLE IF NOT EXISTS default.riemann ( timestamp DateTime, host String, service String, metric Float32, tags Array(String) ) ENGINE = MergeTree PARTITION BY toYYYYMM(timestamp) ORDER BY (timestamp, host, service) SETTINGS index_granularity = 8192;

ClickHouse query for creating table

Generates the URL to which create table query should be posted.

Accepts riemann event and converts it into clickhouse datapoint.

Accepts riemann events and converts it into clickhouse datapoint batch.

Generates the URL to which datapoint should be posted.

Post the riemann event as clickhouse datapoint.