如何在Django中指定时间运行函数？Celery定时任务异常如何解决？

问题2：参数数量不匹配报错修复 #

你使用@shared_task(bind=True)装饰器时，bind=True参数会将当前任务实例作为第一个入参自动注入到任务函数中，你的原函数没有预留对应参数，因此传入args=[id]时会触发「传入2个参数但仅定义1个入参」的报错。
两种修复方案二选一：

1. 保留bind=True，为函数增加第一个self参数：

# tasks.py 修正后
from celery import shared_task
from .models import Product

@shared_task(bind=True)
def set_firsat_urunu(self, id=1):
    p = Product.objects.get(id=id)
    if p.firsat_urunu == True:
        p.firsat_urunu = False
        p.save() # 新增：修改模型后必须调用save()才能写入数据库
    return 'done'

2. 不需要用到任务实例时，直接删除bind=True参数即可：

@shared_task
def set_firsat_urunu(id=1):
    p = Product.objects.get(id=id)
    if p.firsat_urunu == True:
        p.firsat_urunu = False
        p.save()
    return 'done'

问题1：任务接收后不执行、无结果记录修复 #

按以下顺序排查修复：

• 优先完成上述参数错误的修复，参数异常会直接导致任务执行失败，不会生成有效结果记录
• 检查结果后端配置：要在Django管理后台看到Celery执行结果，需要安装django-celery-results依赖，同时在settings.py中配置：

INSTALLED_APPS = [
    ...
    'django_celery_results',
]
CELERY_RESULT_BACKEND = 'django-db'
# 配置完成后执行python manage.py migrate创建结果存储表

• 修复时区配置问题：你当前构造的eta参数是无时区信息的 naive datetime，会和Celery默认的UTC时区产生时差，导致任务触发时间不符合预期。在settings.py中补充以下配置，保持Django和Celery时区一致：

CELERY_TIMEZONE = TIME_ZONE # 与Django的TIME_ZONE配置保持一致，比如"Asia/Shanghai"
CELERY_ENABLE_UTC = False

同时构造eta时使用带时区的时间，避免时差问题：

# views.py 中构造eta的逻辑修正
from django.utils import timezone

# 替换原来的eta=datetime(2021,8,17,0,10)
eta_time = timezone.make_aware(datetime(2021,8,17,0,10))
set_firsat_urunu.apply_async(args=[id], eta=eta_time)

• 检查任务逻辑遗漏：你原任务函数中修改p.firsat_urunu属性后，没有调用p.save()写入数据库，即使任务执行成功也不会修改数据库记录，看起来像任务没有生效，这个逻辑必须补充。
• 确认Celery Worker进程正常运行，查看Worker控制台的日志可以直接看到任务执行的报错信息，比如模型导入异常、数据库连接异常等问题都可以直接定位。
• 确认你设置的eta时间晚于任务发送的时间，如果eta时间早于当前时间，Celery会立即执行任务，你写死的2021年时间已过期，测试时需要替换为未来的时间。

内容的提问来源于stack exchange，提问作者Adil Haydar