src/utils/_redis_client.py

import os
import redis.asyncio as redis


class RedisClient:
    def __init__(self):
        self.redis_url = os.getenv("REDIS_URI")
        self.client = self.init_redis()

    def init_redis(self):
        redis_client = redis.from_url(
            url=self.redis_url, encoding="utf-8", decode_responses=True
        )
        return redis_client