Download the PHP package pnixx/clickhouse-queue without Composer
On this page you can find all versions of the php package pnixx/clickhouse-queue. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Download pnixx/clickhouse-queue
More information about pnixx/clickhouse-queue
Files in pnixx/clickhouse-queue
Package clickhouse-queue
Short Description Clickhouse insert buffer queue using RabbitMQ
License
Informations about the package clickhouse-queue
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.
Example usage
This worker will listen the queue clickhouse
and will inserting bulk data to ClickHouse database. For run worker:
Docker
Environment variables:
CLICKHOUSE_HOST
- ClickHouse host for inserts, defaultlocalhost
CLICKHOUSE_PORT
- ClickHouse port for inserts, default8123
CLICKHOUSE_DB
- ClickHouse database for inserts, defaultdefault
CLICKHOUSE_USER
- ClickHouse user, optionalCLICKHOUSE_PASSWORD
- ClickHouse password, optionalCLICKHOUSE_SSL
- ClickHouse need use HTTPS connection instead HTTP, defaultfalse
RABBIT_HOST
- RabbitMQ host for subscribe, defaultlocalhost
RABBIT_STOMP_PORT
- RabbitMQ STOMP port, default61613
RABBIT_USER
- RabbitMQ STOMP login user, defaultguest
RABBIT_PASSWORD
- RabbitMQ STOMP login password, defaultguest
RABBIT_QUEUE
- RabbitMQ queue for buffer data, defaultclickhouse
MAX_DELAY
- time flush data to ClickHouse, default5
MAX_FILE_SIZE
- max buffer size before flush to ClickHouse, default5242880
Message structure
Header table
: to insert data into the specified table
Body: JSON as string row data
Development
Testing GitHub actions:
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.
All versions of clickhouse-queue with dependencies
workerman/workerman Version ^5.0
workerman/stomp Version ^v1.0
workerman/http-client Version ^v2.1
psr/log Version ^3.0
revolt/event-loop Version ^1.0
ext-pcntl Version *
ext-sockets Version *
ext-event Version *