diff --git a/bg_tasks/bg_task.py b/bg_tasks/bg_task.py index c73b51e..ddf7360 100644 --- a/bg_tasks/bg_task.py +++ b/bg_tasks/bg_task.py @@ -2,6 +2,7 @@ import asyncio from celery import Celery +from ..fastfood.config import settings from .updater import main loop = asyncio.get_event_loop() @@ -9,7 +10,7 @@ loop = asyncio.get_event_loop() celery_app = Celery( 'tasks', - broker='amqp://guest:guest@localhost', + broker=settings.REBBITMQ_URL, backend='rpc://', include=['bg_tasks.bg_task'], ) diff --git a/fastfood/config.py b/fastfood/config.py index 7420230..4bd39c9 100644 --- a/fastfood/config.py +++ b/fastfood/config.py @@ -66,6 +66,17 @@ class Settings(BaseSettings): return f'redis://{self.REDIS_HOST}:{self.REDIS_PORT}/{self.REDIS_DB}' + @property + def REBBITMQ_URL(self): + """ + Возвращает строку подключения к REBBITMQ + """ + file_path = '/usr/src/RUN_IN_DOCKER' + if os.path.exists(file_path): + return 'amqp://guest:guest@localhost' + + # return f"redis://{self.REDIS_HOST}:{self.REDIS_PORT}/{self.REDIS_DB}" + model_config = SettingsConfigDict(env_file='.env')