使用Django / virtualenv运行芹菜时找不到'__main__'模块

Question

Debian 9.8 virtualenv 16.4.3 Python 3.5.3 Django 2.1.7 芹菜4.3.0 django-celery-beat 1.4.0

当我从我的app目录运行celery命令时，我的venv活动如celery worker -A personnel或celery beat -l info --scheduler django_celery_beat.schedulers:DatabaseScheduler，它按预期工作。我的应用程序名称是“人员”。

有几个相关的问题，但没有完全像我的。以下是我尝试各种命令时会发生的情况。

来自项目目录的带有venv active的celery worker启动了worker并看起来正如文档所示它应该（redis工作，beat也工作）

来自proj dir外面的/home/www/personnel/venv/bin/python与venv没有活动，让我陷入了一个shell，在那里我可以毫无错误地导入Celery

来自proj外面的/home/www/personnel/venv/bin/celery向我展示了芹菜帮助（用法：芹菜[选项] ......）

/home/www/personnel/venv/bin/python /home/www/personnel celery worker，我的研究应该是什么，返回：/home/www/personnel/venv/bin/python: can't find '__main__' module in '/home/www/personnel'

使用-A标志返回上述错误。

/home/www/personnel/venv/bin/python /home/www/personnel/manage.py celery worker回归：

Unknown command: 'celery'
Type 'manage.py help' for usage.

stdout日志显示相同的错误。我猜这个命令应该在主管发挥作用之前起作用。

我已经从头开始并以相同的结果重新创建了venv。

# __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
#from celery.schedules import crontab

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'personnel.settings')

app = Celery('personnel')
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))

; ==================================
; celery worker config
; ==================================

[program:celery]
; full path using virtualenv
command=/home/www/personnel/venv/bin/python /home/www/personnel celery worker -A personnel -I info

directory=/home/www/personnel
;user=dunnoyet
numprocs=1
stderr_logfile=/var/log/celery.out.log
stdout_logfile=/var/log/celery.err.log
autostart=true
autorestart=true
startsecs=10

; need to wait for currently executing tasks to finish at shutdown
; increase if long running tasks
stopwaitsecs = 600

; send the termination signal (SIGTERM) to the whole process group
stopasgroup=true

; set Celery priority higher than default (999)
; so, if rabbitmq is supervised, it will start first
priority=1000

# Project structure based on django cookie cutter
pr_project
|--personnel
   |--api/
   |--...
   |--__init__.py
   |--celery.py
   |--urls.py
   |--views.py
   |--wsgi.py
|--requirements
|--...

从项目目录它按预期工作，但我不能让它在外面工作或与主管成功启动。

编辑

#personnel/settings.py
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'

正如建议我尝试/home/www/personnel/venv/bin/celery worker - 它开始，但看起来它无法连接到redis

[2019-04-05 09:18:11,960: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [Errno 111] Connection refused.

使用app flag /home/www/personnel/venv/bin/celery worker -A personnel：

Error:
Unable to load celery application.
The module personnel was not found.

Answer 1

使用主管时，它适用于：

[program:celery]
; full path using virtualenv
command=/home/www/personnel celery worker

directory=/home/www/personnel

从命令行尝试时它不起作用，也许因为它需要Django设置可访问。