stream-processing

ストリーム処理、リアルタイム分析、LLMパイプライン、RAGのためのPython ETLフレームワーク

ライブおよびストリーミングメディア向けのクロスプラットフォーム対応のカスタマイズ可能なMLソリューション。

高性能なオブザーバビリティデータパイプライン。

Flink学習ブログ。http://www.54tianzhisheng.cn/ Flinkの入門、概念、原理、実践、性能チューニング、ソースコード解析などの内容を網羅しています。Flink Connector、Metrics、Library、DataStream API、Table API & SQLなどの学習事例に加え、Flinkの実装適用における大規模プロジェクト事例（PVUV、ログストレージ、百億データリアルタイム重複排除、監視アラート）も共有しています。私のコラム「ビッグデータリアルタイム計算エンジン Flink 実践と性能最適化」をぜひご覧ください。

優れたビッグデータフレームワーク、リソース、その他の機能を厳選したリスト。

Redpandaは開発者向けのストリーミングデータプラットフォームです。Kafka APIと互換性があります。10倍高速。ZooKeeper不要。JVM不要！

素晴らしいシステムデザイン（別名：分散システム）リソースの厳選リスト。

Goでイベント駆動型アプリケーションを簡単に構築する方法。

エージェンティックAIのためのイベントストリーミングプラットフォーム。イベントストリームをリアルタイムで、大規模に継続的に取り込み、変換、提供します。

華やかなストリーム処理を運用上、日常的なものに。

Linux、BSD、OSX、Windows向けの高速かつ軽量なログ、メトリクス、トレースプロセッサ

Pythonストリーム処理

Hazelcastは、ストリーム処理と高速データストアを組み合わせた統合リアルタイムデータプラットフォームであり、顧客がデータインモーションに対して即座に行動し、リアルタイムの洞察を得ることを可能にします。

アプリおよびAIエージェントのためのライブデータレイヤー。SQLのみを使用して、ビジネスの最新のビューを作成できます。

ビッグデータにおけるUpserts、削除、およびインクリメンタル処理

🌊 Pythonでのオンライン機械学習

FastStreamは、イベント駆動型アプリケーションを構築するための非同期Pythonフレームワークです。メッセージブローカー統合、依存性注入、バリデーション、テストユーティリティ、AsyncAPIドキュメント生成を単一のツールキットに集約しています。

🦀 イベントストリーム処理。開発者が動的なデータを収集・変換し、応答性の高いデータ集約型アプリケーションを駆動させるためのもの。

Danfo.jsは、構造化データを操作および処理するための、高性能で直感的かつ使いやすいデータ構造を提供するオープンソースのJavaScriptライブラリです。

Rustによる分散ストリーム処理エンジン。

Postgres から Data Warehouse、Queue、Storage へデータを高速かつシンプルに、コスト効率よくレプリケートするためのツール

素晴らしいストリーミングフレームワークやアプリケーションなどのキュレーションリスト

大規模並列データおよびストリーミングジョブを実行するための Kubernetes ネイティブプラットフォーム

単一の C++ バイナリによる最速の統合型ストリーミング SQL エンジン。⚡ ミリ秒単位のレイテンシ、100+ GB/s のスループット。ストリーム、ログ、メトリクス、イベント、CDC からリアルタイムコンテキストを継続的に計算します。

Go向けの軽量ストリーム処理ライブラリ

Python ストリーム処理

ゼロから構築された分散ログストリーミングエンジン

Yahoo! Pipes をモデルにした Python ストリーム処理エンジン

ストリーム処理および複雑イベント処理エンジン

Kafka 向け Python ストリーミング DataFrame