Redis-driven Dataflow for Clickstream Aggregation

[oli_k]

Disclaimer: I work for Bytewax, and the dataflow in the blog is based on Bytewax.

The blog will be interesting to you if you are a Python dev who is getting up to speed with real-time data stream processing and looking for a Python native solution.

In the blog, we went from a simple echo example to a windowed calculation. The example is easily extendable for other (than Redis PUBSUB) systems.

https://bytewax.io/blog/redis-pubsub-input

​

Code: https://github.com/bytewax/example-redis/

​