Django с asgi_rabbit, почему я получаю сообщение об ошибке закрытия соединения. Не устанавливается новое соединение
Я использую Django с asgi и брокером rabbitmq. Он работает нормально, но по какому-то запросу я получаю следующее сообщение об ошибке. В основном это происходит при загрузке файла. И тогда django теряет соединение и не открывает новое. Понятия не имею, с чего начать поиск.
Я пробовал с asgi-rabbitmq 0.5.5, но то же самое происходило всегда после 60 секунд, так как rabbitmq действительно получил тайм-аут сердцебиения. Но я не знаю, как этого избежать.
зависимости: Rabbit mq 3.8.1
amqp==2.5.2 # via kombu
asgi-rabbitmq==0.5.3
asgiref==1.1.2 # via asgi-rabbitmq, channels, daphne
autobahn==19.11.1 # via daphne
billiard==3.6.1.0 # via celery
cached-property==1.5.1 # via asgi-rabbitmq, zeep
celery==4.3.0
daphne==1.4.2 # via channels
defusedxml==0.6.0 # via zeep
django==1.11.26
djangorestframework==3.9.4
kombu==4.6.6 # via celery
lxml==4.4.2 # via zeep
markupsafe==1.1.1
more-itertools==5.0.0 # via zipp
msgpack-python==0.5.6 # via asgi-rabbitmq
six==1.13.0 # via asgiref,
singledispatch, structlog, txaio, zeep
twisted==19.10.0 # via daphne
Конфигурация каналов: BROKER_URL = 'amqp://'
CHANNEL_LAYERS = {
'default': {
'BACKEND': 'asgi_rabbitmq.RabbitmqChannelLayer',
'CONFIG': {
'url': 'amqp://guest:guest@localhost:5672/%2F',
},
'ROUTING': 'timeline_prototype.apps.core.routing.channel_routing',
}
}
ошибка django (например, сервер запуска)
ERROR daphne.http_protocol http_protocol.py 184 process 2019-12-05 09:31:03 [error ] Traceback (most recent call last):
File "/myproject-env/lib/python2.7/site-packages/daphne/http_protocol.py", line 178, in process
"server": self.server_addr,
File "/myproject-env/lib/python2.7/site-packages/asgi_rabbitmq/core.py", line 812, in send
future = self.thread.schedule(SEND, channel, message)
File "/myproject-env/lib/python2.7/site-packages/asgi_rabbitmq/core.py", line 743, in schedule
return self.connection.schedule(f, *args, **kwargs)
File "/myproject-env/lib/python2.7/site-packages/asgi_rabbitmq/core.py", line 692, in schedule
raise ConnectionClosed
ConnectionClosed
Unexpected frame: <METHOD(['channel_number=2', 'frame_type=1', "method=<Queue.DeclareOk(['consumer_count=0', 'message_count=0', 'queue=daphne.response.UhTfXiymuo!'])>"])>