runnel
runnel copied to clipboard
Distributed event processing for Python based on Redis Streams
Hi. Having a lightweight alternative for Kafka/Faust is awesome, a shame this hasn't got more attention up until now, thanks for sharing! Wondering what's the current status of the project....
Running simple example for middlewares: ```py from datetime import datetime from runnel import App, Record, Events, Middleware app = App(name="myapp", redis_url="redis://127.0.0.1") class Order(Record): order_id: int created_at: datetime amount: int class...
Hi, thank you for developing runnel! I would like to add a simple redis key/value store functionality to be used within processor functions whereas (for performance purposes) the already open...
On pypi https://pypi.org/project/runnel/ as well as https://runnel.dev/ there is no link to https://github.com/mjwestcott/runnel/. That makes searching a bit ... harder :) It would be nice to have links to github...
[This](https://github.com/mjwestcott/runnel/blob/d36cb26bd4b4e782cd267adbc81c869c2dcc3e25/runnel/worker.py#L102) is the calling code. Worker exits with this error just after reaching 'new-leader'. Windows systems not having signals seems to be the cause: https://stackoverflow.com/q/45987985/4670905 Python version: 3.8.5
Hi, I was wondering if you have plans for adding django integration.
Sometimes random integration tests fail with `aredis.exceptions.ResponseError: Wrong number of response items from pipeline execution`. I believe this is a bug in `aredis` caused by failing to disconnect and clean...
Sometimes random integration tests on Python 3.7 fail when exiting due to an uncaught `ConnectionError` from our Redis driver [aredis](https://github.com/NoneGG/aredis). I believe this is a bug in `aredis` caused by...
Traceback (most recent call last): File "", line 2, in File "", line 34, in File "/private/var/folders/cl/f52jsnxs3h17synxy71jj7m80000gn/T/pip-install-imuphfjw/hiredis_f2348412130b4d15bc2c28956de37c49/setup.py", line 7, in import sys, imp, os, glob, io ModuleNotFoundError: No module named...