我已经部署了一个celery应用进行生产,但是在5到10分钟后,它与rabbitmq断开了连接,但是服务器没有响应错误代码为:
[[Errno 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
功能被调用。我期待你的答案。谢谢