Celery ImportError:没有名为tasks的模块

 傅笑寒 发布于 2023-02-11 19:26

我正在为Celery/RabbitMQ/Django创建一个测试场景.浏览/阅读类似我的各种帖子后,我发现这一个,最接近,但仍然没有帮助我.执行芹菜工作时,我遇到"ImportError:no module named tasks"错误.

芹菜:3.1.5(不是dj芹菜)Django:1.5.5

项目结构:

testcele/ (project name)
  mycelery/ (myapp)
    __init__
    tasks

  testcele/
    __init__
    celery_task
    settings

testcele/testcele/celery_task:

  from __future__ import absolute_import
  import os
  from celery import Celery, task, current_task
  from django.conf import settings

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

  app = Celery('testcele', backend='amqp', broker='amqp://guest@localhost//',
                include=['tasks'])

  if __name__ == '__main__':
      app.start()    

  # 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)

testcele/testcele/init .py:

  from __future__ import absolute_import
  from .celery_task import app as celery_app

mycelery/tasks.py:

  from __future__ import absolute_import
  from celery import Celery, task, current_task, shared_task


  @shared_task()
  def create_models():
    .
    .
    .

我正在跑步:"芹菜工人-A testcele -l INFO",位于"testcele /"子目录.我也尝试从testcele/testcel子目录运行,从testcele/mycelery运行,用"tasks"或"mycelery"替换celery worker命令中的"testcele".显然,这会产生其他错误.

我错过了什么?

谢谢,里卡多

撰写答案
今天,你开发时遇到什么问题呢?
立即提问
热门标签
PHP1.CN | 中国最专业的PHP中文社区 | PNG素材下载 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有