входящих сообщений, но что-то происходит с коннектом - вылетает с эксепшеном ConnectionWrongStateError: BlockingConnection.close(200, 'Normal shutdown') called on closed connection.
Код и трейсбек по ссылке:
https://pastebin.com/41gNp5G0
там нет модуля _queue, там только сам коннект и пара функций-обёрток
Делал примерно как https://github.com/pika/pika/blob/0.12.0/examples/basic_consumer_threaded.py
Если запускать без threading, то всё работает хорошо.
В чём может быть проблема и какие советы дадите?
В треде ты что делаешь?
Предполагаю делать запрос в постгрю (локальные сессии sqlalchemy), запрос в redis (вроде как клиент threadsafe), http запрос через urllib3, и собирался ещё делать publish в другую очередь, но пока закоментил, так как и просто получение нормально не отрабатывает.
Обсуждают сегодня