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

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

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

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

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

Чтобы создать привязку для чтения данных из Yandex Data Streams:

1. Настройте соединение с данными.

2. Перейдите в сервис Yandex Query.

3. На панели слева перейдите на вкладку Привязки.

4. Нажмите кнопку Создать.

5. В блоке Параметры соединения:

   1. В поле Тип выберите Data Streams.
   2. В поле Соединение выберите соединение, созданное на первом шаге.

6. В блоке Параметры привязки к данным:

   1. В поле Имя укажите название привязки к данным.
   2. В поле Поток данных укажите название потока данных Yandex Data Streams.
   3. В поле Сжатие укажите способ сжатия данных.
   4. В поле Формат укажите формат передаваемых данных.
   5. В полях Колонки укажите список колонок и их типы данных.

7. Для проверки данных нажмите кнопку Предпросмотр.

8. Нажмите кнопку Создать.

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

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

SELECT
    <выражение>
FROM bindings.`<имя_привязки>`
WHERE
    <фильтр>;

Где:

• <выражение> — выражение, определяющее результат запроса;
• <имя_привязки> — название ранее созданной привязки к данным;
• <фильтр> — условие фильтрации данных.

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

Пример запроса для чтения данных из 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;

Где: