Python中Celery任务出现[Soft time limit exceeded]错误，如何强制结束任务？

遇到Celery的SoftTimeLimitExceeded错误，说明任务执行时间超过了软时间限制但还没到硬限制。这时候任务还在跑，但已经抛异常了。如果你想在超时后立刻终止任务，得用硬时间限制或者手动杀进程。

最直接的办法是在任务装饰器里同时设置soft_time_limit和time_limit。当超过time_limit（硬限制），Celery会直接终止任务进程。下面是个例子：

from celery import Celery
from celery.exceptions import TimeLimitExceeded

app = Celery('tasks')

@app.task(soft_time_limit=5, time_limit=10)
def my_task():
    try:
        # 你的长时间运行逻辑
        import time
        time.sleep(20)  # 这会触发超时
    except TimeLimitExceeded:
        # 硬限制超时后，任务进程会被终止，这里的代码可能执行不到
        print("Hard time limit exceeded, task killed")
        raise

如果任务卡死了连硬限制都等不了，你可以在代码里自己检查并退出。比如在循环里判断已执行时间：

import time
from celery import current_task

@app.task
def stubborn_task():
    start_time = time.time()
    max_time = 5  # 最大允许5秒
    
    while True:
        if time.time() - start_time > max_time:
            # 主动退出
            return "Task terminated manually"
        # ... 任务逻辑

还有个狠招是用signal模块在软超时时直接终止进程，不过得小心资源清理问题：

import signal
from celery.exceptions import SoftTimeLimitExceeded

@app.task(soft_time_limit=5)
def task_with_signal():
    def handler(signum, frame):
        raise SystemExit("Terminated by soft time limit")
    
    signal.signal(signal.SIGALRM, handler)
    signal.alarm(5)  # 5秒后发信号
    
    try:
        # 你的代码
        time.sleep(10)
    except SystemExit:
        raise SoftTimeLimitExceeded()
    finally:
        signal.alarm(0)  # 取消警报

简单说，设硬限制最省事。