Typowe przypadki użycia i wzorce dotyczące grafów przepływu danych

Wybierz wzór na podstawie dostępnych danych wejściowych i potrzebnych wyników. Wszystkie przykładowe wartości są syntetyczne.

Goal Operation Implementation
Dodaj kontekst do odczytów Sprawdź najnowszy rekord według ID aktywa Wbudowane wzbogacanie; aplikacja utrzymuje magazyn stanu
Wyrównaj i skoreluj rekordy Dopasuj odczyty według znacznika czasu lub identyfikatora elementu Niestandardowa próbka z zachowaniem stanu lub usługa zewnętrzna
Redukcja szumu Uśrednij partię bez nakładania się Wbudowane okno tumbling
Odczyty tras według ważności Filtruj niemożliwe odczyty i kieruj według poważności Wbudowany filtr, rozgałęzienie, mapowanie i łączenie
Kierowanie więcej niż dwoma rodzajami wiadomości Wybierz ścieżkę dla każdego rodzaju wiadomości, a następnie połącz ścieżki Wbudowana gałąź i konkatenacja
Przekieruj nieprawidłowe wiadomości do kolejki wiadomości niedostarczonych Oddzielne odrzucone payloady zachowywane przez konsumenta Wbudowana gałąź, mapowanie i konkatenacja
Prognozowanie i aktualizacje Oceń model, zarządzaj jego parametrami lub dostarcz aktualizację Wybierz niezależny schemat poniżej

Predykcja modelu i aktualizacje

Wybierz niezależny schemat do przewidywania, dopasowania lub dostarczania. Łącz je w razie potrzeby.

Wzór Użyj, gdy
Oblicz prognozę przy znanych współczynnikach Musisz ocenić istniejącą formułę, używając parametrów w wiadomości lub pobranych przez enrichment
Zamontuj i aktywuj zatwierdzony model Twoja aplikacja musi dopasować i zatwierdzić nowe parametry, a następnie trwale zapisać pełny rekord aktywnego modelu
Dostarczaj zatwierdzone aktualizacje modeli za pośrednictwem MQTT Musisz przesłać zatwierdzone współczynniki do niestandardowego predyktora do późniejszych odczytów

Prerequisites

Zacznij od istniejącego wdrożenia Operacje Azure IoT, profilu przepływu danych oraz punktu końcowego MQTT z dostępem brokera. Wykonaj instrukcje w Utwórz wykres przepływu danych, aby je skonfigurować.

Przykłady wykorzystują profil default i punkt końcowy MQTT factory-mqtt w przestrzeni azure-iot-operations nazw. Wbudowane transformacje wykorzystują punkt końcowy default rejestru.

Dla niestandardowych wzorców użyj gotowych do zastosowania manifestów lub wykresu Helm w instrukcjach wdrożenia Azure Samples, w tym konfiguracji rejestru i wdrażania pojedynczej instancji. Aby sprawdzić brak danych z czujników, skonfiguruj publisher zegara względem obecnego brokera.