【发布时间】:2020-06-29 22:53:41
【问题描述】:
我在一个 Django 项目中工作,我正在尝试将 celery 集成到我的项目中,但我的应用似乎无法连接到我在本地运行的 redis 服务器。
这是我运行 celery -A project worker 时显示的内容。
---- **** -----
--- * *** * -- Linux-4.15.0-58-generic-x86_64-with-Ubuntu-18.04-bionic 2020-03-18 19:06:29
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app: proyecto_is2:0x7f7c98351518
- ** ---------- .> transport: redis://h:**@ec2-34-202-114-79.compute-1.amazonaws.com:17729//
- ** ---------- .> results: redis://127.0.0.1:6379/0
- *** --- * --- .> concurrency: 8 (prefork)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** -----
-------------- [queues]
.> celery exchange=celery(direct) key=celery
[2020-03-18 19:31:24,595: ERROR/MainProcess] consumer: Cannot connect to
redis://h:**@ec2-34-202-114-79.compute-1.amazonaws.com:17729//: Error 110 connecting to
ec2-34-202-114-79.compute-1.amazonaws.com:17729. Connection timed out..
我注意到传输中的 url 不是我的本地主机,我不知道它是在哪里设置的。 我使用的是 celery 4.3.0,redis 3.2.1。
在我的 celery.py 中有
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'proyecto_is2.settings.dev_settings')
app = Celery('proyecto_is2')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
在我的设置中
... other configs
CELERY_BROKER_URL = 'redis://127.0.0.1:6379'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
【问题讨论】:
标签: python django redis celery