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

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

Важно

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

Примечание

В примерах ydb_source — это заранее созданный внешний источник данных, а topic_name — топик, доступный через него.

Пример

SELECT
    Data
FROM
    ydb_source.topic_name
WITH (
    FORMAT = raw,
    SCHEMA = (
        Data String
    ),
    STREAMING = TRUE
)
LIMIT 1

См. также

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

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

TABLESAMPLE

UPDATE