Comment by bayesian_horse

Dask is relatively lightweight actually, because it is pure Python.

Also, there is "Streamz" which solves a similar problem, seems more mature and can work with or without Dask or Dask-Distributed.