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
       )
Вернуться на верх