Django-parallelized_querysets çoklu çekirdek kendi yürütülmesine yaymak ve bellek kullanımı düşük tutarak büyük Django QuerySets işlemek için Django uygulaması.
Kurulum
Django-parallelized_querysets yüklemek pip
Kullanım
parallelized_queryset (QuerySet, süreçler = Yok, fonksiyon = Yoktur)
Verilen QuerySet Süreç ve bir liste olarak sonuç döndürür.
Süreçler
Süreçlerin sayısı oluşturmak için. Multiprocessing.cpu_count tarafından döndürülen numaraya Varsayılanları ().
işlev
Bir fonksiyonu her sonuç uygulayın. Varsayılan olarak herhangi bir işlev geçerli değildir. İlk argüman olarak çağırıyor Süreci ve ikinci satır olduğunu.
Ayrıca (tanımlanmış zamanlarda işlem tarafından yürütülür fonksiyonu) iki kanca geçirebilirsiniz:
init_hook
O argüman olarak Süreci alarak bir işlev vermek ve en kısa sürede o yarattı olarak yürütülür.
end_hook
O argüman olarak Süreci alarak bir işlev vermek ve Süreç çıkmadan önce sağ yürütmek olacak. Olmayan bir Yok değerini döndürürse, bu sonuçlar kuyruğuna eklenecektir.
& Nbsp; Not
& Nbsp; işlev Yoktur döndüren her zaman, değer ortaya çıkan listede olmayacak.
& Nbsp; Not
& Nbsp; QuerySet sipariş saygı olmayacak!
Örnek
Tüm Makale nesneleri Dönüş:
>>> Parallelized_querysets ithalat parallelized_queryset gelen
>>> Qs = Article.objects.all ()
>>> Parallelized_queryset (qs)
Bir Redis indeksine tüm Makale nesneleri (varsayarak Madde bir append_to_redis yöntemi vardır) ekleyin:
>>> Parallelized_querysets ithalat parallelized_queryset gelen
>>> Qs = Article.objects.all ()
>>> Parallelized_queryset (qs, fonksiyon = lambda p, x: x.append_to_redis ())
Aynı ancak 6 süreçleri yapın:
>>> Parallelized_querysets ithalat parallelized_queryset gelen
>>> Qs = Article.objects.all ()
>>> Parallelized_queryset (qs, süreçler = 6,
& Nbsp; fonksiyonu = lambda p, x: x.append_to_redis ())
parallelized_multiple_querysets (querysets, süreçler = Yok, fonksiyon = Yoktur)
. Parallelized_queryset ama querysets aynı QuerySets listesi
Gereksinimler :
- Python
- Django
Yorum Bulunamadı