Celery,有倒计时的通话延迟

问题描述 投票:6回答:2

我想了解芹菜的工作原理

在我的Django应用程序的tasks.py文件中,我创建了一个任务:

@celery.shared_task(default_retry_delay=2 * 60, max_retries=2)
def my_task(param1, param2):
    # There are some operations

我通过使用以下代码调用此任务:

my_task.delay(param1, param2)

在此my_task内部,有一种情况应再次启动此任务但经过一分钟的延迟

我发现任务有某种ETA and countdown,但它们的示例仅与apply_async有关>

是否可以对delay使用某种倒数计时?

我试图了解celery是如何工作的,在我的Django应用程序task.py文件中,我创建了一个任务:@ celery.shared_task(default_retry_delay = 2 * 60,max_retries = 2)def my_task(param1,param2)。 。

python django celery django-celery
2个回答

0
投票

只需添加到iklinac的答案中即可。这就是您使用apply_async()

© www.soinside.com 2019 - 2024. All rights reserved.