RxPY - przegląd
W tym rozdziale wyjaśniono, czym jest programowanie reaktywne, czym jest RxPY, jego operatory, cechy, zalety i wady.
Co to jest programowanie reaktywne?
Programowanie reaktywne to paradygmat programowania, który zajmuje się przepływem danych i propagacją zmian. Oznacza to, że gdy przepływ danych jest emitowany przez jeden komponent, zmiana będzie propagowana do innych komponentów przez bibliotekę programowania reaktywnego. Propagacja zmiany będzie kontynuowana, aż dotrze do ostatecznego odbiorcy.
Korzystając z RxPY, masz dobrą kontrolę nad asynchronicznymi strumieniami danych, na przykład żądanie skierowane do adresu URL może być śledzone za pomocą obserwowalnego i używać obserwatora do nasłuchiwania, kiedy żądanie jest kompletne, w celu uzyskania odpowiedzi lub błędu.
RxPY oferuje obsługę asynchronicznych strumieni danych przy użyciu Observables, odpytuj strumienie danych za pomocą Operators tj. filtruj, sumuj, konkatuj, mapuj, a także wykorzystuj współbieżność dla strumieni danych za pomocą Schedulers. Utworzenie Observable, daje obiekt obserwatora z metodami on_next (v), on_error (e) i on_completed (), które muszą byćsubscribed abyśmy otrzymali powiadomienie o wystąpieniu zdarzenia.
Do Observable można zapytać przy użyciu wielu operatorów w formacie łańcucha, używając operatora potoku.
RxPY oferuje operatorów w różnych kategoriach, takich jak: -
Operatory matematyczne
Operatory transformacji
Operatory filtrujące
Operatory obsługi błędów
Operatorzy mediów
Operatory warunkowe
Operatory tworzenia
Operatorzy z możliwością podłączenia
Te operatory są szczegółowo wyjaśnione w tym samouczku.
Co to jest RxPy?
RxPY jest zdefiniowany jako a library for composing asynchronous and event-based programs using observable collections and pipable query operators in Python zgodnie z oficjalną stroną RxPy, czyli https://rxpy.readthedocs.io/en/latest/.
RxPY to biblioteka Pythona obsługująca programowanie reaktywne. RxPy oznaczaReactive Extensions for Python. Jest to biblioteka, która używa obserwabli do pracy z programowaniem reaktywnym, które obsługuje asynchroniczne wywołania danych, wywołania zwrotne i programy oparte na zdarzeniach.
Funkcje RxPy
W RxPy następujące koncepcje zajmują się obsługą zadania asynchronicznego -
Zauważalny
Obserwowalna to funkcja, która tworzy obserwatora i dołącza go do źródła zawierającego strumienie danych, których oczekuje się na przykład z tweetów, zdarzeń związanych z komputerem itp.
Obserwator
Jest to obiekt z metodami on_next (), on_error () i on_completed (), który zostanie wywołany, gdy nastąpi interakcja z obserwowalnym, tj. Źródło współdziała z przykładowymi przychodzącymi tweetami itp.
Subskrypcja
Kiedy to, co obserwowalne jest tworzone, aby wykonać to, co obserwowalne, musimy je zapisać.
Operatorzy
Operator jest czystą funkcją, która przyjmuje obserwowalne jako dane wejściowe, a wyjście jest również obserwowalne. Możesz użyć wielu operatorów na obserwowalnych danych, używając operatora potoku.
Przedmiot
Podmiot jest obserwowalną sekwencją, a także obserwatorem, który może przesyłać multiemisją, tj. Rozmawiać z wieloma obserwatorami, którzy się subskrybowali. Temat jest zimny, obserwowalny, tj. Wartości zostaną podzielone między subskrybowanych obserwatorów.
Harmonogramy
Jedną z ważnych cech RxPy jest współbieżność, tj. Umożliwienie równoległego wykonywania zadania. Aby tak się stało, RxPy ma dwa operatory subscribe_on () i observ_on (), które współpracują z programami planującymi i decydują o wykonaniu zasubskrybowanego zadania.
Zalety korzystania z RxPY
Oto zalety RxPy -
RxPY to niesamowita biblioteka, jeśli chodzi o obsługę strumieni danych i zdarzeń asynchronicznych. RxPY używa obserwabli do pracy z programowaniem reaktywnym, które obsługuje asynchroniczne wywołania danych, wywołania zwrotne i programy oparte na zdarzeniach.
RxPY oferuje ogromną kolekcję operatorów w matematyce, transformacji, filtrowaniu, użyteczności, warunkowej, obsłudze błędów, łączeniu kategorii, które ułatwiają życie w programowaniu reaktywnym.
Współbieżność, tj. Jednoczesna praca wielu zadań, jest osiągana za pomocą harmonogramów w RxPY.
Wydajność jest lepsza przy użyciu RxPY, ponieważ obsługa zadania asynchronicznego i przetwarzanie równoległe są łatwe.
Wada korzystania z RxPY
Debugowanie kodu za pomocą obserwabli jest trochę trudne.