Python-фреймворк ETL для потоковой обработки, аналитики в реальном времени, LLM-пайплайнов и RAG на базе движка на Rust.
timeplus-io/proton
Однобинарный движок потокового SQL на базе ClickHouse для обработки потоков, аналитики в реальном времени и конвейеров с Kafka и другими источниками.
Open source альтернатива:Apache Flink
ksqlDB
- Звёзды
- 2,281
- Форки
- 112
- Открытые issues
- 75
- Последний коммит
- 9 дней назад
Что это?
Timeplus Proton — движок потокового SQL, который поставляется в виде одного бинарного файла на C++ и не зависит от JVM или ZooKeeper. Он расширяет возможности ClickHouse по хранению и выполнению запросов, добавляя непрерывную обработку потоков: можно выполнять SQL-запросы к поступающим данным и сохранять результаты в материализованных представлениях, доступных для запросов.
Движок поддерживает внешние потоки для Kafka, Redpanda и Confluent Cloud, внешние таблицы ClickHouse, а также источники и приёмники для таких систем, как MySQL, Postgres, MongoDB и S3/Iceberg. В его возможности входят окна tumble, hop и session, соединение нескольких потоков, инкрементальные материализованные представления, обработка CDC и UDF на Python или JavaScript.
Установить движок можно с помощью shell-скрипта, Homebrew или Docker. Для работы с ним используется SQL-клиент; также доступны драйверы для Python, Java и Go. Версия с открытым исходным кодом поддерживает развёртывание на одном узле; кластеризация, развёртывание в Kubernetes и дополнительные коннекторы входят в коммерческий продукт Timeplus Enterprise.
Ключевые возможности
- 01Потоковый SQL с окнами tumble, hop и session для поступающих данных.
- 02Внешние потоки для Kafka, Redpanda и Confluent Cloud, а также внешние таблицы ClickHouse.
- 03Инкрементальные материализованные представления, сохраняющие результаты запросов внутри движка и позволяющие обращаться к ним через запросы.
- 04Работает как один бинарный файл без зависимостей от JVM и ZooKeeper.
- 05Поддерживает UDF, написанные на Python или JavaScript.
Сценарии использования
- Потоковый ETL: фильтрация, обогащение или маскирование данных Kafka перед загрузкой в ClickHouse.
- Конвейеры обработки телеметрии в реальном времени с маршрутизацией логов и метрик и настройкой оповещений.
- Вычисление потоковых признаков для конвейеров AI/ML с помощью оконных агрегаций.
Быстрый старт
- 1
Запустите официальный скрипт установки, указанный в README (Mac/Linux)
- 2
Или установите через Homebrew на Mac
brew install timeplus-io/timeplus/proton - 3
Запустите сервер
proton server - 4
Откройте SQL-клиент в другом терминале
proton client
Что важно знать
- Развертывание в виде одного бинарного файла документировано только для Mac и Linux.
- Поддержка сообщества доступна только через GitHub и Slack; корпоративные функции, такие как загрузка CSV, NATS и размещение в Kubernetes, доступны в Timeplus Enterprise.
В подборках
Темы
Частые вопросы
- Что такое proton?
- Однобинарный движок потокового SQL на базе ClickHouse для обработки потоков, аналитики в реальном времени и конвейеров с Kafka и другими источниками. Timeplus Proton — движок потокового SQL, который поставляется в виде одного бинарного файла на C++ и не зависит от JVM или ZooKeeper. Он расширяет возможности ClickHouse по хранению и выполнению запросов, добавляя непрерывную обработку потоков: можно выполнять SQL-запросы к поступающим данным и сохранять результаты в материализованных представлениях, доступных для запросов.
- proton можно использовать бесплатно? Какая у него лицензия?
- proton распространяется с открытым исходным кодом под лицензией Apache-2.0. Перед использованием в коммерческих продуктах проверьте условия лицензии.
- proton всё ещё поддерживается?
- Активно поддерживается. Последний коммит в proton — 30 окт. 2026 г..
- Для чего можно использовать proton?
- Потоковый ETL: фильтрация, обогащение или маскирование данных Kafka перед загрузкой в ClickHouse. Конвейеры обработки телеметрии в реальном времени с маршрутизацией логов и метрик и настройкой оповещений. Вычисление потоковых признаков для конвейеров AI/ML с помощью оконных агрегаций.
- Как установить proton?
- Запустите официальный скрипт установки, указанный в README (Mac/Linux) Или установите через Homebrew на Mac: brew install timeplus-io/timeplus/proton Запустите сервер: proton server Откройте SQL-клиент в другом терминале: proton client
- Где скачать proton?
- Исходный код и инструкции по установке — на GitHub: https://github.com/timeplus-io/proton
Описание создано ИИ на основе README проекта. Статистика GitHub обновляется ежедневно.
Похожие проекты
Механизм потоковой обработки данных на Rust: выполняет SQL-запросы, Python UDF и шаги ML/LLM над потоками реального времени из Kafka, MQTT, NATS и других источников.
Распределённый движок потоковой обработки на Rust, который запускает SQL-пайплайны с сохранением состояния на потоках данных в реальном времени.
Потоковый процессор на Go, который связывает брокеры сообщений, облачные сервисы и базы данных и преобразует данные с помощью языка маппинга.
Open-source ETL-инструмент для переноса данных между более чем 30 источниками RDBMS и NoSQL с помощью JSON-конфигураций заданий; активно развиваемый преемник DataX от Alibaba.
Высокопроизводительный конвейер observability на Rust для сбора, преобразования и маршрутизации логов и метрик в любые системы назначения.