udochudo/Telezab
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: (rabbitmq flask client) optimize imports to resolve warnings
All checks were successful
Build and Push Docker Images / build (push) Successful in 1m11s
Details

Browse Source 
Signed-off-by: UdoChudo <stream@udochudo.ru>
This commit is contained in:
Udo Chudo 2025-06-23 00:38:25 +05:00
parent cec3bcb500
commit 295c1f68e0
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
app/extensions/rabbitmq.py
View File

@ -1,7 +1,11 @@
import pika
from config import RABBITMQ_HOST, RABBITMQ_PORT, RABBITMQ_LOGIN, RABBITMQ_PASS, RABBITMQ_QUEUE
import time import time
import pika
from pika.exceptions import ChannelClosedByBroker, ConnectionClosed, AMQPConnectionError
from config import RABBITMQ_HOST, RABBITMQ_PORT, RABBITMQ_LOGIN, RABBITMQ_PASS, RABBITMQ_QUEUE
class RabbitMQClient: class RabbitMQClient:
def __init__(self): def __init__(self):
self._connect() self._connect()
@ -31,9 +35,9 @@ class RabbitMQClient:
delivery_mode=2, delivery_mode=2,
) )
) )
except (pika.exceptions.ChannelClosedByBroker, except (ChannelClosedByBroker,
pika.exceptions.ConnectionClosed, ConnectionClosed,
pika.exceptions.AMQPConnectionError) as e: AMQPConnectionError) as e:
if retry > 0: if retry > 0:
# Короткая пауза перед переподключением # Короткая пауза перед переподключением
time.sleep(1) time.sleep(1)