• 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

Object Storage Arubacloud
0 głosów
108 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ź 191 wizyt
pytanie zadane 7 września 2019 w Python przez Ziito Obywatel (1,110 p.)
0 głosów
1 odpowiedź 109 wizyt
pytanie zadane 23 września 2019 w Python przez Dawid89 Obywatel (1,120 p.)
0 głosów
1 odpowiedź 652 wizyt

92,575 zapytań

141,424 odpowiedzi

319,649 komentarzy

61,960 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

Kolejna edycja największej imprezy hakerskiej w Polsce, czyli Mega Sekurak Hacking Party odbędzie się już 20 maja 2024r. Z tej okazji mamy dla Was kod: pasjamshp - jeżeli wpiszecie go w koszyku, to wówczas otrzymacie 40% zniżki na bilet w wersji standard!

Więcej informacji na temat imprezy znajdziecie tutaj. Dziękujemy ekipie Sekuraka za taką fajną zniżkę dla wszystkich Pasjonatów!

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!

...