PyRank

Streaming Data Python Packages

Python packages with the GitHub topic streaming-data. Sorted by monthly downloads, with stars and forks.
piskvorky
smart-open

Utils for streaming large files (S3, HDFS, gzip, bz2...)

58M 3K 395
guillermo-navas-palencia
optbinning

Optimal binning: monotonic binning with constraints. Support batch & stream optimal binning. Scorecard modelling and counterfactual explanations.

180K 532 118
online-ml
river

🌊 Online machine learning in Python

174K 6K 830
quixio
quixstreams

Python Streaming DataFrames for Kafka

88K 2K 114
Sinotrade
shioaji

Shioaji all new cross platform api for trading ( 跨平台證券交易API )

72K 524 41
python-streamz
streamz

Real-time stream processing for python

40K 1K 150
bytewax
bytewax

Python Stream Processing

40K 2K 112
MaterializeInc
dbt-materialize

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

10K 6K 514
aramisfacchinetti
streaming-json-parser

Python JSON decoding with strict incremental parsing, NDJSON, and selective extraction.

5K 13 2
creme-ml
creme

🌊 Online machine learning in Python

2K 6K 829
scikit-multiflow
scikit-multiflow

A machine learning package for streaming data in Python. The other ancestor of River.

2K 798 188
Menziess
slipstream-async

Slipstream provides a data-flow model to simplify development of stateful streaming applications.

2K 39 2
selimfirat
pysad

Streaming anomaly detection in Python: 16 online detectors (xStream, LODA, RS-Hash, Half-Space Trees, RRCF…) plus calibration and prequential evaluation for real-time data.

2K 295 45
purijs
blazerules

A SIMD-accelerated, C++ rule engine, embeddable in pipelines. Evaluates declarative rules over event batches at memory-bandwidth speed

2K 11 1
maki-nage
rxsci

ReactiveX for data science

2K 14 2
OliverHennhoefer
aberrant

Online Anomaly Detection Algorithms

1K 5 0
sdpython
pandas-streaming

Streaming API for pandas applied to big datasets

1K 31 8
thammo4
uvatradier

Python wrapper for the Tradier brokerage API

776 29 19
streamdal
streamdal-protos

Code-Native Data Privacy

635 614 16
ori88c-python-packages
top-k

Keep the top-k highest-priority items from a stream in O(k) space. Zero runtime dependencies.

459 0 0
OliverHennhoefer
onad

Online Anomaly Detection Algorithms

343 5 0
denisecase
datafun-streaming

Shared Python utilities for Kafka, DuckDB, validation, stats, and visualization across streaming data analytics projects.

302 1 0
neurodata
sdtf

Exploring streaming options for decision trees and random forests. Based on scikit-learn fork.

185 9 3
geniusrise
geniusrise-listeners

A collection of Spouts that listen to events

179 2 5