| <?xml version="1.0" encoding="UTF-8"?> | |
| <rates> | |
| <!-- общий пример --> | |
| <item> | |
| <!-- 1 WMZ на 30.593562 WMX --> | |
| <from>WMZ</from> | |
| <to>WMX</to> | |
| <in>1</in> | |
| <out>30.593562</out> |
This example shows how to process kafka messages in batches with php-rdkafka. As soon as the required number of messages appears in topic, they will be immediately processed.
The key Kafka Conf value to achieve proper behavior is enable.auto.offset.store=false. See here
PARTITION=0
| <?php | |
| /** | |
| * If you build SQL queries like INSERT INTO table ('f1', 'f2', ...) VALUES ('v1', 'v2', ...), ('v1', 'v2', ...), ... | |
| * You should know what | |
| * | |
| * Expression | |
| * `rtrim(str_repeat('?,', TRY_COUNT), ',');` | |
| * works 16 time faster than | |
| * `implode(',', array_pad([], TRY_COUNT, '?'));` |
| --- | |
| - name: Play gitlab-runner | |
| hosts: all | |
| tasks: | |
| - name: Create a GitLab Runner user | |
| user: | |
| name: gitlab-runner | |
| comment: GitLab Runner | |
| create_home: true | |
| shell: /bin/bash |
| CREATE TABLE events_local ON CLUSTER 'local' | |
| ( | |
| event_type String, | |
| title String, | |
| description String, | |
| content String, | |
| date Date | |
| ) | |
| ENGINE = ReplicatedMergeTree('/ch/{cluster}/{shard}/tables/events_local', '{replica}') | |
| PARTITION BY date |