• 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

Aruba Cloud PRO i VPS, Openstack, VMWare, MS Hyper-V
0 głosów
87 wizyt
pytanie zadane 9 stycznia 2020 w Python przez Dawid89 Obywatel (1,010 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ź 149 wizyt
pytanie zadane 7 września 2019 w Python przez Ziito Obywatel (1,110 p.)
0 głosów
1 odpowiedź 79 wizyt
pytanie zadane 23 września 2019 w Python przez Dawid89 Obywatel (1,010 p.)
0 głosów
1 odpowiedź 445 wizyt

90,319 zapytań

138,924 odpowiedzi

311,159 komentarzy

60,027 pasjonatów

Motyw:

Akcja Pajacyk

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

Sklep oferujący ćwiczenia JavaScript, PHP, rozmowy rekrutacyjne dla programistów i inne materiały

Oto dwie polecane książki warte uwagi. Pełną listę znajdziesz tutaj.

...