Le céleri: la détection automatique ne trouve pas de module tâches dans l'app

J'ai la configuration suivante avec une nouvelle installé le céleri et django 1.4:

settings.py:

import djcelery
djcelery.setup_loader()

BROKER_HOST = 'localhost'
BROKER_PORT = 5672
BROKER_USER = 'user'
BROKER_PASSWORD = 'password'
BROKER_VHOST = 'test'

[...]

INSTALLED_APPS = [
    'django.contrib.auth',
    'django.contrib.admin',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.sites',
    'django.contrib.staticfiles',
    'djcelery',
    'south',
    'compressor',
    'testapp',
]

testapp/tasks.py:

from celery.task import task

@task()
def add(x, y):
    return x + y

La livraison d'un Message à l'celeryd fonctionne très bien, mais la tâche est toujours non (si la détection automatique ne semble pas fonctionner correctement ici). Seulement si j'ai importer le module tâches dans tasks/__init__.py la tâche est trouvé et je peux l'utiliser.

Également la documentation est un peu déroutant au sujet de la décoratrice d'importation, mais je pense que c'est la bonne maintenant.

Où est le bug dans mon installation?

OriginalL'auteur Martin | 2012-04-19

11

C'était un bug dans django-céleri 2.5.4, veuillez la mettre à jour 2.5.5!

Je vais tester cela plus tard, mais comme je vois sur Pypi, 2.5.5 a été libéré hier, donc c'est vraiment une bonne information!
Oui, cela a fonctionné 🙂

OriginalL'auteur asksol
24

Ajouter CELERY_IMPORTS à votre settings.py:
```
CELERY_IMPORTS = ('testapp.tasks',)
```
Importer toutes les tâches testapp.tasks.__init__ fichier

Puis Céleri va importer toutes les tâches de testapp.les tâches de dossier et nommez-les comme ils sont

J'ai testé, mais il n'a pas aidé. Seule l'importation dans le __init__.py de l'application a été la tâche de travail.
Eu le même problème avec 2.5.5. L'ajout de CELERY_IMPORTS a fonctionné pour moi, mais seulement avec un nom explicite argument dans le décorateur. Simplement à l'aide de @tâche() génère une KeyError.
Cela fonctionne pour moi, merci beaucoup.

OriginalL'auteur dgel
5

J'ai eu le même problème avec django 1.4.1 céleri 3.0.9 et il fixe le nom de la tâche.

@tâche() -> @tâche(nom='testapp.les tâches.ajouter')

Avez-vous d'autres changements? Je vais avoir le même problème, mais simplement l'ajout d'un nom ne semble pas à le résoudre
J'avais besoin de redémarrer le céleri client. Mais je n'ai pas à faire d'autres changements.
Il ne semble pas fonctionner avec au-dessus de la suggestion.

OriginalL'auteur jantzen05
5

Pour tout celui qui trébuche ici à la recherche d'similaires la solution du problème.

Dans mon cas, c'était de commutation de l'ancien module de bases de INSTALLED_APPS paramètre pour une nouvelle AppConfig en fonction de la configuration.

De nouvelles applications devraient éviter de default_app_config. Au lieu de cela, ils doivent exiger la en pointillés chemin d'accès approprié AppConfig sous-classe à être configuré de manière explicite dans INSTALLED_APPS.

Pour corriger cela, vous devez changer la façon dont vous nourrissez les paquets de céleri, comme indiqué ici dans le 2248 Céleri problème:
```
from django.apps import apps
app.autodiscover_tasks(lambda: [n.name for n in apps.get_app_configs()]
```
Au lieu de l'ancien Céleri 3 voies:
```
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
```
Et notez que si vous utilisez le Céleri 4, le bug a été corrigé -- github.com/celery/celery/issues/3341-- et vous pouvez le faire app.autodiscover_tasks()
oui,par exemple, si je mets le blog de.des apps.BlogConfig " dans mon INSTALLED_APPS，le céleri peut pas trouver que.Je dois mettre "blog" dans INSTALLED_APPS que le céleri peut trouver

OriginalL'auteur Janusz Skonieczny
1

Je suis sûr que vous devez importer le "Céleri instance de l'application" et de déclarer une tâche comme ceci:
```
from project_name.celery import app

@app.task
def video_process_task(video_id):
    pass
```
noter qu'il y a un celery.py fichier dans le project_dir/project_name dossier, qui déclare le céleri exemple, comme ceci:
```
from __future__ import absolute_import
import os
from celery import Celery
from django.conf import settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project_name.settings')
app = Celery('project_name')
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
```
comme indiqué dans le la documentation officielle.

aussi, vous devez vous inscrire à la tâche, dans l'une de ces trois façons:
- la CELERY_IMPORTS variable dans Django du projet settings.py fichier comme dans dgel la réponse de
- passant bind=True le décorateur, comme: @app.task(bind=True)
- si vous définissez la détection automatique pour le céleri comme cela se fait au-dessus de la ligne de app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
  chaque application Django du dossier peut contenir un tasks.py fichier, et les tâches déclarée à l'intérieur, il sera automatiquement enregistré
notez que les modifications apportées aux tâches qui NÉCESSITENT UN CÉLERI REDÉMARRAGE en effet

un céleri redémarrage n'est pas un travail pour moi, j'ai besoin de supprimer le pycache dossier manule. pour faire de la détection automatique de la tâche dans la tasks.py fichiers.. quel est le problème ici??
Je pense que vous devez importer manuellement vos tâches de settings.py. Je suis sur windows et mon céleri version est 3.1.25 . - Je résoudre le problème avec l'importation manuelle

OriginalL'auteur Iman Akbari

Vous devez vous connecter pour publier un commentaire.