当前位置：文江博客话题详情

Python+Celery：忽略每次调用的任务结果？

发布于 2024-09-27 20:39:56 字数 199 浏览 2 评论 0原文

是否可以在每次调用的基础上忽略任务结果？

例如，这样我可以在 Web 请求期间运行任务时忽略任务的结果，但在交互运行任务时等待结果（可能有调试信息）？

我知道任务具有 ignore_result 标志，但我特别想知道是否可以在每次调用的基础上（而不是“全局”基础）设置 ignore_result 。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

长发绾君心 2024-10-04 20:39:56

通常不会，因为ignore_result是只有工作人员使用的任务的属性（以决定是否发回结果）。

但是，如果您使用自己的任务参数（避免将其称为ignore_result），并让任务根据该参数设置其ignore_result，则可以做到这一点：

task mytask(please_ignore_result):
    mytask.ignore_result = please_ignore_result

Not normally, because ignore_result is a property of a Task that only the workers use (to decide whether to send a result back).

But you could do it if you used your own task parameter (avoid calling it ignore_result), and have the task set its ignore_result based on that:

task mytask(please_ignore_result):
    mytask.ignore_result = please_ignore_result

回复收藏 0 原文

绅刃 2024-10-04 20:39:56

您可以在调用 apply_async 或 delay 时使用 ignore_result=True/False

@app.task 
def hello():
    print('hello world')

# storing/rejecting results per invocation basis    
res = hello.apply_async(ignore_result=True)
res1 = hello.apply_async(ignore_result=False)

您可能会遇到如果您运行的是旧版本的 celery，则会出现此错误。您可以阅读有关如何更详细地使用 ignore_result 的文档此处

You can use ignore_result=True/False while calling apply_async or delay

@app.task 
def hello():
    print('hello world')

# storing/rejecting results per invocation basis    
res = hello.apply_async(ignore_result=True)
res1 = hello.apply_async(ignore_result=False)

You might run into this error if you are running an older version of celery. You can read the docs about how to use ignore_result in more detail here

回复收藏 0 原文

~没有更多了~