From 417566a202298d0b00ff355a6aeec655d72c9f65 Mon Sep 17 00:00:00 2001 From: Vladless Date: Sat, 21 Feb 2026 13:52:21 +0300 Subject: [PATCH] Redis url in config file --- bot.py | 7 ++----- core/redis_cache.py | 6 +++--- 2 files changed, 5 insertions(+), 8 deletions(-) diff --git a/bot.py b/bot.py index 1ec1613e..05bece4a 100644 --- a/bot.py +++ b/bot.py @@ -1,4 +1,3 @@ -import os from importlib import import_module from aiogram import Bot, Dispatcher @@ -6,7 +5,7 @@ from aiogram.client.default import DefaultBotProperties from aiogram.enums import ParseMode from aiogram.fsm.storage.memory import MemoryStorage -from config import API_TOKEN +from config import API_TOKEN, REDIS_URL from filters.private import IsPrivateFilter from utils.button_icons import apply_button_icons_patch, set_button_icon_config from utils.custom_emojis import initialize_custom_emojis @@ -17,13 +16,11 @@ apply_button_icons_patch() bot = Bot(token=API_TOKEN, default=DefaultBotProperties(parse_mode=ParseMode.HTML)) storage = MemoryStorage() -redis_url = os.getenv("REDIS_URL", "redis://127.0.0.1:6379/0") - try: RedisStorage = import_module("aiogram.fsm.storage.redis").RedisStorage redis_from_url = import_module("redis.asyncio").from_url - redis = redis_from_url(redis_url, encoding="utf-8", decode_responses=True) + redis = redis_from_url(REDIS_URL, encoding="utf-8", decode_responses=True) storage = RedisStorage(redis=redis) except Exception: storage = MemoryStorage() diff --git a/core/redis_cache.py b/core/redis_cache.py index 5e760b45..71a384c4 100644 --- a/core/redis_cache.py +++ b/core/redis_cache.py @@ -1,9 +1,10 @@ import json -import os import time from importlib import import_module from typing import Any +from config import REDIS_URL + _REDIS_CLIENT = None _REDIS_UNAVAILABLE_UNTIL = 0.0 _REDIS_BACKOFF_SEC = 5.0 @@ -22,9 +23,8 @@ async def _get_redis() -> Any | None: return None try: - redis_url = os.getenv("REDIS_URL", "redis://127.0.0.1:6379/0") redis_from_url = import_module("redis.asyncio").from_url - client = redis_from_url(redis_url, encoding="utf-8", decode_responses=True) + client = redis_from_url(REDIS_URL, encoding="utf-8", decode_responses=True) await client.ping() _REDIS_CLIENT = client return _REDIS_CLIENT