INNER CODE UNIT · Python

redis_watchdog

arvin341az-glitch/RVG · main.py:176

async def redis_watchdog():
    """هر ۱۵ ثانیه وضعیت اتصال Redis رو چک/تلاش برای وصل‌شدن دوباره می‌کنه، تا
    وضعیت نمایش‌داده‌شده در پنل همیشه واقعی باشه (نه فقط لحظه‌ی استارت)."""
    global redis_client, REDIS_CONNECTED
    if not REDIS_URL or aioredis is None:
        return
    while True:
        await asyncio.sleep(15)
        try:
            if redis_client is None:
                redis_client = aioredis.from_url(
                    REDIS_URL, decode_responses=True, socket_connect_timeout=5, socket_timeout=5,
                )
            await redis_client.ping()
            if not REDIS_CONNECTED:
                logger.info("اتصال به Redis دوباره برقرار شد.")
            REDIS_CONNECTED = True
        except Exception:

View source record →