Strumień Kafka IoT przetwarza średnio ~5000 wiadomości/s. Utwórz alert, gdy tylko 1-godzinna średnia krocząca spadnie poniżej 4000 wiadomości/s. Co należy zaimplementować?
Wybierz odpowiedź
Dotknij opcji, aby sprawdzić swoją odpowiedź.
Poprawna odpowiedź: Użyj Dataflow z Kafka IO, przesuwnego 1-godzinnego okna co 5 minut, oblicz średnią przy każdym przesunięciu i wyślij alert, jeśli <4000.
Dlaczego to jest odpowiedź
Prawidłowa odpowiedź wykorzystuje Dataflow z Kafka IO i przesuwne okno (sliding window). Przesuwne okno o długości 1 godziny, przesuwające się co 5 minut, pozwala na ciągłe monitorowanie średniej przepustowości w ostatniej godzinie. Obliczenie średniej przy każdym przesunięciu i natychmiastowe wysłanie alertu, gdy spadnie poniżej 4000 wiadomości/s, zapewnia szybką reakcję na problem. Stałe okno (fixed window) nie nadaje się, ponieważ alert byłby generowany tylko raz na godzinę, co jest zbyt wolne. Rozwiązania z Kafka Connect, Pub/Sub, Bigtable/BigQuery i Cloud Scheduler są zbyt złożone i wprowadzają niepotrzebne opóźnienia, ponieważ wymagają zapisywania danych i cyklicznego ich odpytywania, zamiast przetwarzania strumieniowego w czasie rzeczywistym.
Zdaj egzamin — bez niekończącego się szukania odpowiedzi
Uzyskaj wszystkie zweryfikowane pytania i wyjaśnienia do tego egzaminu w jednym miejscu i zaoszczędź godziny przygotowań. Ponad 1000 certyfikacji · Ponad 20 języków · Zacznij za darmo.
Zdaj egzamin szybciej → Karta nie jest wymagana