Чтение данных с помощью привязок к данным в Query

При работе с Yandex Data Streams с помощью привязок к данным удобно выполнять запросы к хранимым данным на регулярной основе без необходимости указывать все детали работы с этими данными.

Пример чтения данных из привязок к данным:

SELECT
    JSON_VALUE(CAST(Data AS Json), "$.action") AS action
FROM bindings.`input_stream`
LIMIT 10;

Настройка привязки к даннымНастройка привязки к данным

Для чтения данных из Yandex Data Streams c помощью привязок к данным необходимо:

1. Настроить соединение с данными.
2. В поле Тип выбрать Data Streams.
3. В выпадающем поле Соединение выбрать соединение, созданное в первом пункте.
4. В поле Имя указать название привязки к данным.
5. В поле Поток данных указать название потока данных Yandex Data Streams.
6. В поле Сжатие указать способ сжатия данных.
7. В поле Формат указать формат передаваемых данных.
8. В полях Колонки указать список колонок в данных и их типы данных.
9. Для проверки данных нажать кнопку Предпросмотр.
10. Создать привязку к данным, нажав кнопку Создать.

Модель данныхМодель данных

Данные через Yandex Data Streams передаются в бинарном виде. Чтение данных выполняется с помощью SQL-выражений.

SELECT 
    <выражение> 
FROM 
    <соединение>.<имя_потока>
WITH
(
    format=raw,
    SCHEMA 
    (
        Data String
    )
)
WHERE <фильтр>;

Где:

• <соединение> — название соединения с потоком данных Data Streams, созданного в предыдущем пункте.
• <имя_потока> — название потока данных в Data Streams.

Пример чтения данныхПример чтения данных

Пример запроса для чтения данных из Yandex Data Streams и записи результатов в Yandex Data Streams.

$data = 
SELECT 
    JSON_VALUE(Data, "$.host") AS host,
    JSON_VALUE(Data, "$.count") AS count,
    JSON_VALUE(Data, "$.tag") AS tag,    
FROM 
(
    SELECT
        CAST(Data AS Json) AS Data
    FROM bindings.`binding_name`
)
WHERE 
    JSON_VALUE(Data, "$.tag") = "my_tag";

SELECT 
    * 
FROM 
    $data
LIMIT 10;    

Где: