import aioredis
import os

redis = None

async def init_redis():
    global redis
    redis = await aioredis.from_url(
        os.getenv("REDIS_URL", "redis://localhost"), decode_responses=True
    )