芹菜任务未执行 - 芹菜不工作的最简单示例
我在运行非常基本的、实际上是最简单的 celery 示例时遇到了麻烦。
你能指导我是否我在这里做错了什么?
工作部分:
from celery import Celery
celery = Celery('tasks', broker='redis://localhost:6379/0',backend='redis://localhost:6379/1')
@celery.task
def add(x, y):
return x + y
并运行它: celery -Atasksworker --loglevel=INFO
然后我打开新终端并输入:
>>> from tasks import add
>>> result = add.delay(1,1)
>>>
但 result.ready()
始终为 False
并在芹菜工人我看不到已完成的任务,仅收到并运行。
[2022-04-01 13:07:23,434: INFO/MainProcess] Task tasks.add[b0b98051-53b3-4fec-8f83-b1f74be27cfa] received
[2022-04-01 13:07:24,304: INFO/SpawnPoolWorker-19] child process 31632 calling self.run()
[2022-04-01 13:07:24,318: INFO/SpawnPoolWorker-20] child process 4648 calling self.run()
[2022-04-01 13:07:24,322: INFO/SpawnPoolWorker-21] child process 3984 calling self.run()
我做错了什么? 谢谢!
I have troubles running very basic, actually the simplest celery example.
Can You guide me whether I'm doing something wrong here?
worker part:
from celery import Celery
celery = Celery('tasks', broker='redis://localhost:6379/0',backend='redis://localhost:6379/1')
@celery.task
def add(x, y):
return x + y
and run it with:celery -A tasks worker --loglevel=INFO
then I open new terminal and type:
>>> from tasks import add
>>> result = add.delay(1,1)
>>>
but result.ready()
is always False
and in the celery worker I cannot see task that is finished only received and run.
[2022-04-01 13:07:23,434: INFO/MainProcess] Task tasks.add[b0b98051-53b3-4fec-8f83-b1f74be27cfa] received
[2022-04-01 13:07:24,304: INFO/SpawnPoolWorker-19] child process 31632 calling self.run()
[2022-04-01 13:07:24,318: INFO/SpawnPoolWorker-20] child process 4648 calling self.run()
[2022-04-01 13:07:24,322: INFO/SpawnPoolWorker-21] child process 3984 calling self.run()
What am I doing wrong?
Thanks!
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
您正在尝试在不支持的窗口上运行芹菜。 https:///docseceleryq.dev/en/en/最新/faq.html#do-celery-support-windows
You are attempting to run Celery on Windows which is unsupported. https://docs.celeryq.dev/en/latest/faq.html#does-celery-support-windows