main.py 文件源码

def install_redis_handle(app):
    global SUB
    while True:
        SUB = await aioredis.create_redis((settings.REDIS_HOST, 6379), password=settings.REDIS_PASSWORD)
        res = await SUB.psubscribe("enibar-*")
        subscriber = res[0]

        while await subscriber.wait_message():
            reply = await subscriber.get_json()
            await app.redis_handle(reply[0].decode(), reply[1])
        await asyncio.sleep(1)