Python Stream Processing with Denormalized
Python Stream Processing with Denormalized
tl;dr we’re releasing python bindings for writing stream processing jobs using the Denormalized Rust library. Hey HN, A few months ago we released Denormalized, our embeddable stream processing engine written in rust [0]. Today we’re excited to showcase python bindings for the library. Python is still very much the language of data and we wanted to make it easy for more engineers to write fast streaming jobs without having to learn Rust. Currently, you can use the library to write streaming aggregations, stream joins, and user defined aggregate functions (thought the API for this is quite clunk). The library is available on pypi: `pip install denormalized` and we’ve created a simple docker container that will quickly spin up an instance of kafka along with a script to write fake data to make running the examples [1] really easy: `docker run --rm -p 9092:9092 emgeee/kafka_emit_measurements:latest` We’d love to hear your feedback [0] https://news.ycombinator.com/item?id=41258276 [1] https://github.com/probably-nothing-labs/denormalized/tree/m...
Share cardActual performance
Launch Intel predictions
Analyze your own launch →Correct prediction on native model
Similar products
Minibatch – Python stream processing
Bytewax – Python Stateful Stream Processing on Timely Dataflow
Riko – A Python stream processing engine modeled after Yahoo! Pipes
Table data stream processing – Python convtools
Iterable-subprocess – Stream to and from a subprocess in Python
Stream-zip – Stream-construct ZIP archives in Python
We built rescaling for distributed stateful stream processing
Stream-unzip – stream unZIP files in Python
Jet – in-memory, fault-tolerant, distributed stream processing
Benthos, stream multiplexer and processing service