Tinybird — платформа для приёма событий и аналитики в реальном времени: источники данных, pipes (конвейеры запросов) и API (Application Programming Interface — программный интерфейс) поверх SQL.
С Tinybird в Pailot вы можете:
- Отправлять события в Data Source через Events API — JSON или NDJSON (newline-delimited JSON — JSON по строке на событие), при необходимости с gzip
- Выполнять SQL к pipes и источникам через Query API
- Ждать подтверждение записи (
wait) — безопаснее повторы, выше задержка - Получать статистику запроса: время, прочитанные строки и байты (при
FORMAT JSON)
Нужен токен API Tinybird с нужной областью: DATASOURCE:APPEND / DATASOURCE:CREATE для записи, PIPE:READ для запросов. Укажите base_url региона (например https://api.tinybird.co или https://api.us-east.tinybird.co).
Блок ставят на холст как отдельный шаг или прикрепляют к агенту. Токен — в переменных окружения рабочего пространства.
Инструменты
tinybird_events
Отправка событий в Data Source через Events API. Форматы JSON и NDJSON, опционально gzip.
Вход
| Параметр | Тип | Обязательный | Описание |
|---|---|---|---|
base_url | string | Да | Базовый URL API Tinybird (например https://api.tinybird.co или https://api.us-east.tinybird.co) |
datasource | string | Да | Имя Data Source, куда писать события |
data | string | Да | Данные в NDJSON или JSON. Каждое событие — валидный объект JSON |
wait | boolean | Нет | Ждать подтверждение записи в БД. Надёжнее повторы, выше задержка. По умолчанию false |
format | string | Нет | Формат: ndjson (по умолчанию) или json |
compression | string | Нет | Сжатие: none (по умолчанию) или gzip |
token | string | Да | Токен API с областью DATASOURCE:APPEND или DATASOURCE:CREATE |
Выход
| Параметр | Тип | Описание |
|---|---|---|
successful_rows | number | Число успешно принятых строк |
quarantined_rows | number | Число строк в карантине (не прошли проверку) |
tinybird_query
SQL к pipes и источникам через Query API.
Вход
| Параметр | Тип | Обязательный | Описание |
|---|---|---|---|
base_url | string | Да | Базовый URL API Tinybird (например https://api.tinybird.co) |
query | string | Да | SQL-запрос. Укажите формат вывода (FORMAT JSON, FORMAT CSV, FORMAT TSV). JSON даёт структуру, остальные — сырой текст |
pipeline | string | Нет | Имя pipe. Если задано, можно писать SELECT * FROM _ |
token | string | Да | Токен API с областью PIPE:READ |
Выход
| Параметр | Тип | Описание |
|---|---|---|
data | json | Результат запроса. Для FORMAT JSON — массив объектов. Для CSV, TSV и др. — сырая строка |
rows | number | Число строк (только при FORMAT JSON) |
statistics | json | Статистика: время, прочитанные строки и байты (только при FORMAT JSON) |