Потоковое чтение данных из топика

Можно выполнять чтение данных из топика обычным SELECT без создания потокового запроса. Для этого необходимо указать STREAMING = TRUE в блоке WITH и задать ограничение на количество выходных строк через LIMIT, иначе запрос не завершится.

Важно

Этот способ предназначен только для отладки и проверки данных в топике. Для production процессов создавайте потоковые запросы через CREATE STREAMING QUERY.

Примечание

В примерах:

ext_source — это заранее созданный внешний источник данных;
input_topic — локальный или внешний топик.

Подробнее — локальные и внешние топики в потоковых запросах.

Пример

SELECT
    Data
FROM
    ext_source.input_topic -- или локальный топик input_topic
WITH (
    FORMAT = raw,
    SCHEMA = (
        Data String
    ),
    STREAMING = TRUE
)
LIMIT 1

См. также

Отладочное чтение из топика — рецепт с дополнительными примерами
Потоковые запросы
CREATE STREAMING QUERY

Была ли статья полезна?

TABLESAMPLE

SHOW CREATE