【发布时间】:2015-06-15 02:58:50
【问题描述】:
我在 celery task.py 中遇到导入错误。另一个包中的 StockManager 类方法用于保存详细信息。但是,我收到 StockManager() 的导入错误。我该如何解决这个问题。我做错什么了吗?
Folder structure
src
-tradeapp
-logic --> Common businesss logic layer
-asynctaskmanager --> Here the task.py and celery resides
from djcelery import celery
from logic.StockManager import StockManager
@celery.task
def save_stock_data(details):
stock_mngr = StockManager()
is_saved = stock_mngr.save_data(details)
return is_saved
谢谢
【问题讨论】:
-
你是如何运行 celery 的?使用主管或其他任何东西?
-
如果你尝试在python shell中导入这个模块可以吗?
-
我们需要有关您的项目结构以及逻辑文件夹在哪里的更多信息
-
上面的文件夹结构已经更新,我在控制台运行celeryd。
-
您使用的是 manage.py 还是直接使用 celeryd?即:python manage.py celery 或 celeryd
标签: python django django-celery celery-task celeryd