django-parallelized_querysets

Django-parallelized_querysets je aplikace Django pro zpracování velkých Django QuerySets šířením jejich plnění na více jader a udržování využití paměti minima.
Instalace
Pip nainstalovat Django-parallelized_querysets
Použít
parallelized_queryset (queryset, procesy = None, funkce = None)
Zpracovat danou queryset a vrátí výsledek jako seznam.
procesy
Počet procesů vytvořit. Výchozí nastavení počtu vrácených multiprocessing.cpu_count ().
funkce
Aplikovat funkci na každý výsledek. Neplatí žádnou funkci ve výchozím nastavení. První argument je proces, který je volat to, a druhý je řada.
Můžete také předat dva háčky (funkce, které budou provedeny v procesu určených časech):
init_hook
Dejte mu funkci, při níž proces jako argument a bude provedena v okamžiku, kdy je vytvořil.
end_hook
Dejte mu funkci, při níž proces jako argument a bude provádět přímo před procesem východy. Pokud se vrátí non-Žádné hodnoty, budou přidány do výsledků fronty.
& Nbsp; Note
& Nbsp; Pokaždé, když funkce vrací None, hodnota nebude ve výsledném seznamu.
& Nbsp; Note
& Nbsp; pořadí v QuerySet nebude brán zřetel!
Příklad
Vrátit všechny článek objekty:
>>> Z parallelized_querysets import parallelized_queryset
>>> Qs = Article.objects.all ()
>>> parallelized_queryset (qs)
Přidejte všechny Článek objekty s indexem REDIS (za předpokladu, že článek má metodu append_to_redis):
>>> Z parallelized_querysets import parallelized_queryset
>>> Qs = Article.objects.all ()
>>> Parallelized_queryset (qs, funkce = lambda p, x: x.append_to_redis ())
Do stejné, ale na 6 procesy:
>>> Z parallelized_querysets import parallelized_queryset
>>> Qs = Article.objects.all ()
>>> parallelized_queryset (qs, procesy = 6,
& Nbsp; funkce = lambda p, x: x.append_to_redis ())
parallelized_multiple_querysets (querysets, procesy = None, funkce = None)
. Stejně jako parallelized_queryset ale querysets je seznam QuerySets

Požadavky na :

• Python
• Django