使用芹菜在特定任務上設置時間限制

Question

在Celery中有一項任務可以在正常運行時運行10,000秒。然而，我的其餘任務應該在不到一秒的時間內完成。如何在不更改短時間運行任務的時間限制的情況下爲特意長時間運行的任務設置時間限制？

Answer 1

您可以在定義任務時或調用時設置任務時間限制（hard和/或soft）。

from celery.exceptions import SoftTimeLimitExceeded 

@celery.task(time_limit=20) 
def mytask(): 
    try: 
     return do_work() 
    except SoftTimeLimitExceeded: 
     cleanup_in_a_hurry() 

或

mytask.apply_async(args=[], kwargs={}, time_limit=30, soft_time_limit=10) 

Answer 2

這是使用soft_time_limit與裝飾爲一個特定的任務和芹菜3.1.23示例 = 10000

@task(bind=True, default_retry_delay=30, max_retries=3, soft_time_limit=10000) 
def process_task(self, task_instance): 
    """Task processing.""" 
     pass