Reading data using Query bindings

When working with Yandex Data Streams, bindings help you run regular queries to stored data with no need to specify all details of operations with this data.

Example of reading data using bindings:

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

Setting up a data bindingSetting up a data binding

To read data from Yandex Data Streams using bindings:

1. Setting up a data connection.
2. In the Type field, select Data Streams.
3. In the drop-down list of the Connection field, select the connection you created in the first step.
4. Specify a name for the data binding in the Name field.
5. Specify a name for a Yandex Data Streams stream in the Stream field.
6. Specify the data compression method in the Compression field.
7. Specify the format of transferred data in the Format field.
8. List data columns and their data types in the Columns fields.
9. To check the data, click Preview.
10. Click Create to create a binding.

Data modelData model

Data is sent via Yandex Data Streams in binary form. Data is read using SQL statements.

SELECT
    <expression>
FROM
    <connection>.<stream_name>
WITH
(
    format=raw,
    SCHEMA
    (
        Data String
    )
)
WHERE <filter>;

Where:

• <connection>: Name of the Data Streams data stream connection created in the previous step.
• <stream_name>: Name of the data stream in Data Streams.

Example of reading dataExample of reading data

Sample query for reading data from Yandex Data Streams and writing the results to 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;

Where: