такие настройки rabbitmq_max_block_size=500000, rabbitmq_flush_interval_ms=7500000, дабы проверить как работает вставка пачками, и по ощущениям вставляется по одной строке, я что то упускаю?
Данные сразу появляются буквально, Хотя ожидаю задержку.
Полный код создания тестовых таблиц
create table queue3
(
json String
)
engine = RabbitMQ SETTINGS rabbitmq_host_port = 'rabbit:5672',
rabbitmq_exchange_name = '/',
rabbitmq_format = 'LineAsString',
rabbitmq_num_consumers = 1,
rabbitmq_max_block_size=500000000,
rabbitmq_flush_interval_ms=7500000
CREATE TABLE event (json String) ENGINE = Log();
CREATE MATERIALIZED VIEW IF NOT EXISTS event_view
TO event AS
SELECT *
FROM queue3;
было уже, макс блок читается (тут я был не прав) за макс период, не так? а из MQ читается, что доступно EDIT: не так? - не так ли предполагается?
немного не понял вас, можете по другому сформулировать пжз 😢
Обсуждают сегодня