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!'])>"])>

0 ответов

Другие вопросы по тегам