Status of node rabbit@DESKTOP-P6AC70L ...
Error: unable to perform an operation on node 'rabbit@DESKTOP-P6AC70L'. Please see diagnostics information and suggestions below.

Most common reasons for this are:

 * Target node is unreachable (e.g. due to hostname resolution, TCP connection or firewall issues)
 * CLI tool fails to authenticate with the server (e.g. due to CLI tool's Erlang cookie not matching that of the server)
 * Target node is not running

In addition to the diagnostics info below:

 * See the CLI, clustering and networking guides on http://rabbitmq.com/documentation.html to learn more
 * Consult server logs on node rabbit@DESKTOP-P6AC70L

DIAGNOSTICS
===========

attempted to contact: ['rabbit@DESKTOP-P6AC70L']

rabbit@DESKTOP-P6AC70L:
  * connected to epmd (port 4369) on DESKTOP-P6AC70L
  * epmd reports node 'rabbit' uses port 25672 for inter-node and CLI tool traffic
  * TCP connection succeeded but Erlang distribution failed

  * Authentication failed (rejected by the remote node), please check the Erlang cookie


Current node details:
 * node name: 'rabbitmqcli60@DESKTOP-P6AC70L'
 * effective user's home directory: C:\Users\junwe
 * Erlang cookie hash: aXFZrVZ2A9gF0kkNeMhRXA==

from celery import Celery
import time

app = Celery('tasks', backend='amqp', broker='amqp://')

@app.task
def add(x, y):
  time.sleep(5)
  return x + y

  -------------- celery@iZev0nc46ircftZ v4.1.0 (latentcall)
  ---- **** -----
  --- * ***  * -- Windows-10-10.0.14393-SP0 2018-04-19 21:24:48
  -- * - **** ---
  - ** ---------- [config]
  - ** ---------- .> app:         tasks:0x213343e6630
  - ** ---------- .> transport:   amqp://guest:**@localhost:5672//
  - ** ---------- .> results:     disabled://
  - *** --- * --- .> concurrency: 2 (prefork)
  -- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
  --- ***** -----
   -------------- [queues]
                .> celery           exchange=celery(direct) key=celery
  
  
  [tasks]
    . tasks.add
  
  [2018-04-19 21:24:48,634: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10042] 在 getsockopt 或 setsockopt 调用中指定的一个未知的、无效的或不受支持的选项或层次。.
  Trying again in 2.00 seconds...
  
  [2018-04-19 21:24:49,322: INFO/SpawnPoolWorker-2] child process 2956 calling self.run()
  [2018-04-19 21:24:49,353: INFO/SpawnPoolWorker-1] child process 5768 calling self.run()
  [2018-04-19 21:24:50,697: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10042] 在 getsockopt 或 setsockopt 调用中指定的一个未知的、无效的或不受支持的选项或层次。.
  Trying again in 4.00 seconds...

>>> from tasks import add
>>> res = add.delay(4,4)
>>> res.ready()
False
>>> res.ready()
True
>>> res.result
8
>>>

    The AMQP result backend is scheduled for deprecation in     version 4.0 and removal in version v5.0.     Please use RPC backend or a persistent backend.

  alternative='Please use RPC backend or a persistent backend.')
[2018-04-20 16:27:26,581: INFO/SpawnPoolWorker-1] child process 4104 calling self.run()
[2018-04-20 16:27:26,596: WARNING/SpawnPoolWorker-1] c:\programdata\anaconda3\lib\site-packages\celery\backends\amqp.py:68: CPendingDeprecationWarning:
    The AMQP result backend is scheduled for deprecation in     version 4.0 and removal in version v5.0.     Please use RPC backend or a persistent backend.

  alternative='Please use RPC backend or a persistent backend.')
[2018-04-20 16:27:26,800: INFO/MainProcess] mingle: all alone
[2018-04-20 16:27:26,846: INFO/MainProcess] celery@iZ15r2bhksa4s0Z ready.
[2018-04-20 16:28:23,878: INFO/MainProcess] Received task: tasks.add[0a988088-95da-44a1-8c04-7c4581ad6f25]
[2018-04-20 16:28:23,956: ERROR/MainProcess] Task handler raised error: ValueError('not enough values to unpack (expected 3, got 0)',)
Traceback (most recent call last):
  File "c:\programdata\anaconda3\lib\site-packages\billiard\pool.py", line 358, in workloop
    result = (True, prepare_result(fun(*args, **kwargs)))
  File "c:\programdata\anaconda3\lib\site-packages\celery\app\trace.py", line 525, in _fast_trace_task
    tasks, accept, hostname = _loc
ValueError: not enough values to unpack (expected 3, got 0)

1. pip install eventlet
2. celery -A tasks worker --pool=eventlet