Невозможно запустить работников сельдерея (Приложение Flask) - PullRequest
Новая
       9

Невозможно запустить работников сельдерея (Приложение Flask)

0 голосов
/ 23 апреля 2019

Я пробую сельдерей с помощью Python Flask.

celery_example.py 

from __future__ import absolute_import, unicode_literals
from flask import Flask
from flask_celery import make_celery

flask_app = Flask(__name__)
flask_app.config.update(
    CELERY_BROKER_URL='amqp://rsrc:rsrc@localhost:5672/localhost',
    CELERY_RESULT_BACKEND='db+postgresql://postgres:postgres@localhost/rsrc_celery'
)

celery = make_celery(flask_app)

@flask_app.route('/process/<name>')
def process(name):
    reverse.delay(name)
    return "Async !"


@celery.task(name="celery_example.reverse")
def reverse(nm):
    return nm[::-1]

if __name__ == "__main__":
    flask_app.run(debug=True)

flask_celery.py 

from __future__ import absolute_import, unicode_literals
from celery import Celery

def make_celery(app):
    celery = Celery(app.import_name, backend=app.config['CELERY_RESULT_BACKEND'], broker=app.config['CELERY_BROKER_URL'])
    celery.conf.update(app.config)
    TaskBase = celery.Task
    class ContextTask(TaskBase):
        abstract = True
        def __call__(self, *args, **kwargs):
            with app.app_context():
                return TaskBase.__call__(self, *args, **kwargs)
    celery.Task = ContextTask
    return celery

Сервер FLask работает и работает нормально,Я могу назвать маршрут, который определен.Но я не могу запустить работника Celery ( работник сельдерея -A celery_example.celery --loglevel = info ) Это ошибка, которую я получаю всегда. 

Traceback (most recent call last):
  File "/usr/local/bin/celery", line 10, in <module>
    sys.exit(main())
  File "/Library/Python/2.7/site-packages/celery/__main__.py", line 16, in main
    _main()
  File "/Library/Python/2.7/site-packages/celery/bin/celery.py", line 322, in main
    cmd.execute_from_commandline(argv)
  File "/Library/Python/2.7/site-packages/celery/bin/celery.py", line 496, in execute_from_commandline
    super(CeleryCommand, self).execute_from_commandline(argv)))
  File "/Library/Python/2.7/site-packages/celery/bin/base.py", line 290, in execute_from_commandline
    self.on_error(UNABLE_TO_LOAD_APP_MODULE_NOT_FOUND.format(e.name))
AttributeError: 'exceptions.ImportError' object has no attribute 'name'

Моя структура каталогов

1015 *

1 Ответ

0 голосов
/ 07 мая 2019

Ладно, в чем проблема с окружающей средой.

Я создавал среду с помощью "virtualenv env", который создавал среду с python, тогда как мне требовалась среда python3.

ИтакЯ создал виртуальную среду, используя "python3 -m venv env", а затем загрузил все зависимости, которые устранили ошибку.

...