Не могу импортировать модели в файл сельдерея tasks.py - PullRequest
Новая
       8

Не могу импортировать модели в файл сельдерея tasks.py

0 голосов
/ 25 декабря 2018

в моем файле tasks.py я хочу импортировать модели из приложения опросов, но я получаю django.core.exceptions.AppRegistryNotReady: приложения еще не загружены при запуске рабочего

tasks.py 

from __future__ import absolute_import
import sys ,os
from polls.models import User
from .celery import app


@app.task
def add_user(user):
    # for user in users:
    print('urra')
    #user = User(user.first_name, user.last_name, user.email)
    # user.save()

celery.py: 

from __future__ import absolute_import, unicode_literals
from celery import Celery
import os, sys
from task import celery_config
import dotenv
from os.path import dirname, join

app = Celery('task',
             broker='amqp://root:lusine_admin@localhost/task',
             backend='amqp://',
             include=['task.tasks'])

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "task.settings")
app.config_from_object(celery_config)
# app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

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

На самом деле я получил модуль опросов ошибок не найден, но затем из bash я добавил его в pythonpath и знаю, что получаю эту ошибку,

1 Ответ

0 голосов
/ 25 декабря 2018

Ваша ошибка в вашей конфигурации.Если вы хотите соединить сельдерей с вашим django, вам нужно инициализировать конфигурацию сельдерея из настроек django .В вашем celery.py замените эту строку: 

app.config_from_object(celery_config)

на 

app.config_from_object('django.conf:settings', namespace='CELERY')
...