redis 如何在CELERYBEAT_SCHEDULE配置中设置优先级？

polkgigr 于 2023-10-15 发布在 Redis

关注(0)|答案(1)|浏览(138)

在我的Django应用程序中，我试图将Celery beat任务的优先级值设置为6，但下面的方法不起作用。设置此值的正确方法是什么？我在此配置中有其他任务，并希望设置不同的优先级值。

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

redis

来源：https://stackoverflow.com/questions/73855879/how-to-set-priority-in-celerybeat-schedule-config

1条答案

按热度按时间

gzszwxb41#

您的节拍时间表配置看起来是正确的，您需要确保在应用程序配置中也设置了queue_order_strategy。

app = Celery(
    'tasks',
    broker=f'redis://...',
)

app.conf.broker_transport_options = {'queue_order_strategy': 'priority'}
app.conf.task_default_priority = 1

app.conf.beat_schedule = CELERYBEAT_SCHEDULE

赞(0）回复(0）举报 2023-10-15

我来回答

redis 如何在CELERYBEAT_SCHEDULE配置中设置优先级？

1条答案

相关问题

热门标签

最新问答