/
DieNice
/
clickhouse-integration-engine
Обзор
Документация
Войти
/
DieNice
/
clickhouse-integration-engine
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
dev
clickhouse_integration.sql
34 строки
727 B
Proskurin.DA
WIP
08 июн 2025, 08:16
08 июн 2025, 08:16
1b0aa16
Код
Авторство
О чём код?
CREATE TABLE queue ( name_client String, address String, name_pizza String, weight Float64, price Float64, date_time_order DateTime, date_time_delivery DateTime, count Int8, percent_discont Float32 ) ENGINE = Kafka('kafka:9093', 'my_topic', 'group1', 'JSONEachRow'); select * from queue limit 5; CREATE TABLE destination ( name_client String, address String, name_pizza String, weight Float64, price Float64, date_time_order DateTime, date_time_delivery DateTime, count Int8, percent_discont Float32 ) ENGINE = MergeTree() order by date_time_order; CREATE MATERIALIZED VIEW consumer TO destination AS SELECT * FROM queue;