Django celery с redis выполняет одно и то же задание несколько раз
Я пытаюсь создать фоновую задачу с Django celery и Redis в качестве брокера. эта задача отправляется из моделей, когда модель post save. Но проблема в том, что одна и та же задача выполняется 1000 раз (другие задачи отладки или добавления работают нормально). Я уже пробовал этот метод, но это не решило проблему. Пожалуйста, приведите приведенные ниже коды для справки и помощи в решении проблемы. Заранее спасибо.
models.py
from django.db.models.signals import post_save
from django.dispatch import receiver
from student.tasks import create_student_subject_tryout_result, add
@receiver(post_save, sender=TryoutSubmission,
dispatch_uid='create_student_subject_tryout_result')
def result_calculation(sender, instance, **kwargs):
if instance.status == 'C':
print('Calculating result')
create_student_subject_tryout_result.delay(instance.student.id,
instance.tryout.id)
celery.py
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'eec.settings')
app = Celery('eec')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.conf.broker_transport_options = {'visibility_timeout': 3600} .
app.autodiscover_tasks()
@app.task(bind=True)
def debug_task(self):
print(f'Request: {self.request!r}')
tasks.py
from celery import shared_task
import tryout.models
@shared_task(bind=True)
def create_student_subject_tryout_result(self, student_id, tryout_id):
tryout_submission
=tryout.models.TryoutSubmission.objects.get(student_id=student_id,
tryout_id=tryout_id)
tryout_questions = tryout_submission.tryout.tryoutquestion_set.all().count()
answered_qs = tryout_submission.tryout.tryoutanswersubmission_set.filter(
is_answered=True).count()
correct_ans = tryout_submission.tryout.tryoutanswersubmission_set.filter(
is_correct=True).count()
tryout_submission.total_questions = tryout_questions
tryout_submission.answered_questions = answered_qs
tryout_submission.correct_answers = correct_ans
tryout_submission.total_time = tryout_submission.end_time -
tryout_submission.start_time
tryout_submission.save()
return "Result created"
settings.py
CELERY_RESULT_BACKEND = 'django-db'
CELERY_CACHE_BACKEND = 'django-cache'
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Asia/Kolkata'
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'
Ну, если вы посмотрите на свой приемник, вы слушаете post_save
на вашей модели.
Сигнал post_save
также передает boolean
для обозначения того, был ли он создан или нет. Вместо того чтобы проверять instance.status == 'C'
, проверьте наличие созданного:
from django.db.models.signals import post_save
from django.dispatch import receiver
from student.tasks import create_student_subject_tryout_result, add
@receiver(post_save, sender=TryoutSubmission,
dispatch_uid='create_student_subject_tryout_result')
def result_calculation(sender, instance, raw, created, **kwargs):
if created:
print('Calculating result')
create_student_subject_tryout_result.delay(
instance.student.id,
instance.tryout.id
)