Я пытаюсь настроить django + celery + redis + celery_beats, но это дает мне проблемы. Документация довольно проста, но когда я запускаю сервер django, redis, сельдерей и сельдерей, ничто не печатается или не регистрируется (вся моя тестовая задача делает свой журнал что-то).
Это моя структура папок:
- aenima
- aenima
- __init__.py
- celery.py
- criptoball
- tasks.py
celery.py выглядит так:
from __future__ import absolute_import, unicode_literals
import os
from django.conf import settings
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'aenima.settings')
app = Celery("criptoball")
app.conf.broker_url = 'redis://localhost:6379/0'
# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
# should have a 'CELERY_' prefix.
app.config_from_object('django.conf:settings', namespace='CELERY')
# Load task modules from all registered Django app configs.
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
app.conf.timezone = 'UTC'
@app.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))
app.conf.beat_schedule = {
'test-every-30-seconds': {
'task': 'tasks.test_celery',
'schedule': 30.0,
'args': (16, 16)
}, }
и tasks.py выглядит так:
from __future__ import absolute_import, unicode_literals
from datetime import datetime, timedelta
from celery import shared_task
import logging
from django_celery_beat.models import PeriodicTask, IntervalSchedule
cada_10_seg = IntervalSchedule.objects.create(every=10, period=IntervalSchedule.SECONDS)
test_celery_periodic = PeriodicTask.objects.create(interval=cada_10_seg, name='test_celery', task='criptoball.tasks.test_celery',
expires=datetime.utcnow()+timedelta(seconds=30))
@shared_task
def test_celery(x, y):
logger = logging.getLogger("AENIMA")
print("EUREKA")
logger.debug("EUREKA")
Это django_celery_beat docs
Не уверен, что мне не хватает. Когда я бегу
сельдерей -A aenima beat -l debug --scheduler django_celery_beat.schedulers: DatabaseScheduler
сельдерей -A рабочий aenima -l отладка
redis-cli ping PONG
django runningerver и redis server, я ничего не печатаю.
settings.py
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = TIME_ZONE
CELERY_IMPORTS = ('criptoball.tasks',)
До сих пор не найдено никакого официального ответа на эту тему.
Я хотел бы решить все это, эта ошибка может быть только одним из многих. Большое спасибо за вашу помощь!
Редактировать:
Добавлены настройки для redis, объявлены задачи по-разному и увеличен уровень отладки. Теперь ошибка:
Получена незарегистрированная задача типа u'tasks.test_celery '. Сообщение было проигнорировано и отброшено.
Помните ли вы импортировать модуль, содержащий эту задачу? Или, может быть, вы используете относительный импорт? KeyError: u'aenima.criptoball.tasks.test_celery '
Я считаю, что документация на сельдерей плохая.
EDIT 2 После того, как все было проработано, оно сработало, когда я поставил все задачи внутри одного файла celery.py. @shared_task не работает, пришлось использовать @app.task.
