fix: правка урла кролика

develop
Сергей Ванюшкин 2024-02-12 00:54:53 +03:00
parent a0ebe9bdb9
commit 3df3c67e7c
2 changed files with 13 additions and 1 deletions

View File

@ -2,6 +2,7 @@ import asyncio
from celery import Celery from celery import Celery
from ..fastfood.config import settings
from .updater import main from .updater import main
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
@ -9,7 +10,7 @@ loop = asyncio.get_event_loop()
celery_app = Celery( celery_app = Celery(
'tasks', 'tasks',
broker='amqp://guest:guest@localhost', broker=settings.REBBITMQ_URL,
backend='rpc://', backend='rpc://',
include=['bg_tasks.bg_task'], include=['bg_tasks.bg_task'],
) )

View File

@ -66,6 +66,17 @@ class Settings(BaseSettings):
return f'redis://{self.REDIS_HOST}:{self.REDIS_PORT}/{self.REDIS_DB}' 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') model_config = SettingsConfigDict(env_file='.env')