9

celery 文档告诉我，如果多个任务链接在一起，第一个任务的结果将是下一个任务的第一个参数。我的问题是，当我有一个返回多个结果的任务时，我无法让它工作。

例子：

@task()
def get_comments(url):
    #get the comments and the submission and return them as 2 objects
    return comments, submission

@task
def render_template(threadComments, submission):
    #render the objects into a html file
    #does not return anything

现在，如果我在 (get_comments(url) | render_template()).apply_asnc() 之类的链中调用它们，python 将抛出一个TypeError: render_template() takes exactly 2 arguments (0 given).

我可以看到结果没有展开并应用于参数。如果我只调用 get_comments，我可以这样做：

result = get_comments(url)
arg1, arg2 = result

并得到两个结果。

4

1 回答 1

26

这里有两个错误。

首先，您不必调用get_comments()and render_template()。相反，您应该使用.s()任务方法。像：

( get_comments.s(url) | render_template.s()).apply_async()

在您的情况下，您首先启动该函数，然后尝试将函数结果连接到一个链中。

其次，实际上，您不会从第一个任务中返回“两个结果”。相反，您返回一个包含两个结果的元组，并且该元组作为单个对象传递给第二个任务。

因此，您应该将第二个任务重写为

@task
def render_template(comments_and_submission):
   comments, submission = comments_and_submission

如果你修复了这些，它应该可以工作。

于 2013-01-21T15:29:06.990 回答