Django芹菜如何配置队列并在Rabbitmq Admin仪表板中查看它们



在我的配置文件中我有以下行:

CELERY_QUEUES = (
    Queue('fetch_tweets_requests'),
)
CELERY_ROUTES = {
    'applications.twitter.tasks.fetch_tweets': {'queue': 
    'fetch_tweets_requests' },
}

射击时的任务按预期运行,但是当我去RabbitMQ Admin仪表板时,我看不到任何名为fetch_tweets_requests的队列如何配置Django,以便我可以看到已设置的队列?

我弄清楚了。这是因为在芹菜应用中,我也将其配置为命名空间芹菜配置,即

app.config_from_object('django.conf:settings', namespace='CELERY')

因此,我需要做的就是确保设置被命名空间遵守。即

CELERY_CELERY_QUEUES = (
    Queue('fetch_tweets_requests'),
)
CELERY_CELERY_ROUTES = {
    'applications.twitter.tasks.fetch_tweets': {'queue': 
    'fetch_tweets_requests' },
}

相关内容

  • 没有找到相关文章