Django Celery定时任务无返回值问题求最简示例与解决提示

先给你两个最简洁的定时任务实现示例，再帮你排查当前遇到的无返回值问题。

一、最简定时任务示例 #

1. 每5分钟执行一次的任务 #

用你当前使用的periodic_task装饰器写法，只需要调整crontab参数即可：

from celery.task.schedules import crontab
from celery.decorators import periodic_task

@periodic_task(
    run_every=crontab(minute='*/5'),  # 通配符表示每5分钟触发一次
    name="run_every_5_minutes",
    ignore_result=False  # 想要看到返回值，这个参数必须设为False
)
def return_five():
    result = 5
    print(f"定时任务执行完成，返回值：{result}")  # 打印到终端方便调试
    return result

2. 指定每天12:00执行的任务 #

精准设置小时、分钟和秒，实现固定时间触发：

@periodic_task(
    run_every=crontab(hour=12, minute=0, second=0),  # 每天中午12点整执行
    name="run_at_12_noon",
    ignore_result=False
)
def run_at_noon():
    result = "中午12点的定时任务已执行"
    print(result)
    return result

更推荐的Celery 4.0+写法（集中管理任务） #

如果你的Celery版本是4.0及以上，更建议在配置文件里统一定义定时任务，后续维护更方便：

在config/celery.py中添加beat调度配置：

from celery.task.schedules import crontab

# 保留你原来的Celery初始化代码...

app.conf.beat_schedule = {
    # 每5分钟执行的任务
    'run-every-5-minutes': {
        'task': 'myapp.tasks.return_five',  # 任务的完整路径
        'schedule': crontab(minute='*/5'),
    },
    # 每天12点执行的任务
    'run-at-12-noon': {
        'task': 'myapp.tasks.run_at_noon',
        'schedule': crontab(hour=12, minute=0, second=0),
    },
}

然后在myapp/tasks.py里写普通任务即可，无需再用periodic_task装饰器：

from celery import task

@task(ignore_result=False)
def return_five():
    return 5

@task(ignore_result=False)
def run_at_noon():
    return "中午12点的定时任务已执行"

二、解决你的定时任务无返回值问题 #

你现在能在任务列表看到定时任务，但看不到返回值，大概率是两个原因：

1. 没启动Celery Beat服务
   定时任务的触发需要Beat作为调度器，只启动Worker是不会触发定时任务的。你需要同时启动Worker和Beat：

# 第一个终端启动Worker
celery -A config worker -l info
# 第二个终端启动Beat
celery -A config beat -l info

开发环境下也可以合并启动（不建议生产环境这么做）：

celery -A config worker -B -l info

2. 设置了ignore_result=True
   你的原代码里定时任务加了ignore_result=True，这会让Celery不存储任务结果，自然在Flower和终端都看不到返回值。把这个参数改成ignore_result=False（或者直接删掉，默认就是False），然后重启Worker和Beat，就能看到结果了。

另外，建议在定时任务里加上print语句，这样可以直接在Worker的终端日志里看到任务执行情况，调试起来更方便。

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