Сельдерей с Gevant дает сбой с ошибкой подключения для Windows 10 - PullRequest
0 голосов
/ 26 июня 2019

Я использую windows 10 и Celery 4.3, когда я первоначально пытался настроить Celery, я обнаружил, что celery не поддерживает окна начиная с версии 4 и выше, поэтому люди предложили использовать gevent, как предложено в ответе ниже

Сельдерей повышает ValueError: недостаточно значений для распаковки

Итак, я попробовал вышеописанное, сначала все, казалось, работало, но позже я столкнулся с проблемой ниже от Gavent

[2019-06-26 23:16:24,282: WARNING/MainProcess] Traceback (most recent call last):
[2019-06-26 23:16:24,282: WARNING/MainProcess] File "src/gevent/_waiter.py", line 119, in gevent.__waiter.Waiter.switch
[2019-06-26 23:16:24,283: WARNING/MainProcess] File "c:\users\aadhikarla\appdata\local\continuum\anaconda3\lib\site-packages\celery\worker\pidbox.py", line 120, in loop
    connection.drain_events(timeout=1.0)
[2019-06-26 23:16:24,284: WARNING/MainProcess] File "c:\users\aadhikarla\appdata\local\continuum\anaconda3\lib\site-packages\kombu\connection.py", line 315, in drain_events
    return self.transport.drain_events(self.connection, **kwargs)
[2019-06-26 23:16:24,284: WARNING/MainProcess] File "c:\users\aadhikarla\appdata\local\continuum\anaconda3\lib\site-packages\kombu\transport\pyamqp.py", line 103, in drain_events
    return connection.drain_events(**kwargs)
[2019-06-26 23:16:24,284: WARNING/MainProcess] File "c:\users\aadhikarla\appdata\local\continuum\anaconda3\lib\site-packages\amqp\connection.py", line 500, in drain_events
    while not self.blocking_read(timeout):
[2019-06-26 23:16:24,284: WARNING/MainProcess] File "c:\users\aadhikarla\appdata\local\continuum\anaconda3\lib\site-packages\amqp\connection.py", line 505, in blocking_read
    frame = self.transport.read_frame()
[2019-06-26 23:16:24,285: WARNING/MainProcess] File "c:\users\aadhikarla\appdata\local\continuum\anaconda3\lib\site-packages\amqp\transport.py", line 252, in read_frame
    frame_header = read(7, True)
[2019-06-26 23:16:24,285: WARNING/MainProcess] File "c:\users\aadhikarla\appdata\local\continuum\anaconda3\lib\site-packages\amqp\transport.py", line 436, in _read
    s = recv(n - len(rbuf))
[2019-06-26 23:16:24,286: WARNING/MainProcess] File "c:\users\aadhikarla\appdata\local\continuum\anaconda3\lib\site-packages\gevent\_socket3.py", line 378, in recv
    return _socket.socket.recv(self._sock, *args)
[2019-06-26 23:16:24,286: WARNING/MainProcess] ConnectionResetError: [WinError 10054] An existing connection was forcibly closed by the remote host
[2019-06-26 23:16:24,286: WARNING/MainProcess] 2019-06-26T17:46:24Z
[2019-06-26 23:16:24,286: WARNING/MainProcess] <built-in method switch of gevent.__greenlet_primitives.TrackedRawGreenlet object at 0x000001EA469FAAC8> failed with ConnectionResetError

Не могу понять, к чему относится ошибка, любая информация очень поможет.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...