zoukankan      html  css  js  c++  java
  • Task handler raised error: ValueError('not enough values to unpack (expected 3, got 0)')

    原文出处:

    Celery ValueError: not enough values to unpack (expected 3, got 0)的解决方案

    背景

    最近因项目需要,学习任务队列Celery的用法,跟着官网写Demo,出现如题错误,最终在github的Issues里找到解决办法,记录如下。

    场景还原

    本地环境如下:

    • Windows 10
    • Python 3.5.2
    • Celery 4.1.0

    我是跟着这个前人翻译的中文文档敲的Demo。

    代码tasks.py

    from celery import Celery
    
    app = Celery('tasks', broker='redis://:xxxx@xxx.xxx.xxx.xx:6379/0')
    
    @app.task
    def add(x, y):
        return x + y

    执行worker

    celery -A tasks worker --loglevel=info
     

    输出:

     -------------- celery@kong9wei11 v4.1.0 (latentcall)
    ---- **** -----
    --- * ***  * -- Windows-10-10.0.14393-SP0 2018-01-12 19:01:39
    -- * - **** ---
    - ** ---------- [config]
    - ** ---------- .> app:         tasks:0x157fd248550
    - ** ---------- .> transport:   redis://:**@114.67.225.0:6379/0
    - ** ---------- .> results:     disabled://
    - *** --- * --- .> concurrency: 4 (prefork)
    -- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
    --- ***** -----
     -------------- [queues]
                    .> celery           exchange=celery(direct) key=celery
    
    
    [tasks]
      . tasks.add
    
    [2018-01-12 19:01:40,029: INFO/MainProcess] Connected to redis://:**@114.67.225.0:6379/0
    [2018-01-12 19:01:40,130: INFO/MainProcess] mingle: searching for neighbors
    [2018-01-12 19:01:40,550: INFO/SpawnPoolWorker-1] child process 9048 calling self.run()
    [2018-01-12 19:01:40,557: INFO/SpawnPoolWorker-2] child process 9028 calling self.run()
    [2018-01-12 19:01:40,578: INFO/SpawnPoolWorker-3] child process 13064 calling self.run()
    [2018-01-12 19:01:40,611: INFO/SpawnPoolWorker-4] child process 9856 calling self.run()
    [2018-01-12 19:01:41,693: INFO/MainProcess] mingle: all alone
    [2018-01-12 19:01:42,212: INFO/MainProcess] celery@xx ready.
     

    调用任务代码manager.py

    from tasks import add
    
    add.delay(4, 4)
    执行
    python manager.py
     

    然后worker里报错:

    [2018-01-12 19:08:15,545: INFO/MainProcess] Received task: tasks.add[5d387722-5389-441b-9b01-a619b93b4702]
    [2018-01-12 19:08:15,550: ERROR/MainProcess] Task handler raised error: ValueError('not enough values to unpack (expected 3, got 0)',)
    Traceback (most recent call last):
      File "d:programmingsoftwarepython35libsite-packagesilliardpool.py", line 358, in workloop
        result = (True, prepare_result(fun(*args, **kwargs)))
      File "d:programmingsoftwarepython35libsite-packagesceleryapp	race.py", line 525, in _fast_trace_task
        tasks, accept, hostname = _loc
    ValueError: not enough values to unpack (expected 3, got 0)

    解决:

    原网页:Unable to run tasks under Windows

    看别人描述大概就是说win10上运行celery4.x就会出现这个问题,解决办法如下,原理未知:

    先安装一个`eventlet

    pip install eventlet
    然后启动worker的时候加一个参数,如下:
    celery -A <mymodule> worker -l info -P eventlet
    然后就可以正常的调用了。

    运行

    python manage.py

    worker里输出:

    [2018-01-12 19:35:33,640: INFO/MainProcess] Received task: tasks.add[3f9b5255-60a2-4a08-96b6-38f5fbc31543]
    [2018-01-12 19:35:33,640: INFO/MainProcess] Task tasks.add[3f9b5255-60a2-4a08-96b6-38f5fbc31543] succeeded in 0.0s: 8
  • 相关阅读:
    C# 使用SqlBulkCopy类批量复制大数据 快速导入Excel大量数据
    Git的安装与使用
    未能加载文件或程序集“Microsoft.VisualStudio.Web.PageInspector.Loader, Version=1.0.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a”或它的某一个依赖项。
    Android SDK Manager不能显示所有包的解决办法
    editor多功能文本框在有些计算机上不能正常加载,解决方法,本人用的是把js调用方法放到<body></body>后面)
    MVC URL参数传递+变为空格解决方法
    SQL 查询不重复数据
    Java基本数据类型取值范围
    统计数组中的逆数对个数
    Docker 安装 ElasticSearch
  • 原文地址:https://www.cnblogs.com/kaerxifa/p/13560581.html
Copyright © 2011-2022 走看看