无法启动 Celery Worker (Kombu.asynchronous.timer)

Question

我遵循 Celery (Django) 的第一步，并尝试在后台运行繁重的进程。我安装了 RabbitMQ 服务器。但是，当我尝试 celery -A my_app worker -l info 它会抛出以下错误

File "<frozen importlib._bootstrap>", line 994, in _gcd_import
File "<frozen importlib._bootstrap>", line 971, in _find_and_load
File "<frozen importlib._bootstrap>", line 955, in _find_and_load_unlocked
File "<frozen importlib._bootstrap>", line 665, in _load_unlocked
File "<frozen importlib._bootstrap_external>", line 678, in exec_module
File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
File "c:\anaconda3\lib\site-packages\celery\concurrency\prefork.py", line
18, in <module>
from celery.concurrency.base import BasePool
File "c:\anaconda3\lib\site-packages\celery\concurrency\base.py", line 15,
in <module>
from celery.utils import timer2
File "c:\anaconda3\lib\site-packages\celery\utils\timer2.py", line 16, in
<module>
from kombu.asynchronous.timer import Entry
ModuleNotFoundError: No module named 'kombu.asynchronous.timer'

我搜索了很多，但似乎无法正常工作。任何帮助将不胜感激。谢谢！

原文由 CodeSsscala 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

我有同样的问题，但是在使用 3.1.25 版本重新安装 celery 时解决了

pip uninstall celery && pip install celery==3.1.25

可能是因为windows官方不支持celery 4， https://github.com/celery/celery/issues/3551

原文由 chuhy 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 2

我在 pip (3.1.26Post2) 的默认 Celery 安装中遇到了这个问题。如上所述，我安装了 3.1.25 版，但 Celery 仍然无法正常工作。因此我明确安装了最新版本：

pip 安装 Celery==4.3

现在一切正常！

原文由 Corri 发布，翻译遵循 CC BY-SA 4.0 许可协议