基于“Avoid launching synchronous subtasks”部分中的“最佳实践”,我想在后台执行链,而不是等待作业的链结果。如何实现这一目标?
就那么简单吗(基于我提供的链接中的示例)?:
def update_page_info(url):
# fetch_page -> parse_page -> store_page
chain = fetch_page.s() | parse_page.s() | store_page_info.s(url)
chain.delay()
最佳答案
而不是
chain.delay()
应该有
chain.apply_async()
其余部分看起来不错。
关于python - Celery 3.1 - 异步执行任务链,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24122624/