RxPY - Genel Bakış
Bu bölüm reaktif programlamanın ne olduğunu, RxPY'nin ne olduğunu, operatörlerini, özelliklerini, avantajlarını ve dezavantajlarını açıklamaktadır.
Reaktif Programlama nedir?
Reaktif programlama, veri akışı ve değişimin yayılmasıyla ilgilenen bir programlama paradigmasıdır. Bu, bir bileşen tarafından bir veri akışı yayınlandığında, değişikliğin reaktif bir programlama kitaplığı tarafından diğer bileşenlere yayılacağı anlamına gelir. Değişimin yayılması, nihai alıcıya ulaşana kadar devam edecektir.
RxPY'yi kullanarak, eşzamansız veri akışları üzerinde iyi bir kontrole sahip olursunuz, örneğin, URL'ye yapılan bir istek gözlemlenebilir kullanılarak izlenebilir ve yanıt veya hata için istek tamamlandığında dinlemek için gözlemciyi kullanabilirsiniz.
RxPY, asenkron veri akışlarını kullanarak Observables, kullanarak veri akışlarını sorgulayın Operators yani filtre, toplama, birleştirme, eşleme ve aynı zamanda veri akışları için eşzamanlılık kullanma Schedulers. Bir Gözlemlenebilir oluşturma, olması gereken on_next (v), on_error (e) ve on_completed () yöntemleriyle bir gözlemci nesnesi verir.subscribed Böylece bir olay meydana geldiğinde bildirim alırız.
Gözlemlenebilir, boru operatörü kullanılarak bir zincir formatında birden fazla operatör kullanılarak sorgulanabilir.
RxPY, aşağıdakiler gibi çeşitli kategorilerde operatörler sunar: -
Matematiksel operatörler
Dönüşüm operatörleri
Filtreleme operatörleri
Hata işleme operatörleri
Kamu hizmeti operatörleri
Koşullu operatörler
Oluşturma operatörleri
Bağlanabilir operatörler
Bu operatörler, bu eğitimde ayrıntılı olarak açıklanmıştır.
RxPy nedir?
RxPY şu şekilde tanımlanır: a library for composing asynchronous and event-based programs using observable collections and pipable query operators in Python RxPy'nin resmi web sitesine göre, https://rxpy.readthedocs.io/en/latest/.
RxPY, Reaktif Programlamayı destekleyen bir python kitaplığıdır. RxPy,Reactive Extensions for Python. Eşzamansız veri aramaları, geri aramalar ve olay tabanlı programlarla ilgilenen reaktif programlama ile çalışmak için gözlemlenebilirleri kullanan bir kitaplıktır.
RxPy'nin Özellikleri
RxPy'de, aşağıdaki kavramlar eşzamansız görevin üstesinden gelir -
Gözlenebilir
Gözlenebilir, bir gözlemci yaratan ve onu, örneğin Tweetler, bilgisayarla ilgili olaylar vb. Gibi beklenen veri akışlarına sahip kaynağa ekleyen bir işlevdir.
Gözlemci
On_next (), on_error () ve on_completed () yöntemlerine sahip bir nesnedir, gözlemlenebilir ile etkileşim olduğunda yani kaynak bir örnek gelen Tweet için etkileşime girdiğinde çağrılır.
Abonelik
Gözlenebilir olan yaratıldığında, gözlemlenebilir olanı yürütmek için ona abone olmamız gerekir.
Operatörler
Operatör, girdi olarak gözlemlenebilir olan saf bir fonksiyondur ve çıktı da gözlemlenebilirdir. Boru operatörünü kullanarak gözlemlenebilir bir veri üzerinde birden fazla operatör kullanabilirsiniz.
Konu
Bir özne, gözlemlenebilir bir dizinin yanı sıra çok noktaya yayın yapabilen bir gözlemcidir, yani abone olan birçok gözlemciyle konuşur. Konu soğuk gözlemlenebilir, yani değerler abone olmuş gözlemciler arasında paylaşılacaktır.
Zamanlayıcılar
RxPy'nin önemli bir özelliği eşzamanlılıktır, yani görevin paralel olarak yürütülmesine izin vermek. Bunu gerçekleştirmek için RxPy'nin zamanlayıcılarla çalışan ve abone olunan görevin yürütülmesine karar verecek olan subscribe_on () ve observe_on () adlı iki operatörü vardır.
RxPY kullanmanın avantajları
Aşağıdakiler RxPy'nin avantajlarıdır -
Eşzamansız veri akışlarının ve olaylarının işlenmesi söz konusu olduğunda RxPY harika bir kitaplıktır. RxPY, eşzamansız veri aramaları, geri aramalar ve olay tabanlı programlarla ilgilenen reaktif programlama ile çalışmak için gözlemlenebilirleri kullanır.
RxPY, reaktif programlama ile kullanıldığında hayatı kolaylaştıran matematiksel, dönüşüm, filtreleme, yardımcı program, koşullu, hata işleme, birleştirme kategorilerinde çok sayıda operatör koleksiyonu sunar.
Eşzamanlılık, yani birden fazla görevin birlikte çalışması, RxPY'deki zamanlayıcılar kullanılarak gerçekleştirilir.
Eşzamansız görevin yürütülmesi ve paralel işlemin kolaylaştırılması nedeniyle performans RxPY kullanılarak geliştirildi.
RxPY kullanmanın dezavantajı
Gözlenebilirlerle kodda hata ayıklamak biraz zordur.