【问题标题】:Celery worker does not start ImportError for an app芹菜工人不会为应用程序启动 ImportError
【发布时间】:2016-08-22 09:37:31
【问题描述】:

我正在尝试将 celery 与 django 一起使用,并以 redis 作为代理。我的应用名称之一是用户,其模型由其他应用导入。当我运行 django 服务器时,它启动时没有任何错误,一切正常。

但是当我尝试使用命令“celery -A project worker -l INFO”启动 celery worker 时,我收到以下错误:

Traceback (most recent call last):
  File "/usr/local/bin/celery", line 11, in <module>
    sys.exit(main())
  File "/usr/local/lib/python2.7/dist-packages/celery/__main__.py", line 30, in main
    main()
  File "/usr/local/lib/python2.7/dist-packages/celery/bin/celery.py", line 81, in main
    cmd.execute_from_commandline(argv)
  File "/usr/local/lib/python2.7/dist-packages/celery/bin/celery.py", line 793, in execute_from_commandline
    super(CeleryCommand, self).execute_from_commandline(argv)))
  File "/usr/local/lib/python2.7/dist-packages/celery/bin/base.py", line 311, in execute_from_commandline
    return self.handle_argv(self.prog_name, argv[1:])
  File "/usr/local/lib/python2.7/dist-packages/celery/bin/celery.py", line 785, in handle_argv
    return self.execute(command, argv)
  File "/usr/local/lib/python2.7/dist-packages/celery/bin/celery.py", line 717, in execute
    ).run_from_argv(self.prog_name, argv[1:], command=argv[0])
  File "/usr/local/lib/python2.7/dist-packages/celery/bin/worker.py", line 179, in run_from_argv
    return self(*args, **options)
  File "/usr/local/lib/python2.7/dist-packages/celery/bin/base.py", line 274, in __call__
    ret = self.run(*args, **kwargs)
  File "/usr/local/lib/python2.7/dist-packages/celery/bin/worker.py", line 212, in run
    state_db=self.node_format(state_db, hostname), **kwargs
  File "/usr/local/lib/python2.7/dist-packages/celery/worker/__init__.py", line 95, in __init__
    self.app.loader.init_worker()
  File "/usr/local/lib/python2.7/dist-packages/celery/loaders/base.py", line 128, in init_worker
    self.import_default_modules()
  File "/usr/local/lib/python2.7/dist-packages/celery/loaders/base.py", line 116, in import_default_modules
    signals.import_modules.send(sender=self.app)
  File "/usr/local/lib/python2.7/dist-packages/celery/utils/dispatch/signal.py", line 166, in send
    response = receiver(signal=self, sender=sender, **named)
  File "/usr/local/lib/python2.7/dist-packages/celery/fixups/django.py", line 73, in on_import_modules
    self.worker_fixup.validate_models()
  File "/usr/local/lib/python2.7/dist-packages/celery/fixups/django.py", line 158, in validate_models
    django_setup()
  File "/usr/local/lib/python2.7/dist-packages/django/__init__.py", line 18, in setup
    apps.populate(settings.INSTALLED_APPS)
  File "/usr/local/lib/python2.7/dist-packages/django/apps/registry.py", line 108, in populate
    app_config.import_models(all_models)
  File "/usr/local/lib/python2.7/dist-packages/django/apps/config.py", line 202, in import_models
    self.models_module = import_module(models_module_name)
  File "/usr/lib/python2.7/importlib/__init__.py", line 37, in import_module
    __import__(name)
  File "/path_to_project/project/app1/models.py", line 2, in <module>
    from app1.models import *
  File "/path_to_project/project/project/models.py", line 9, in <module>
    from user.models import *
ImportError: No module named models

这里要注意的是它说没有名为models的模块和not没有名为user.models的模块。这可能意味着与其他文件存在一些冲突,尽管我已经仔细检查并且项目目录或 app1 目录中都没有 user.py。如果我将应用程序“user”重命名为“user2”,工作人员就会启动。还要注意的是,芹菜在某个时候开始很好。此后代码已更改,但未添加任何应用程序。

我的项目具有以下结构(仅显示相关部分)

- project
  - project
    - celery.py
    - models.py
  - user
    - models.py
  - app1
    - models.py
    - tasks.py

而 celery.py 是

from __future__ import absolute_import

import os
from celery import Celery
from django.conf import settings

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')

app = Celery('project')

# Using a string here means the worker will not have to
# pickle the object when using Windows.
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

CELERY 配置是

BROKER_URL = 'redis://localhost:6379/0'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'

谢谢

【问题讨论】:

    标签: python django redis celery


    【解决方案1】:

    问题是命名空间冲突。因为python 2.x 包含一个user 配置挂钩,并在python 3 中删除。更多关于user的信息。

    【讨论】:

    • 是否有解决方法来重命名它。我尝试使用 project.user 进行绝对导入,但它说没有模块名称 project.user
    • 您可能必须为您的项目使用python 3,或者可以执行this answer 之类的操作才能使用project.user。或者只是重命名user,即使是大写也可以暂时解决它。
    最近更新 更多