Jest to mój pierwszy kontakt z Celery i mimo przeczytania dokumentacji i kilku artykułów nie wiem jak wykorzystać asynchroniczność do zapisania modelu. Model dodaje grafiki, które są często dużych rozmiarów. Dlatego wykorzystałem zewnętrze API które podczas uploadu na serwer od razu kompresuje grafikę. Chciałbym aby po kliknięciu w panelu admina 'zapisz' nie trzeba było czekać aż wszystko się wykona.
Utworzyłem pliki celery.py i tasks.py(tutaj nic nie mam jak na razie):
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'basic.settings.development')
celery_app = Celery('basic')
celery_app.config_from_object('django.conf:settings', namespace='CELERY')
celery_app.autodiscover_tasks()
w settings dodałem brokera:
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
model:
from celery import shared_task
class Image(models.Model):
'''
Default models.ImageField replaced with OptimizedImageField which is TinyPNG API object
'''
title = models.CharField('Tytuł (opcjonalnie)', max_length=255, null=True, blank=True)
img = OptimizedImageField('wybrana grafika', upload_to='images', null=True)
display = models.BooleanField('wyświetl', default=True)
created = models.DateTimeField('Utworzono', auto_now_add=True)
updated = models.DateTimeField('Zmodyfikowano', auto_now=True)
class Meta:
verbose_name = 'Plik graficzny'
verbose_name_plural = 'Pliki graficzne'
def replace_url_string(self):
replace_image_name = self.img.url.replace("/media/images/", " ")
return replace_image_name
def __str__(self):
return f'id: {self.id} | nazwa pliku: {self.replace_url_string()}'
@shared_task
def save(self, *args, **kwargs):
super(Image, self).save(*args, **kwargs)
Jak widać próbuję to zrobić przez użycie .save() i udekorowanie jej taskiem no ale szczerze mówiąc nie mam pojęcia co robię :) Może ktoś pomóc ?