这个问题我遇到过，核心原因是Celery的soft_time_limit依赖系统时钟，而分布式环境下各节点时间不同步会导致计时混乱。

解决方案：

1. 强制时间同步（最根本） 在所有Celery worker和broker节点配置NTP服务：

   # Ubuntu/Debian
   sudo apt install ntpdate
   sudo ntpdate pool.ntp.org
   
   # 或使用chrony（推荐）
   sudo apt install chrony
   sudo systemctl enable --now chronyd
   

2. 代码层面增加容错处理

   from celery.exceptions import SoftTimeLimitExceeded
   import time
   
   [@app](/user/app).task(soft_time_limit=30)
   def my_task():
       start_time = time.time()
       try:
           # 你的任务逻辑
           while time.time() - start_time < 25:  # 提前5秒自检
               # 处理逻辑
               time.sleep(1)
           # 如果接近超时，主动清理退出
           if time.time() - start_time > 28:
               cleanup_resources()
               return "timeout_handled"
       except SoftTimeLimitExceeded:
           cleanup_resources()
           return "soft_timeout"
   

3. 使用相对时间替代绝对时间

   [@app](/user/app).task(bind=True, soft_time_limit=30)
   def my_task(self):
       deadline = time.time() + 25  # 设置内部截止时间
       while time.time() < deadline:
           # 正常处理
           pass
       # 主动退出避免触发soft_time_limit
       return "completed_before_limit"
   

4. Docker环境特别处理 在Dockerfile中确保时区同步：

   RUN apt-get update && apt-get install -y tzdata
   ENV TZ=Asia/Shanghai
   RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime
   

总结：强制NTP同步是根本，代码中增加主动超时检查作为补充。