如何在Django的CELERYBEAT_SCHEDULE中正确设置Celery Beat任务优先级？

你的配置写法本身没问题，但优先级不生效通常是因为消息代理未配置优先级支持或worker未正确处理优先级，以下是完整的解决步骤：

1. 修正Beat任务配置（二选一即可） #

方式一：直接在任务条目里添加priority字段 #

CELERYBEAT_SCHEDULE = {
    'some_task_name': {
        'task': 'app_name.tasks.some_task_name',
        'schedule': crontab(hour=18, minute=30),
        'priority': 6  # 直接设置优先级
    },
    'another_task': {
        'task': 'app_name.tasks.another_task',
        'schedule': crontab(hour=9, minute=0),
        'priority': 3  # 给其他任务设置不同优先级
    }
}

方式二：保留options字段（兼容部分Celery版本） #

CELERYBEAT_SCHEDULE = {
    'some_task_name': {
        'task': 'app_name.tasks.some_task_name',
        'schedule': crontab(hour=18, minute=30),
        'options': {'priority': 6}
    },
    'another_task': {
        'task': 'app_name.tasks.another_task',
        'schedule': crontab(hour=9, minute=0),
        'options': {'priority': 3}
    }
}

2. 配置消息代理支持优先级 #

根据你使用的消息代理做对应配置：

若使用RabbitMQ #

需要给队列设置最大优先级（比如设为10，覆盖你要用到的优先级范围）：

CELERY_QUEUES = {
    'default': {
        'exchange': 'default',
        'exchange_type': 'direct',
        'routing_key': 'default',
        'queue_arguments': {'x-max-priority': 10}  # 队列最大优先级
    }
}

若使用Redis #

Redis原生支持任务优先级，无需额外配置队列，直接使用即可。

3. 调整Worker启动参数 #

为了让worker优先处理高优先级任务，启动worker时添加--prefetch-multiplier=1参数，避免worker预取大量低优先级任务导致高优先级任务排队：

celery -A your_django_app worker -l info --prefetch-multiplier=1

完成以上配置后，Celery Beat调度的任务就会按照设置的优先级执行了。

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