Przetwarzanie komunikatów w rozwiązaniu IoT

W tym omówieniu przedstawiono kluczowe pojęcia dotyczące przetwarzania komunikatów wysyłanych z urządzeń w typowym rozwiązaniu usługi Azure IoT. Każda sekcja zawiera linki do zawartości, która zawiera szczegółowe informacje i wskazówki.

Na poniższym diagramie przedstawiono ogólny widok składników w typowym rozwiązaniu IoT. Ten artykuł koncentruje się na składnikach przetwarzania komunikatów rozwiązania IoT.

Diagram that shows the high-level IoT solution architecture highlighting message processing areas.

W usłudze Azure IoT przetwarzanie komunikatów odnosi się do procesów, takich jak routing i wzbogacanie komunikatów telemetrycznych wysyłanych przez urządzenia. Te procesy służą do kontrolowania przepływu komunikatów za pośrednictwem rozwiązania IoT i dodawania dodatkowych informacji do komunikatów.

Kierowanie komunikatów

Centrum IoT udostępnia punkt wejścia w chmurze dla komunikatów telemetrycznych wysyłanych przez urządzenia. W typowym rozwiązaniu IoT te komunikaty są dostarczane do innych usług podrzędnych na potrzeby magazynowania lub analizy.

Routing usługi IoT Hub

W usłudze IoT Hub można skonfigurować routing w celu dostarczania komunikatów telemetrycznych do wybranego miejsca docelowego. Miejsca docelowe obejmują:

  • Kontenery magazynu
  • Kolejki usługi Service Bus
  • Tematy usługi Service Bus
  • Event Hubs

Każde centrum IoT ma domyślne miejsce docelowe nazywane wbudowanym punktem końcowym. Usługi podrzędne mogą łączyć się z wbudowanym punktem końcowym w celu odbierania komunikatów z centrum IoT.

Aby dowiedzieć się więcej, zobacz Wysyłanie komunikatów z urządzenia do chmury do różnych punktów końcowych przy użyciu routingu komunikatów usługi IoT Hub.

Zapytania umożliwiają filtrowanie komunikatów wysyłanych do różnych miejsc docelowych.

Routing usługi IoT Central

Jeśli używasz usługi IoT Central, możesz użyć eksportu danych do wysyłania komunikatów telemetrycznych do innych usług podrzędnych. Miejsca docelowe obejmują:

  • Kontenery magazynu
  • Kolejki usługi Service Bus
  • Tematy usługi Service Bus
  • Event Hubs
  • Azure Data Explorer
  • Elementy webhook

Konfiguracja eksportu danych usługi IoT Central umożliwia filtrowanie komunikatów wysyłanych do miejsca docelowego.

Aby dowiedzieć się więcej, zobacz Eksportowanie danych z usługi IoT Central.

Event Grid

Usługa IoT Hub ma wbudowaną integrację z usługą Azure Event Grid. Centrum IoT może publikować zdarzenie za każdym razem, gdy odbiera komunikat telemetrii z urządzenia. Za pomocą usługi Event Grid można kierować te zdarzenia do innych usług.

Aby dowiedzieć się więcej, zobacz React to IoT Hub events by using Event Grid to trigger actions (Reagowanie na zdarzenia za pomocą usługi Event Grid w celu wyzwalania akcji) i Compare message routing and Event Grid for IoT Hub (Porównanie routingu komunikatów i usługi Event Grid dla usługi IoT Hub).

Wzbogacanie lub przekształcanie komunikatów

Aby uprościć przetwarzanie podrzędne, możesz dodać dane do komunikatów telemetrycznych lub zmodyfikować ich strukturę.

Wzbogacanie komunikatów usługi IoT Hub

Wzbogacanie komunikatów usługi IoT Hub umożliwia dodawanie danych do komunikatów wysyłanych przez urządzenia. Możesz dodać:

  • Ciąg statyczny
  • Nazwa centrum IoT Hub przetwarza komunikat
  • Informacje z bliźniaczej reprezentacji urządzenia

Aby dowiedzieć się więcej, zobacz Wzbogacanie komunikatów dotyczących komunikatów usługi IoT Hub z urządzenia do chmury.

Przekształcenia komunikatów usługi IoT Central

Usługa IoT Central oferuje dwie opcje przekształcania komunikatów telemetrycznych:

  • Użyj mapowań , aby przekształcić złożone dane telemetryczne urządzenia w dane strukturalne na ruch przychodzący do usługi IoT Central.
  • Użyj przekształceń , aby manipulować formatem i strukturą danych urządzenia przed wyeksportowanie ich do miejsca docelowego.

Przetwarzanie komunikatów na brzegu

Moduł usługi Azure IoT Edge może przetwarzać dane telemetryczne z dołączonego czujnika lub urządzenia, zanim wyśle je do centrum IoT. Na przykład przed wysłaniem danych do chmury moduł usługi IoT Edge może:

Inne usługi w chmurze

Inne usługi platformy Azure umożliwiają przetwarzanie komunikatów telemetrycznych z urządzeń. Zarówno usługa IoT Hub, jak i usługa IoT Central mogą kierować komunikaty do innych usług. Można na przykład przekazywać komunikaty telemetryczne do:

Usługa Azure Stream Analytics to zarządzany aparat przetwarzania strumieniowego, który jest przeznaczony do analizowania i przetwarzania dużych ilości danych przesyłanych strumieniowo. Usługa Stream Analytics może identyfikować wzorce w danych, a następnie wyzwalać akcje, takie jak tworzenie alertów, wysyłanie informacji do narzędzia raportowania lub przechowywanie przekształconych danych. Usługa Stream Analytics jest również dostępna w środowisku uruchomieniowym usługi Azure IoT Edge, umożliwiając jej przetwarzanie danych na brzegu sieci, a nie w chmurze.

Azure Functions to bezserwerowa usługa obliczeniowa, która umożliwia uruchamianie kodu w odpowiedzi na zdarzenia. Za pomocą usługi Azure Functions można przetwarzać komunikaty telemetryczne z urządzeń.

Aby dowiedzieć się więcej, zobacz:

Następne kroki

Po wyświetleniu przeglądu zarządzania urządzeniami i kontroli w rozwiązaniach usługi Azure IoT niektóre sugerowane następne kroki obejmują: