Clickhouse Queue

Clickhouse insert buffer queue using RabbitMQ STOMP protocol.

Required PHP Version

• PHP 8.1+

Installation

This package can be installed as a Composer dependency.

composer require pnixx/clickhouse-queue

Example usage

$worker = new ClickhouseWorker([
	'clickhouse' => [
		'database' => 'example',
		'host'     => 'localhost',
		'port'     => 8123,
	],
	'stomp'      => [
		'host'  => 'localhost',
		'port'  => 61613,
		'queue' => 'clickhouse',
	],
], __DIR__ . '/../tmp');

Worker::runAll();

This worker will listen the queue clickhouse and will inserting bulk data to ClickHouse database. For run worker:

php examples/run.php start

Docker

docker build --rm -t clickhouse-queue .
docker run --name clickhouse-queue clickhouse-queue

Environment variables:

• CLICKHOUSE_HOST - ClickHouse host for inserts, default localhost
• CLICKHOUSE_PORT - ClickHouse port for inserts, default 8123
• CLICKHOUSE_DB - ClickHouse database for inserts, default default
• CLICKHOUSE_USER - ClickHouse user, optional
• CLICKHOUSE_PASSWORD - ClickHouse password, optional
• CLICKHOUSE_SSL - ClickHouse need use HTTPS connection instead HTTP, default false
• RABBIT_HOST - RabbitMQ host for subscribe, default localhost
• RABBIT_STOMP_PORT - RabbitMQ STOMP port, default 61613
• RABBIT_USER - RabbitMQ STOMP login user, default guest
• RABBIT_PASSWORD - RabbitMQ STOMP login password, default guest
• RABBIT_QUEUE - RabbitMQ queue for buffer data, default clickhouse
• MAX_DELAY - time flush data to ClickHouse, default 5
• MAX_FILE_SIZE - max buffer size before flush to ClickHouse, default 5242880

Message structure

Header table: to insert data into the specified table

Body: JSON as string row data

{"column1": "data1", "column2": "data2"}

Development

Testing GitHub actions:

act

Donations

Donations to this project are going directly to PNixx, the original author of this project:

• BTC address: 1H3rhpf7WEF5JmMZ3PVFMQc7Hm29THgUfN
• ETH address: 0x6F094365A70fe7836A633d2eE80A1FA9758234d5
• XMR address: 42gP71qLB5M43RuDnrQ3vSJFFxis9Kw9VMURhpx9NLQRRwNvaZRjm2TFojAMC8Fk1BQhZNKyWhoyJSn5Ak9kppgZPjE17Zh
• TON address: UQBt0-s1igIpJoEup0B1yAUkZ56rzbpruuAjNhQ26MVCaNlC

Contributing

Bug reports and pull requests are welcome on GitHub at https://github.com/PNixx/clickhouse-queue. This project is intended to be a safe, welcoming space for collaboration, and contributors are expected to adhere to the Contributor Covenant code of conduct.

License

The MIT License (MIT). Please see LICENSE for more information.