logo标签列表

Celery无法运行chord回调

pythonubuntucelery
5

在查看了很多关于弦回调未执行并尝试它们的解决方案后，我仍然无法使其工作。实际上，由于某种原因，chord_unlock方法也未能执行。

celery.py

from __future__ import absolute_import
from celery import Celery

app = Celery('sophie',
             broker='redis://localhost:6379/2',
             backend='redis://localhost:6379/2',
             include=['sophie.lib.chord_test'])

app.conf.update(
    CELERY_ACCEPT_CONTENT=["json"],
    CELERY_TASK_SERIALIZER="json",
    CELERY_TRACK_STARTED=True,
    CELERYD_PREFETCH_MULTIPLIER=1,   # NO PREFETCHING OF TASKS
    BROKER_TRANSPORT_OPTIONS = {
        'priority_steps': [0, 1]     # ALLOW ONLY 2 TASK PRIORITIES
    }
)

if __name__ == '__main__':
    app.start()

chord_test.py

from __future__ import absolute_import
from sophie.celery import app
from celery import chord

@app.task(name='sophie.lib.add')
def add(x, y):
    return x + y

@app.task(name='sophie.lib.tsum')
def tsum(numbers):
    return sum(numbers)

if __name__ == '__main__':
    tasks = [add.s(100, 100), add.s(200, 200)]
    chord(tasks, tsum.s()).apply_async()

我的工作日志文件输出如下：
$ celery worker -l info --app=sophie.celery -n worker1.%h

 -------------- celery@worker1.vagrant-ubuntu-11 v3.1.6 (Cipater)
---- **** ----- 
--- * ***  * -- Linux-3.0.0-12-server-x86_64-with-Ubuntu-11.10-oneiric
-- * - **** --- 
- ** ---------- [config]
- ** ---------- .> broker:      redis://localhost:6379/2
- ** ---------- .> app:         sophie:0x3554250
- ** ---------- .> concurrency: 1 (prefork)
- *** --- * --- .> events:      OFF (enable -E to monitor this worker)
-- ******* ---- 
--- ***** ----- [queues]
 -------------- .> celery           exchange=celery(direct) key=celery


[tasks]
  . sophie.lib.add
  . sophie.lib.tsum

[2013-12-12 19:37:26,499: INFO/MainProcess] Connected to redis://localhost:6379/2
[2013-12-12 19:37:26,506: INFO/MainProcess] mingle: searching for neighbors
[2013-12-12 19:37:27,512: INFO/MainProcess] mingle: all alone
[2013-12-12 19:37:27,527: WARNING/MainProcess] celery@worker1.vagrant-ubuntu-11 ready.
[2013-12-12 19:37:29,723: INFO/MainProcess] Received task: sophie.lib.add[b7d504c1-217f-43a9-b57e-86f0fcbdbe22]
[2013-12-12 19:37:29,734: INFO/MainProcess] Task sophie.lib.add[b7d504c1-217f-43a9-b57e-86f0fcbdbe22] succeeded in 0.009769904
00522s: 200
[2013-12-12 19:37:29,735: INFO/MainProcess] Received task: sophie.lib.add[eb01a73e-f6c8-401d-8049-6cdbc5f0bd90]
[2013-12-12 19:37:29,737: INFO/MainProcess] Task sophie.lib.add[eb01a73e-f6c8-401d-8049-6cdbc5f0bd90] succeeded in 0.001446505
00442s: 400

完全没有调用chord_unlock。以下是更多输出，以提供进一步上下文:

$ sudo pip freeze | egrep 'celery|kombu|billiard'
billiard==3.3.0.12
celery==3.1.6
kombu==3.0.7

$ uname -a
Linux vagrant-ubuntu-11 3.0.0-12-server #20-Ubuntu SMP Fri Oct 7 16:36:30 UTC 2011 x86_64 x86_64 x86_64 GNU/Linux

$ redis-server --version
Redis server version 2.2.11 (00000000:0)
你最终解决了这个问题吗？我现在也遇到了类似的问题。 - devrelm
4个回答
4

Chords文档使用以下语法来表示chord：

 result = chord(header)(callback)

那么你可以这样做：

 chord(tasks)(tsum.s())
1
在和弦文档下有一个Important Notes部分，其中写道：

和弦内使用的任务必须不忽略它们的结果。实际上，这意味着您必须启用CELERY_RESULT_BACKEND才能使用和弦。此外，如果在配置中将CELERY_IGNORE_RESULT设置为True，请确保要在和弦内使用的各个任务都定义了ignore_result=False。这适用于Task子类和装饰任务。

即使我遵循了建议，和弦回调也没有被执行，但可能会帮助其他人。 编辑：

在我的情况下找到了原因！和弦不完全支持在所有情况下指定队列名称： https://github.com/celery/celery/issues/2085

1
当我的任务签名与流程提供的参数不匹配时，会发生这种情况，接受一个*args可能有助于调试此类问题。
0
网页内容由stack overflow 提供, 点击上面的
可以查看英文原文，
原文链接