mam w mojej konfiguracji seleraSeler próbuje połączyć się z niewłaściwym maklera
BROKER_URL = 'redis://127.0.0.1:6379'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379'
Jednak gdy uruchomię celeryd, otrzymuję ten błąd
consumer: Cannot connect to amqp://[email protected]:5672//: [Errno 111] Connection refused. Trying again in 2.00 seconds...
Dlaczego nie jest to łączenia się z REDiS broker ustawiłem go na, który działa btw?
zaimportować seler i dodaj swoją broker tak:
celery = Celery('task', broker='redis://127.0.0.1:6379')
celery.config_from_object(celeryconfig)
Gdzie to się podział? Mam plik selery.py, który zawiera podobny kod jak twoja odpowiedź, który znajduje się w tym samym folderze co mój plik settings.py. Mimo to otrzymuję ten sam błąd co OP. Ten sam problem po umieszczeniu w settings.py –
Mam ten sam problem. Proszę zobaczyć mój post na http://stackoverflow.com/questions/29402447/how-to-set-celeryconfig-file-in-in-django?noredirect=1#comment47060151_29402447 – user61629
Z tego co wiem 'config_from_object' zastąpi' broker' podany jako argument do konstruktora, jeśli 'BROKER_URL' istnieje w pliku celeryconfig ... – chefarov
Jeśli po First Steps with Celery samouczek, w szczególności:
app.config_from_object('django.conf:settings', namespace='CELERY')
to trzeba poprzedzić ustawienia z CELERY, więc zmienić BROKER_URL na:
CELERY_BROKER_URL = 'redis://127.0.0.1:6379'
Wygląda jak seler c nie znajdź swojej konfiguracji i używaj domyślnych. Gdzie umieściłeś swój plik 'celeryconfig.py'? Musi być na twojej ścieżce python ([docs] (http://docs.celeryproject.org/en/latest/configuration.html#configuration-and-defaults)). – alecxe