Структура и макет структуры каталога Django Celery

Question

У меня есть проект django, используя следующую структуру каталогов.

project/ 
    account/ 
     models.py 
     views.py 
    blog/ 
     models.py 
     views.py 
    mediakit/ 
     models.py 
     views.py 
    reports/ 
     celery.py <-- new 
     models.py 
     tasks.py <-- new 
     views.py 
    settings/ 
     __init__.py <-- project settings file 
    system/ 
     cron/ 
     mongodb/ 
     redis/ 
    manage.py 

Вот содержимое celery.py, полученные из сельдерея учебника (http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html).

from __future__ import absolute_import 

import os 

from celery import Celery 

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

from django.conf import settings 

# app = Celery('reports') 
app = Celery('reports', 
      backend='djcelery.backends.database:DatabaseBackend', 
      broker='amqp://guest:guest@localhost:5672//') 

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


@app.task(bind=True) 
def debug_task(self): 
    print('Request: {0!r}'.format(self.request)) 

Некоторые из моих приложений разделены между проектами. отчеты, например, могут быть использованы в 4 разных проектах, поэтому Я могу видеть, как tasks.py должен жить в приложении отчетов, поэтому, когда он добавляется в новый проект, возникают задачи . Я не совсем понимаю, почему celery.py необходимо проживать в приложении отчетов . Когда я добавляю некоторые задачи в приложение учетной записи, я в основном строю один и тот же файл celery.py , заменяя «отчеты» на «учетную запись». Должен ли я иметь один файл сельдерея, который живет на том же уровне как manage.py? Любая помощь или предложения были бы весьма признательны.

Answer 1

Файл приложения сельдерея должен находиться в основной директории вашего проекта, по настройкам и всем остальным, как показано в документации, которую вы опубликовали.

Для определения переносных задач имеет смысл разместить их в приложении, которое использует их, как вы указали, в вашем случае приложение отчетов.

Идея состоит в том, что ваш файл задачи зарегистрирован любым приложением для сельдерея, определенным в проекте, а вашему приложению django не нужно знать, какое приложение для сельдерея регистрирует задачи. Вы делаете это, используя декоратор shared_task вместо app.task.

Резюмируя:

project/ 
    project/ 
     settings.py 
     celery.py <- new, shown in the docs, also add __init__.py 
     urls.py 
    account/ 
     models.py 
     views.py 
    blog/ 
     models.py 
     views.py 
    mediakit/ 
     models.py 
     tasks.py <-- tasks for the me 
     views.py 
    reports/ 
     models.py 
     tasks.py <-- tasks for the reports app 
     views.py 
    manage.py 

В tasks.py у вас есть что-то вроде этого:

from celery import shared_task 

@shared_task 
def my_add_task(a, b): 
    return a + b 

Надеется, что это помогает.

Answer 2

Вам нужен только один файл сельдерея. Рекомендуется поместить его в основной каталог проекта или в ваши настройки, если файл __init__ находится в одной папке и имеет необходимые вызовы.