Redis Pub/Sub Listener

import redis, json, threading

r = redis.from_url("redis://localhost:6379/0")

def listen(channel: str, handlers: dict):
    ps = r.pubsub()
    ps.subscribe(channel)
    def _run():
        for msg in ps.listen():
            if msg["type"] != "message": continue
            data = json.loads(msg["data"])
            fn = handlers.get(data.get("event"))
            if fn: fn(data)
    threading.Thread(target=_run, daemon=True).start()

listen("events", {"module.published": lambda d: print("New module:", d)})