Rustエンジンを基盤とし、ストリーム処理、リアルタイム分析、LLMパイプライン、RAGに対応するPython ETLフレームワーク。
timeplus-io/proton
ClickHouseを基盤とする単一バイナリのストリーミングSQLエンジン。Kafkaなどのデータソースを使ったストリーム処理、リアルタイム分析、パイプラインを実現します。
代替できる製品:Apache Flink
ksqlDB
- スター
- 2,281
- フォーク
- 112
- 未解決の Issue
- 75
- 最終コミット
- 9 日前
これは何?
Timeplus Protonは、JVMやZooKeeperに依存しない単一のC++バイナリとして配布されるストリーミングSQLエンジンです。ClickHouseのストレージ機能とクエリ機能を連続ストリーム処理で拡張し、ライブデータに対するSQLの実行や、クエリ可能なマテリアライズドビューへの結果の永続化ができます。
Kafka、Redpanda、Confluent Cloud向けの外部ストリーム、ClickHouse向けの外部テーブルに対応し、MySQL、Postgres、MongoDB、S3/Icebergなどのシステム向けにソースとシンクを提供します。tumble、hop、sessionウィンドウ、複数ストリームの結合、インクリメンタルなマテリアライズドビュー、CDC処理、PythonまたはJavaScriptで記述するUDFを利用できます。
シェルスクリプト、Homebrew、Dockerでインストールでき、SQLクライアントから利用できます。Python、Java、Goのドライバーも用意されています。オープンソース版は単一ノードでのデプロイに対応し、クラスタリング、Kubernetesへのデプロイ、追加コネクターは商用製品のTimeplus Enterpriseで提供されます。
主な機能
- 01ライブデータに対し、tumble、hop、sessionウィンドウを使ったストリーミングSQLを実行できます。
- 02Kafka、Redpanda、Confluent Cloud向けの外部ストリームと、ClickHouse向けの外部テーブルに対応します。
- 03クエリ可能な結果をエンジン内に永続化する、インクリメンタルなマテリアライズドビューを提供します。
- 04JVMやZooKeeperに依存せず、単一のバイナリとして動作します。
- 05PythonまたはJavaScriptで記述したUDFに対応します。
ユースケース
- ClickHouseに読み込む前にKafkaデータをフィルタリング、エンリッチ、マスキングするストリーミングETL。
- アラート機能を備え、ログやメトリクスを振り分けるリアルタイムのテレメトリパイプライン。
- ウィンドウ集計を使って、AI/MLパイプライン向けのストリーミング特徴量を計算。
クイックスタート
- 1
README に記載されている公式インストールスクリプトを実行します(Mac/Linux)
- 2
または、Mac では Homebrew でインストールします
brew install timeplus-io/timeplus/proton - 3
サーバーを起動します
proton server - 4
別のターミナルで SQL クライアントを開きます
proton client
使う前に知っておきたいこと
- 単一バイナリでのデプロイは、Mac と Linux のみを対象としてドキュメント化されています。
- コミュニティサポートは GitHub と Slack でのみ利用できます。CSV アップロード、NATS、Kubernetes ホスティングなどのエンタープライズ機能は、Timeplus Enterprise で提供されています。
収録されている特集
トピック
よくある質問
- proton とは?
- ClickHouseを基盤とする単一バイナリのストリーミングSQLエンジン。Kafkaなどのデータソースを使ったストリーム処理、リアルタイム分析、パイプラインを実現します。 Timeplus Protonは、JVMやZooKeeperに依存しない単一のC++バイナリとして配布されるストリーミングSQLエンジンです。ClickHouseのストレージ機能とクエリ機能を連続ストリーム処理で拡張し、ライブデータに対するSQLの実行や、クエリ可能なマテリアライズドビューへの結果の永続化ができます。
- proton は無料で使えますか?ライセンスは?
- proton は Apache-2.0 ライセンスのオープンソースです。商用製品で使う前にライセンス条件を確認してください。
- proton は今もメンテナンスされていますか?
- 活発にメンテナンス中。proton の最終コミットは 2026年10月30日 です。
- proton は何に使えますか?
- ClickHouseに読み込む前にKafkaデータをフィルタリング、エンリッチ、マスキングするストリーミングETL。 アラート機能を備え、ログやメトリクスを振り分けるリアルタイムのテレメトリパイプライン。 ウィンドウ集計を使って、AI/MLパイプライン向けのストリーミング特徴量を計算。
- proton のインストール方法は?
- README に記載されている公式インストールスクリプトを実行します(Mac/Linux) または、Mac では Homebrew でインストールします: brew install timeplus-io/timeplus/proton サーバーを起動します: proton server 別のターミナルで SQL クライアントを開きます: proton client
- proton はどこで入手できますか?
- ソースコードとインストール手順は GitHub にあります:https://github.com/timeplus-io/proton
概要はプロジェクトの README をもとに AI が生成しています。GitHub の数値は毎日更新されます。
関連プロジェクト
Kafka、MQTT、NATSなどのリアルタイムデータに対して、SQL、Python UDF、ML/LLM処理を実行するRust製ストリーム処理エンジン。
Rust製の分散ストリーム処理エンジン。リアルタイムデータストリーム上で、状態を保持するSQLパイプラインを実行できます。
メッセージブローカー、クラウドサービス、データベースをつなぎ、間でペイロードを変換するマッピング言語を備えたGo製ストリームプロセッサ。
JSON形式のジョブ設定で30以上のRDBMS・NoSQLデータソース間のデータを移行できるオープンソースETLツール。AlibabaのDataXを引き継いで保守を継続。
ログやメトリクスを収集・変換し、任意の宛先へルーティングするRust製の高性能なオブザーバビリティデータパイプライン。