芹菜应该如何从数据库中挑选任务



I have python django web application.当用户提交请求时,我必须在数据库中插入 10 行,基本上是必须完成的任务。

我可以有函数来获取这些任务,然后芹菜可以运行这些功能。

@shared_task
def provision(tasks):
    for tasks in tasks:
       pass

我的问题是

  1. 我想要的一些任务接二连三地发生
  2. 我想并行执行的一些任务
  3. 如果某些任务失败,那么我应该能够重新启动它们

我不确定芹菜将如何帮助我

Celery 框架提供了一些工作流原语,允许您按顺序(链)或并行(组)运行任务。

芹菜还带有内置的重试机制。

相关内容

  • 没有找到相关文章

最新更新