T
Странно
Size: a a a
2020 June 16
T
У тебя какой брокер?
ЕР
кролик
ЕР
rabbitmq_broker = RabbitmqBroker(url=f'amqp://{login}:{password}@rabbitmq:5672')T
по dramatiq'у подскажи момент ещё. Вот тут решение от автора.
Я правильно понял, что вот так закрывать надо
или же надо внутри
Я правильно понял, что вот так закрывать надо
@dramatiq.actor
def handle_message(event):
bot.handle_message(event)
def receive_message(event):
handle_message.send(event)
rabbitmq_broker.connection.close()
return 'OK'
или же надо внутри
send'а это делать?эм, это какая-то фигня
T
по dramatiq'у подскажи момент ещё. Вот тут решение от автора.
Я правильно понял, что вот так закрывать надо
или же надо внутри
Я правильно понял, что вот так закрывать надо
@dramatiq.actor
def handle_message(event):
bot.handle_message(event)
def receive_message(event):
handle_message.send(event)
rabbitmq_broker.connection.close()
return 'OK'
или же надо внутри
send'а это делать?это у него реашает пробелму долгих тасков только
T
или даже долгих простоев без опроса
T
у тебя таск сколько выполняется в норме?
ЕР
быстро
ЕР
а, ну там есть слип
T
ну короче это тупо issue про то что рвется соединение
T
а, ну там есть слип
зачем?
ЕР
зачем?
ну типа имитация написания ответа ботом
ЕР
слип секунду
ЕР
а если много сообщений от бота, то получается несколько слипов
АП
Удобно.
ЕР
Удобно.
звучит, как подъёб
АП
Это он и есть.
ЕР
Удобно.
а как ещё сделать имитацию?
ЕР
ну короче это тупо issue про то что рвется соединение
Я правильно понимаю, что rabbit открывает соединения по 60 секунд и потом закрывает, и видимо в эти последние секунды влетает вот такой долгий send на 5-6 секунд и из-за этого получается ошибка - я прав?