在我的配置文件中我有以下行:
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' },
}