• Najnowsze pytania
  • Bez odpowiedzi
  • Zadaj pytanie
  • Kategorie
  • Tagi
  • Zdobyte punkty
  • Ekipa ninja
  • IRC
  • FAQ
  • Regulamin
  • Książki warte uwagi

zapisanie modelu z użyciem Celery

VPS Starter Arubacloud
0 głosów
110 wizyt
pytanie zadane 9 stycznia 2020 w Python przez Dawid89 Obywatel (1,120 p.)

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 ?

Zaloguj lub zarejestruj się, aby odpowiedzieć na to pytanie.

Podobne pytania

0 głosów
1 odpowiedź 200 wizyt
pytanie zadane 7 września 2019 w Python przez Ziito Obywatel (1,110 p.)
0 głosów
1 odpowiedź 119 wizyt
pytanie zadane 23 września 2019 w Python przez Dawid89 Obywatel (1,120 p.)
0 głosów
1 odpowiedź 723 wizyt

92,830 zapytań

141,771 odpowiedzi

320,817 komentarzy

62,159 pasjonatów

Motyw:

Akcja Pajacyk

Pajacyk od wielu lat dożywia dzieci. Pomóż klikając w zielony brzuszek na stronie. Dziękujemy! ♡

Oto polecana książka warta uwagi.
Pełną listę książek znajdziesz tutaj.

Akademia Sekuraka

Niedawno wystartował dodruk tej świetnej, rozchwytywanej książki (około 940 stron). Mamy dla Was kod: pasja (wpiszcie go w koszyku), dzięki któremu otrzymujemy 10% zniżki - dziękujemy zaprzyjaźnionej ekipie Sekuraka za taki bonus dla Pasjonatów! Książka to pierwszy tom z serii o ITsec, który łagodnie wprowadzi w świat bezpieczeństwa IT każdą osobę - warto, polecamy!

...