概述:
我正在尝试将芹菜作为发送电子邮件任务的守护程序运行。它在开发中运行良好,但在生产中则不然。我现在有我的网站,每个函数都运行良好(没有 django 错误(,但任务没有通过,因为守护程序设置不正确,我在 ubuntu 16.04 中收到此错误:
project_celery FATAL can't find command '/home/my_user/myvenv/bin/celery'
已安装的程序/硬件,以及到目前为止我所做的:
我在VPS上使用Django 2.0.5,python 3.5,ubuntu 16.04,rabbitmq和celery。我为这一切使用静脉。我也安装了 supervisor,当我与sudo service --status-all
检查时它正在运行,因为它旁边有一个 +。还安装了 Erlang,当我与 top
检查时,rabbitmq 正在运行。使用sudo service rabbitmq-server status
显示 rabbitmq 也处于活动状态。
最初,我遵循了芹菜网站上的说明,但它们非常混乱,经过~40个小时的测试/阅读/观察其他人的解决方案后,我无法让它工作。我感到非常愤怒和失败,我选择了这里的方向来设置守护进程,并希望我能到达某个地方,我已经走得更远,但我得到了上面的错误。
我通读了主管文档,检查了流程状态以尝试调试问题和程序设置,根据文档,我迷路了,因为据我所知,我的路径是正确的。
这是我的文件结构被剥离了:
home/
my_user/ # is a superuser
portfolio-project/
project/
__init__.py
celery.py
settings.py # this file is in here too
app_1/
app_2/
...
...
logs/
celery.log
myvenv/
bin/
celery # executable file, is colored green
celery_user_nobody/ # not a superuser, but created for celery tasks
etc/
supervisor/
conf.d/
project_celery.conf
这是我的project_celery.conf:
[program:project_celery]
command=/home/my_user/myvenv/bin/celery worker -A project --loglevel=INFO
directory=/home/my_user/portfolio-project/project
user=celery_user_nobody
numprocs=1
stdout_logfile=/home/my_user/logs/celery.log
stderr_logfile=/home/my_user/logs/celery.log
autostart=true
autorestart=true
startsecs=10
stopwaitsecs = 600
stopasgroup=true
priority=1000
这是我的 init.py:
from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app
__all__ = ['celery_app']
这是我的 celery.py:
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')
app = Celery('project')
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))
更新:这是我 settings.py:
这是我唯一的设置,因为芹菜网站 django 指令中的示例仅显示更多内容,除非我要使用 redis 之类的东西。我把它放在我的 settings.py 文件中,因为 django 指令说你可以: CELERY_BROKER_URL = 'amqp://localhost'
更新:我创建了 rabbitmq 用户:
$ sudo rabbitmqctl add_user rabbit_user1 mypassword
$ sudo rabbitmqctl add_vhost myvhost
$ sudo rabbitmqctl set_user_tags rabbit_user1 mytag
$ sudo rabbitmqctl set_permissions -p myvhost rabbit_user1 ".*" ".*" ".*"
当我做sudo rabbitmqctl status
时,我得到了Status of node 'rabbit@django2-portfolio'
,但奇怪的是,我没有看到任何节点像下面这样运行,因为这里的指示表明我应该看到:
{nodes,[rabbit@myhost]},
{running_nodes,[rabbit@myhost]}]
我遵循的步骤:
- 我在我说的地方创建了 .conf 和 .log 文件。
- sudo systemctl enable supervisor
- sudo systemctl start supervisor
- 须藤监事重读
- 须藤主管CTL更新
# no errors up to this point
- 须藤主管状态
6 之后我收到此错误:
project_celery FATAL can't find command '/home/my_user/myvenv/bin/celery'
更新:我检查了错误日志,我在/var/log/rabbitmq/rabbit@django2-portfolio.log 中有多个以下实例:
=INFO REPORT==== 9-Aug-2018::18:26:58 ===
connection <0.690.0> (127.0.0.1:42452 -> 127.0.0.1:5672): user 'guest' authenticated and granted access to vhost '/'
=ERROR REPORT==== 9-Aug-2018::18:29:58 ===
closing AMQP connection <0.687.0> (127.0.0.1:42450 -> 127.0.0.1:5672):
missed heartbeats from client, timeout: 60s
结语:
有人知道发生了什么吗?当我查看 project_celery.conf 文件中的绝对路径时,我看到所有设置都正确,但显然有些错误。再看一下我的代码,rabbitmq说没有节点在运行。当我做sudo rabbitmqctl status
时,但芹菜做celery status
时(它显示OK 1 node online
(。
任何帮助将不胜感激。我什至专门做了这个帐户,因为我有这个问题。这让我发疯。如果有人需要更多信息,请询问。这是我第一次部署任何东西,所以我不是专业人士。
你能在你的project_celery.conf
中尝试以下任何一种吗
command=/home/my_user/myvenv/bin/celery worker -A celery --loglevel=INFO
directory=/home/my_user/portfolio-project/project
或
command=/home/my_user/myvenv/bin/celery worker -A project.celery --loglevel=INFO
directory=/home/my_user/portfolio-project/
此外,celery.py
是否可以将project
模块的父文件夹添加到sys.path
(或确保已正确打包部署并通过 pip 或其他方式安装(?
我怀疑(从您对 @Jack Shedd 的评论中,您指的是一个不存在的项目,因为目录相对于魔术 celery.py 文件的设置位置。