windows Celery任务始终待定

z9zf31ra 于 2023-03-19 发布在 Windows

关注(0)|答案(6)|浏览(198)

我试着在Windows上运行Celery示例，代码如下所示：

from celery import Celery

app = Celery('risktools.distributed.celery_tasks',
             backend='redis://localhost',
             broker='redis://localhost')

@app.task(ignore_result=False)
def add(x, y):
    return x + y

@app.task(ignore_result=False)
def add_2(x, y):
    return x + y

我使用iPython控制台启动任务：

>>> result_1 = add.delay(1, 2)    
>>> result_1.state
'PENDING'
>>> result_2 = add_2.delay(2, 3)    
>>> result_2.state
'PENDING'

看起来这两个任务都没有执行，但是Celery worker输出显示它们成功了：

[2014-12-08 15:00:09,262: INFO/MainProcess] Received task: risktools.distributed.celery_tasks.add[01dedca1-2db2-48df-a4d6-2f06fe285e45]
[2014-12-08 15:00:09,267: INFO/MainProcess] Task celery_tasks.add[01dedca1-2db2-48df-a4d6-2f06fe28
5e45] succeeded in 0.0019998550415s: 3
[2014-12-08 15:00:24,219: INFO/MainProcess] Received task: risktools.distributed.celery_tasks.add[cb5505ce-cf93-4f5e-aebb-9b2d98a11320]
[2014-12-08 15:00:24,230: INFO/MainProcess] Task celery_tasks.add[cb5505ce-cf93-4f5e-aebb-9b2d98a1
1320] succeeded in 0.010999917984s: 5

我已经尝试根据Celery文档解决这个问题，但是没有一个建议是有用的。我做错了什么，我如何从Celery任务接收结果？

**UPD：**我添加了一个没有ignore_result参数的任务，但没有任何变化

@app.task
def add_3(x, y):
    return x + y

>>>r = add_3.delay(2, 2)
>>>r.state
'PENDING'

windows

来源：https://stackoverflow.com/questions/27357732/celery-task-always-pending

6条答案

按热度按时间

gz5pxeao1#

根据Celery 'Getting Started' not able to retrieve results; always pending和https://github.com/celery/celery/issues/2146，这是一个Windows问题。Celery --pool=solo选项解决了这个问题。

赞(0）回复(0）举报 2023-03-19

e0uiprwp2#

在Windows上尝试-P threads，而不是Celery --pool=solo选项。

赞(0）回复(0）举报 2023-03-19

xtfmy6hx3#

设置CELERY_TASK_TRACK_STARTED = True（或在单个任务上设置track_started=True）也会有所帮助-这将启用STARTED状态。

赞(0）回复(0）举报 2023-03-19

laximzn54#

从celery 文档中删除ignore_result=False

Task.ignore_result

Don’t store task state. Note that this means you can’t 
use AsyncResult to check if the task is ready, or get its return value.

赞(0）回复(0）举报 2023-03-19

bvjxkvbb5#

谢谢大家。
我的celery 配置：

-------------- celery@DESKTOP-FD38GOO v4.4.2 (cliffs)
--- ***** -----
-- ******* ---- Windows-10-10.0.18362-SP0 2020-04-17 06:58:18
- *** --- * ---
- ** ---------- [config]
- ** ---------- .> app:         mysite:0x25cfd40d208
- ** ---------- .> transport:   redis://localhost:6379//
- ** ---------- .> results:     redis://localhost:6379/1
- *** --- * --- .> concurrency: 8 (thread)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** -----
 -------------- [queues]
                .> celery           exchange=celery(direct) key=celery

[tasks]
  . mysite.celery.debug_task
  . supplier.tasks.add
  . supplier.tasks.count_widgets
  . supplier.tasks.count_widgets2
  . supplier.tasks.mul
  . supplier.tasks.xsum

我已经修正了这样的问题：
我等待这样的问题约1天，并尝试卸载redis和安装redis上的windows 10一些时候。
最后我发现没有并发配置。
第一溶液：
celery -一个mysite工人-l信息-P线程
第二种解决方案：
celery -一个mysite工人-l信息--池=独奏
我的celery 配置：

CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/1'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
CELERY_IGNORE_RESULT = False
CELERY_TIMEZONE = TIME_ZONE
CELERY_TRACK_STARTED = True
CELERYD_LOG_FILE = os.path.join(
    BASE_DIR, 'celery', 'logs')   
CELERYD_LOG_LEVEL = "INFO"

赞(0）回复(0）举报 2023-03-19

mbyulnm06#

如果您正在从Celery对象设置配置，则可以使用其他方法-

app = Celery("MyTasks")
app.conf.task_track_started = True
app.conf.task_ignore_result = False
..
..

赞(0）回复(0）举报 2023-03-19

我来回答

windows Celery任务始终待定

6条答案

相关问题

热门标签

最新问答