连接到默认的RabbitMQ我试图设置Amazon SQS作为Django应用程序中Celery的默认消息代理。芹菜工人正在启动,但经纪人被设置为默认RabbitMQ。下面你可以找到我的工作人员的输出。Django +芹菜+ SQS设置。 Celery通过ampq
下面是我在项目中的一些配置。我celery.py样子:
from __future__ import absolute_import
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'dance.settings')
app = Celery('dance')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
@app.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))
的负责经纪人的URL设置Django的芹菜设置的重要组成部分是:
BROKER_URL = 'sqs://{}:{}@'.format(AWS_ACCESS_KEY_ID, quote(AWS_SECRET_ACCESS_KEY, safe=''))
BROKER_TRANSPORT_OPTIONS = {
'region': 'eu-west-1',
'polling_interval': 3,
'visibility_timeout': 300,
'queue_name_prefix':'dev-celery-',
}
当我试图与虚拟环境中启动工人:
celery -A dance worker -l info
我收到下面的输出:
-------------- [email protected] v4.0.0 (latentcall)
---- **** -----
--- * *** * -- Linux-4.8.0-28-generic-x86_64-with-debian-stretch-sid 2016-12-02 14:20:40
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app: dance:0x7fdc592ca9e8
- ** ---------- .> transport: amqp://guest:**@localhost:5672//
- ** ---------- .> results:
- *** --- * --- .> concurrency: 8 (prefork)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** -----
-------------- [queues]
.> celery exchange=celery(direct) key=celery
[tasks]
...
task1
task2
...
任务已列出,所以我猜Celery会获取并处理相关的Django设置。如果要将设置从SQS切换到Redis,我会遇到同样的问题。
据我所知,阅读教程工人的输出应该看起来类似于。
- ** ---------- .> transport: sqs://*redacted*:**@localhost//
- ** ---------- .> results: djcelery.backends.database:DatabaseBackend
此外,我不使用djcelery
尽可能过时。相反,我正在使用django_celery_results
,因为它在Celery设置页面上推荐使用。最后的输出只是侧面项目的猜测。