【发布时间】:2018-04-25 06:42:10
【问题描述】:
我已经通过how to use celery on my django production server using supervisor。
但是,当我尝试使用 sudo supervisorctl start app-celery 启动主管时 - 它返回:
app-celery: ERROR (spawn error)
这是我的配置/etc/supervisor/conf.d/app-celery.conf:
[program:app-celery]
command=/home/zorgan/app/env/bin/celery worker -A draft1 --loglevel=INFO
directory=/home/zorgan/app/draft1
numprocs=1
stdout_logfile=/var/log/supervisor/celery.log
stderr_logfile=/var/log/supervisor/celery.log
autostart=true
autorestart=true
startsecs=10
; Need to wait for currently executing tasks to finish at shutdown.
; Increase this if you have very long running tasks.
stopwaitsecs = 600
stopasgroup=true
; Set Celery priority higher than default (999)
; so, if rabbitmq is supervised, it will start first.
priority=1000
我逐字逐句地按照教程进行操作 - 我不知道为什么它不起作用。我检查了我到celery 的路径是/home/zorgan/app/env/bin/celery,我的celery.py 和tasks.py 在/home/zorgan/app/draft1 中。以及/home/zorgan/app/draft1 中的初始化文件被更改为:
from __future__ import absolute_import, unicode_literals
#This will make sure the app is always imported when
#Django starts so that shared_task will use this app.
from .celery import app as celery_app
__all__ = ['celery_app']
这是我的 celery.py:
import os
from celery import Celery
from celery.schedules import crontab
from .settings import CELERY_BROKER_URL #CELERY_BROKER_URL = 'amqp://174.138.62.649' (changed the number for privacy reasons)
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'draft1.settings')
app = Celery("draft1", broker=CELERY_BROKER_URL)
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()
这里有任何危险信号吗?因为我的celery.log 文件中也出现了这个错误:
File "/home/zorgan/app/env/lib/python3.5/site-packages/kombu/utils/imports.py", line 56, in symbol_by_name
module = imp(module_name, package=package, **kwargs)
File "/home/zorgan/app/env/lib/python3.5/site-packages/celery/utils/imports.py", line 101, in import_from_cwd
return imp(module, package=package)
File "/home/zorgan/app/env/lib/python3.5/importlib/__init__.py", line 126, in import_module
return _bootstrap._gcd_import(name[level:], package, level)
File "<frozen importlib._bootstrap>", line 986, in _gcd_import
File "<frozen importlib._bootstrap>", line 969, in _find_and_load
File "<frozen importlib._bootstrap>", line 956, in _find_and_load_unlocked
ImportError: No module named 'draft1'
但我不确定这是否相关。这是我的supervisord.log的sn-p:
2018-04-25 03:15:07,665 INFO spawned: 'app-celery' with pid 24296
2018-04-25 03:15:08,050 INFO exited: app-celery (exit status 1; not expected)
2018-04-25 03:15:09,052 INFO gave up: app-celery entered FATAL state, too many start retries too quickly
2018-04-25 03:15:09,815 INFO spawned: 'app-celery' with pid 24302
2018-04-25 03:15:10,221 INFO exited: app-celery (exit status 1; not expected)
2018-04-25 03:15:11,231 INFO spawned: 'app-celery' with pid 24309
2018-04-25 03:15:11,646 INFO exited: app-celery (exit status 1; not expected)
2018-04-25 03:15:13,650 INFO spawned: 'app-celery' with pid 24313
2018-04-25 03:15:14,068 INFO exited: app-celery (exit status 1; not expected)
2018-04-25 03:15:17,074 INFO spawned: 'app-celery' with pid 24317
2018-04-25 03:15:17,505 INFO exited: app-celery (exit status 1; not expected)
知道问题出在哪里吗?
编辑:
项目树:
home / zorgan / app / draft1
... ...
manage.py celery.py
env tasks.py
【问题讨论】:
-
尝试
app = Celery("draft1", broker=BROKER_URL)如果您仍然遇到同样的问题,请向您展示项目目录结构。 -
嗯,我没有
BROKER_URL- 这可能是问题所在?我怎么知道BROKER_URL使用什么? -
BROKER_URL = 'amqp://localhost'如果您使用的是任何服务器,则放置该服务器的 ip,而不是localhost,如BROKER_URL = 'amqp://IP_OF_SERVER -
我刚刚尝试过,但仍然遇到同样的错误。我在编辑中更新了我的
celery.py并添加了我的项目树。对于问题可能是什么,还有其他建议吗? -
试试
app = Celery("app.draft1", broker=BROKER_URL)
标签: python django unix celery supervisord