Stream Processing Python Packages

mediapipe

Cross-platform, customizable ML solutions for live and streaming media.

faststream

FastStream is a powerful and easy-to-use asynchronous Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS, MQTT and Redis.

river

🌊 Online machine learning in Python

quixstreams

Python Streaming DataFrames for Kafka

csp

csp is a high performance reactive stream processing library, written in C++ and Python

distogram

A library to compute histograms on distributed environments, on streaming data

sentry-arroyo

A library to build streaming applications that consume from and produce to Kafka.

hdx-python-utilities

A range of helpful utilities for Python developers including streaming tabular data, date parsing, JSON and YAML handling, dictionary and list utilities

bytewax

Python Stream Processing

faust

Python Stream Processing

mediapipe-nightly

Cross-platform, customizable ML solutions for live and streaming media.

pathway

Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.

mediapipe-model-maker

Cross-platform, customizable ML solutions for live and streaming media.

zef

Toolkit for graph-relational data across space and time

gretel-client

The Gretel Python Client allows you to interact with the Gretel REST API.

probstructs

Collection of probabilistic data structures - CM-Sketch, ECM-Sketch, exponential histogram

ralph-malph

:gear: Ralph, the ultimate Learning Record Store (and more!) for your learning analytics

dbt-materialize

The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL

streamsx

Python core package for IBM Streams.

creme

🌊 Online machine learning in Python

wingfoil

Python bindings for the wingfoil Rust library

radio-active

Play any radios around the globe right from the terminal :zap:

beavers

Python stream processing for analytics

numalogic-prometheus

Numalogic Prometheus based tools