我已经为生产部署了一个芹菜应用程序,但它在 5 到 10 分钟后与 rabbitmq 断开连接,服务器没有给出任何响应 错误代码为:
[错误 104] 对等方重置连接
这是我 celery.py 文件Django项目:
import os
from celery import Celery
from parrot_server import settings
BROKER_URL = 'amqp://parrot_user:Alireza@1234@localhost:5672/parrot'
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'parrot_server.settings')
app = Celery('parrot_server',
broker=BROKER_URL,
backend='rpc://')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
@app.task(bind=True)
def debug_task(self):
print('Request:{0!r}'.format(self.request))
它有 8 个函数,其中 2 个使用apply_async
函数调用。 我期待你的回答。 谢谢
你的broker_url看起来不对劲。 这是正确的格式:
amqp://username:password@host:port/vhost