我正在使用git repo的最新主分支https://github.com/celery/librabbitmq并librabbitmq==2.0.0按照自述文件中的说明安装Python 3.6
您可以通过执行以下操作来克隆存储库:
$ git clone git://github.com/celery/librabbitmq.git
Run Code Online (Sandbox Code Playgroud)
然后通过执行以下操作安装它:
$ cd librabbitmq
$ make install # or make develop
Run Code Online (Sandbox Code Playgroud)
正常运行(在操作系统中安装了某些二进制文件进行c编译之后),但是当我随后执行一个小的a+b添加任务并对其进行调用时,add.delay(2,2)失败并出现以下错误。我抬头看,发现Celery 4使用json作为序列化器,所以很明显这不是因为pickle序列化
[2018-04-30 23:40:02,956:CRITICAL / MainProcess]不可恢复的错误:SystemError('返回了带有错误集的结果',)追溯(最近一次调用为最后):文件“ /Users/somghosh/.virtualenvs/ ctdb / lib / python3.6 / site-packages / kombu / messaging.py”第624行,在_receive_callback中,如果on_m则返回on_m(message),否则self.receive(已解码,消息)文件“ /Users/somghosh/.virtualenvs/ ctdb / lib / python3.6 / site-packages / celery / worker / consumer / consumer.py”,行570,在on_task_received回调中,文件“ /Users/somghosh/.virtualenvs/ctdb/lib/python3.6/site- package / celery / worker / strategy.py”,第145行,位于task_message_handler句柄(要求)文件“ /Users/somghosh/.virtualenvs/ctdb/lib/python3.6/site-packages/celery/worker/worker.py”中,第221行,在_process_task_sem中返回self._quick_acquire(self._process_task,req)在获取回调中的文件“ /Users/somghosh/.virtualenvs/ctdb/lib/python3.6/site-packages/kombu/async/semaphore.py”,第62行(* partial_args,** partial_kwargs)文件“ /Users/somghosh/.virtualenvs/ctdb/lib/python3.6/site-packages/celery/worker/worker.py”,第226行,位于_process_task req.execute_using_pool(自身。池)文件“ /Users/somghosh/.virtualenvs/ctdb/lib/python3.6/site-packages/celery/worker/request.py”,行531,在execute_using_poolcorrelation_id …