timeplus-io/proton

解決的問題

Timeplus Proton 是一個為即時串流處理、分析與可觀測性設計的高效率 SQL 流水線引擎。它作為 Apache Flink 或 ksqlDB 等複雜框架的輕量級 C++ 替代方案，無需 JVM 或 ZooKeeper，同時支援即時資料處理與儲存可查詢的物化檢視，以供分析儀表板使用。

工作原理

Proton 基於 ClickHouse 引擎建構，透過擴展其儲存與運算能力來支援串流處理。它使用單一 C++ 二進位檔，並搭配 SIMD 優化，實現高吞吐量與低延遲。使用者主要透過 SQL 建立外部串流（例如來自 Kafka 或 Redpanda）與外部資料表，並使用物化檢視實時轉換與路由資料。

適用對象

適用於建構即時 ETL 流水線、具備警示功能的遙測流水線，以及需要低延遲、高吞吐量處理即時資料的 AI/ML 模型即時特徵流水線的資料工程師與開發者。

主要特色

• 高效率：可達每秒 9000 萬事件（EPS），端對端延遲為毫秒級。
• 零相依：以單一二進位檔（<500MB）分發，無需 JVM 或 ZooKeeper。
• 廣泛連接性：原生支援 Kafka、ClickHouse、MySQL、Postgres、MongoDB，以及 S3/Iceberg 等資料來源與目標。
• 串流 SQL：支援 tumble、hop 與 session 窗格、水印與增量物化檢視。
• 可擴充性：支援使用 Python 與 JavaScript 編寫的使用者定義函數（UDF）。