Sellerie: die automatische Erkennung nicht finden, Aufgaben-Modul in der app

Habe ich im folgenden setup mit einem frisch installierten Sellerie und 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

Zustellung der Nachricht an den celeryd funktioniert gut, aber die Aufgabe ist immer unregistrierte (also die automatische Erkennung scheint nicht zu funktionieren, richtig hier). Nur wenn ich das import-Modul Aufgaben, die in tasks/__init__.py die Aufgabe wird gefunden und ich kann es benutzen.

Auch die Dokumentation war ein wenig verwirrend über den decorator importieren, aber ich denke das ist das richtige jetzt.

Wo ist der Fehler in meinem setup?

InformationsquelleAutor Martin | 2012-04-19

11

Dies war ein bug in django-celery 2.5.4, bitte ein upgrade auf 2.5.5!

Ich werde den test später, aber so wie ich das sehe auf Pypi, 2.5.5 wurde gestern veröffentlicht, so ist dies eine wirklich gute Informationen!
Ja, das hat geklappt 🙂

InformationsquelleAutor asksol
24

Hinzufügen CELERY_IMPORTS zu Ihrem settings.py:
```
CELERY_IMPORTS = ('testapp.tasks',)
```
Importieren Sie alle Aufgaben in testapp.tasks.__init__ Datei

Dann Sellerie importieren werden alle Aufgaben von der testapp.Aufgaben-Ordner und benennen Sie Sie so, wie Sie sind

Getestet habe ich diese, aber es hat nicht geholfen. Nur der import in die __init__.py von der app haben die Aufgabe, die Arbeit.
Hatte das gleiche problem mit 2.5.5. Hinzufügen CELERY_IMPORTS für mich gearbeitet, aber nur zusammen mit einem expliziten argument name, in den Dekorateur. Einfach über @task() löst eine KeyError.
Dies funktioniert für mich, vielen Dank.

InformationsquelleAutor dgel
5

Ich hatte das gleiche Problem mit django 1.4.1 Sellerie 3.0.9 und fixiert es durch die Benennung der Aufgabe.

@task() -> @task(name= " testapp.Aufgaben.hinzufügen')

Haben Sie irgendwelche anderen änderungen? Ich habe das gleiche Problem, aber nur indem ein name nicht scheinen, um es zu lösen
Ich musste neu starten Sellerie-client. Aber ich wusste nicht, weitere änderungen vorzunehmen.
Es scheint nicht zu funktionieren mit oben genannten Vorschlag.

InformationsquelleAutor jantzen05
5

Für jeden, der stolpert hier auf der Suche nach ähnlichen problem-Lösung.

In meinem Fall war es die Umschaltung vom alten Modul Grundlagen INSTALLED_APPS Einstellung auf eine neue AppConfig basierte Konfiguration.

Neue Anwendungen sollten vermeiden, default_app_config. Stattdessen sollten Sie bedürfen der gestrichelten Pfad zu der entsprechenden AppConfig Unterklasse konfiguriert werden explizit in INSTALLED_APPS.

Um dies zu beheben, sollten Sie ändern die Weise, die Sie füttern Pakete Sellerie, wie hier angegeben, in der 2248 Sellerie Ausgabe:
```
from django.apps import apps
app.autodiscover_tasks(lambda: [n.name for n in apps.get_app_configs()]
```
Statt der alte Sellerie, 3-Weg:
```
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
```
Und beachten Sie, dass wenn Sie mit Sellerie 4, war der Fehler behoben -- github.com/celery/celery/issues/3341--, und Sie können tun app.autodiscover_tasks()
ja,zum Beispiel, wenn ich 'blog.apps.BlogConfig' in meinem INSTALLED_APPS，Sellerie nicht finden können.Ich habe zu 'blog' in INSTALLED_APPS, Sellerie finden

InformationsquelleAutor Janusz Skonieczny
1

Ich bin mir ziemlich sicher, dass Sie zum importieren der "Sellerie app-Instanz" und erklären, eine Aufgabe wie diese:
```
from project_name.celery import app

@app.task
def video_process_task(video_id):
    pass
```
beachten Sie, dass es ein celery.py Datei in der project_dir/Projektname-Ordner, erklärt die Sellerie-Instanz, wie diese:
```
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)
```
gemäß den Anweisungen in der offizielle Dokumentation.

außerdem müssen Sie registrieren Sie die Aufgabe, in einer von diesen drei Möglichkeiten:
- die CELERY_IMPORTS variable in Django-Projekts settings.py Datei, wie in dgel Antwort
- vorbei bind=True dem Dekorator wie: @app.task(bind=True)
- wenn Sie autodiscovery für Sellerie, wie es oben in der Zeile app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
  jedes Django-Anwendung Ordner enthalten kann tasks.py Datei, und die Aufgaben erklärt innerhalb es automatisch registriert
beachten Sie, dass änderungen der Aufgaben ERFORDERN EINE SELLERIE NEUSTART wirksam

ein Sellerie-Neustart ist nicht für mich, ich brauche Sie zum löschen die pycache - Ordner manule. um es auto-discovery-die Aufgabe in die tasks.py Dateien.. was ist hier das problem??
Ich denke, müssen Sie manuell importieren Sie Ihre Aufgaben bis settings.py. Ich bin auf windows und mein Sellerie-version 3.1.25 . Ich löse das Problem mit den manuellen import

InformationsquelleAutor Iman Akbari

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.