This commit is contained in:
Vladislav 2026-07-19 22:20:43 -04:00
parent f72102e7b1
commit 07039cca40
4 changed files with 23 additions and 5 deletions

View File

@ -426,7 +426,16 @@
"metadata": {}, "metadata": {},
"outputs": [], "outputs": [],
"source": [ "source": [
"!ssh kultmost 'systemctl restart fastapi.service'\n", "!ssh kultmost 'systemctl restart fastapi.service'\n"
]
},
{
"cell_type": "code",
"execution_count": null,
"id": "8714f4cc",
"metadata": {},
"outputs": [],
"source": [
"!ssh kultmost 'systemctl status fastapi.service'" "!ssh kultmost 'systemctl status fastapi.service'"
] ]
}, },
@ -445,7 +454,16 @@
"metadata": {}, "metadata": {},
"outputs": [], "outputs": [],
"source": [ "source": [
"!ssh kultmost 'systemctl restart vk-celery.service'\n", "!ssh kultmost 'systemctl restart vk-celery.service'\n"
]
},
{
"cell_type": "code",
"execution_count": null,
"id": "3f77084c",
"metadata": {},
"outputs": [],
"source": [
"!ssh kultmost 'systemctl status vk-celery.service'" "!ssh kultmost 'systemctl status vk-celery.service'"
] ]
}, },

2
db.py
View File

@ -66,7 +66,7 @@ __all__ = [
"users_collection", "users_token_collection", "users_collection", "users_token_collection",
"notify_collection", "social_collection", "notify_collection", "social_collection",
"posts_collection", "news_collection", "posts_collection", "news_collection",
"gridfs_map", "redis_client", "redis_uri" "gridfs_map", "redis_client", "redis_uri",
"mongo_client", "invitations_collection", "mongo_client", "invitations_collection",
"delivery_collection", "exhibition_collection", "delivery_collection", "exhibition_collection",
"rabbit_mq_uri" "rabbit_mq_uri"

View File

@ -102,7 +102,7 @@
"metadata": {}, "metadata": {},
"outputs": [], "outputs": [],
"source": [ "source": [
"celery_app_tg = Celery('tg', broker=f'amqps://admin:{RABBITMQ_PASS}@{RABBITMQ_HOST}/tg', task_track_started=True )\n" "celery_app_tg = Celery('tg', broker=f'amqps://admin:{RABBITMQ_PASS}@{RABBITMQ_HOST}:{RABBITMQ_PORT}/tg', task_track_started=True )\n"
] ]
}, },
{ {

2
tg.py
View File

@ -24,7 +24,7 @@ Image.MAX_IMAGE_PIXELS = 50_000_000
TMP_DIR = Path("/tmp") TMP_DIR = Path("/tmp")
TMP_DIR.mkdir(parents=True, exist_ok=True) TMP_DIR.mkdir(parents=True, exist_ok=True)
celery_app_tg = Celery('tg', broker=f'amqps://admin:{RABBITMQ_PASS}@{RABBITMQ_HOST}/tg', task_track_started=True ) celery_app_tg = Celery('tg', broker=f'amqps://admin:{RABBITMQ_PASS}@{RABBITMQ_HOST}:{RABBITMQ_PORT}/tg', task_track_started=True )
async def fetch_bytes(client: httpx.AsyncClient, url: str) -> bytes: async def fetch_bytes(client: httpx.AsyncClient, url: str) -> bytes: