Jak połączyć wiele strumieni w regule aktywatora

W tym artykule pokazano, jak wykonać następujące działania:

  • Monitorowanie danych z wielu strumieni zdarzeń i automatyzowanie akcji przez zdefiniowanie reguły aktywatora
  • Skonfiguruj wiele zaawansowanych warunków, takich jak średnia, maksymalna lub minimalna wartość właściwości danych, przy użyciu możliwości modelowania aktywatora.

Scenario

W tym przykładzie można śledzić kondycję pomp wodnych (maszyn) przez monitorowanie przepływów i drgań maszyny. Celem jest automatyczne podejmowanie działań, takich jak wysyłanie alertu lub uruchamianie procesu biznesowego, jeśli drgania są nietypowe, gdy maszyna jest uruchomiona i przenosi znaczną ilość wody (FlowRate). Drgania pompy wysokociśnieniowej mogą sygnalizować podstawowe problemy; jednak oczekuje się ich, jeżeli parametr FlowRate jest nieistotny.

Maszyny monitorują dane, które są przesyłane do dwóch strumieni zdarzeń.

  • MachineHeartbeat eventstream zawiera kolumnę MachineNumber identyfikującą maszynę i kolumnę MachineRunning , która wskazuje, czy maszyna jest uruchomiona (1) lub nie (0). Zdarzenie jest emitowane za każdym razem, gdy zmienia się stan maszyny.
  • MachineSensorsReadings eventstream zawiera kolumnę MachineId wraz z kolumnami FlowRate i Vibration . Każda maszyna emituje odczyty czujników co kilka sekund.

Zwróć uwagę, że dwa strumienie zdarzeń identyfikują maszynę za pomocą różnych kolumn: MachineId w MachineSensorsReadings i MachineNumber w MachineHeartbeat. Obie kolumny przechowują te same wartości identyfikatora komputera.

W tym scenariuszu chcesz zgłosić alert, gdy wszystkie te warunki są spełnione:

  • Maksymalna liczba drgań w ciągu ostatnich 1 godziny zwiększa się powyżej 18.
  • Średnia szybkość przepływu w ciągu ostatnich 10 minut wynosi powyżej 185.
  • Maszyna jest uruchomiona.

Reguły aktywatora obsługują złożone warunki bazujące na licznych strumieniach zdarzeń. Możesz tworzyć właściwości obliczone na podstawie kolumn zdarzeń i połączyć je razem w warunku reguły.

W tym scenariuszu połączysz dwa strumienie zdarzeń, tworząc obiekt, który czerpie dane z obu strumieni. Po dodaniu strumienia zdarzeń do obiektu należy określić, która kolumna w zdarzeniach jednoznacznie identyfikuje wystąpienie obiektu.

Note

Activator obsługuje łączenie strumieni zdarzeń, które identyfikują ten sam obiekt przy użyciu różnych kolumn z unikatowymi identyfikatorami. W tym scenariuszu MachineSensorsReadings używa MachineId, a MachineHeartbeat używa MachineNumber, a Activator łączy je w pojedynczy obiekt.

Następnie utworzysz właściwość, która oblicza wartość average (FlowRate), drugą dla parametru max(Vibration) i połączysz ją z właściwością IsRunning . Podczas oceniania reguły funkcja Aktywator oblicza wartości właściwości zgodnie z ich definicjami i utrzymuje ostatnią obliczoną wartość każdej właściwości. Te wartości są używane podczas oceniania warunku.

W regułach aktywatora należy ustawić jeden warunek, taki jak max(Vibration) 18, i dodać opcjonalne filtry, takie jak avg(FlowRate) >> 185 i MachineRunning. Reguła jest uruchamiana po spełnieniu warunku, pod warunkiem, że filtry są również prawdziwe.

Warunek napędza regułę, jak pokazano na poniższej ilustracji:

Zrzut ekranu przedstawiający diagram pokazujący, jak warunek wpływa na regułę w Activator z filtrami i akcjami.

Rozwiązanie

  1. Dodaj miejsce docelowe Aktywatora do obu strumieni zdarzeń. Upewnij się, że oba strumienie zdarzeń używają tego samego wystąpienia Aktywatora.

    Zrzut ekranu przedstawiający strumień zdarzeń MachineHeartbeat z dodanym miejscem docelowym aktywatora.

    Zrzut ekranu przedstawiający strumień zdarzeń MachineSensorsReadings z dodanym miejscem docelowym aktywatora.

    Oba strumienie zdarzeń są konfigurowane przy użyciu tego samego miejsca docelowego aktywatora:

    Zrzut ekranu przedstawiający oba strumienie zdarzeń skonfigurowane z tym samym miejscem docelowym aktywatora.

  2. Otwórz element aktywatora. Teraz możesz połączyć obie strumienie zdarzeń w obiekcie i skonfigurować regułę.

    Zrzut ekranu elementu Aktywator pokazujący dwa strumienie zdarzeń dostępne do połączenia.

  3. Aby połączyć te dwa strumienie, wybierz dowolny strumień i wybierz pozycję Nowy obiekt.

    Zrzut ekranu przedstawiający wybieranie strumienia zdarzeń i kliknięcie przycisku Nowy obiekt.

  4. Wybierz nazwę kolumny używaną do identyfikowania wystąpienia obiektu i kolumn, które są wymagane dla reguły, a następnie wybierz pozycję Utwórz. Wartość kolumny MachineId w każdym zdarzeniu jest kluczem identyfikującym maszynę, która wyemitowała to zdarzenie.

    Zrzut ekranu przedstawiający panel obiektu kompilacji, w którym wybrano MachineId jako unikatowy identyfikator oraz odpowiednie kolumny.

  5. Wybierz inny strumień zdarzeń, wybierz pozycję Nowy obiekt, a następnie wybierz pozycję Dodaj do istniejącego obiektu w okienku Obiekt kompilacji . Wybierz kolumnę MachineNumber jako unikatowy identyfikator. Wybierz Przypisz. Teraz dwa strumienie są łączone w jednym obiekcie, mimo że każdy strumień używa innej kolumny identyfikatora.

    Zrzut ekranu przedstawiający panel Build object z zaznaczoną opcją Add to existing object oraz elementem MachineNumber jako unikatowym identyfikatorem.

  6. Teraz możesz zdefiniować obliczoną właściwość. Utwórz atrybut do obliczania średniej flowRate w ciągu ostatnich 10 minut. Wybierz atrybut FlowRate i wybierz Edytuj szczegóły.

    Zrzut ekranu przedstawiający wybieranie atrybutu FlowRate i kliknięcie pozycji Edytuj szczegóły.

  7. W okienku Definicja wybierz pozycję Dodaj podsumowanie, wybierz pozycję Średnia i ustaw 10 minut jako rozmiar okna. Wybierz Zapisz.

    Zrzut ekranu przedstawiający okienko Definicja z wybraną opcją Dodaj podsumowanie i wybraną pozycją Średnia.

    Zrzut ekranu przedstawiający uśrednianie skonfigurowane z 10-minutowym oknem czasowym.

  8. Wybierz pozycję Vibration attribute ( Atrybut drgań ) i wybierz pozycję Edit details (Edytuj szczegóły). W okienku Definicja wybierz pozycję Dodaj podsumowanie, wybierz pozycję Maksimum i ustaw 1 godzinę jako rozmiar okna. Wybierz Zapisz.

    Zrzut ekranu przedstawiający atrybut Vibration z maksymalnym podsumowaniem skonfigurowanym dla okna czasowego o długości jednej godziny.

  9. Teraz utwórz regułę. Wybierz właściwość Vibration i wybierz pozycję Nowa reguła.

    Zrzut ekranu przedstawiający wybieranie właściwości Vibration i kliknięcie przycisku Nowa reguła.

  10. W okienku Definicja skonfiguruj warunek Wzrost powyżej z progiem 18.

    Zrzut ekranu przedstawiający okienko Definicja z ustawionym warunkiem

  11. Dodaj filtr dla właściwości FlowRate i jeden dla właściwości MachineRunning .

    Zrzut ekranu reguły z filtrami dodanymi dla właściwości FlowRate i MachineRunning.

  12. Wybierz akcję, na przykład wysyłanie wiadomości e-mail, lub wiadomości w usłudze Teams, uruchamianie procesu biznesowego, takiego jak potok, notes lub funkcje, lub uruchamianie niestandardowej akcji bez pisania kodu za pomocą usługi Power Automate. Wybierz pozycję Zapisz i uruchom.

    Zrzut ekranu przedstawiający stronę wyboru akcji z opcjami wysyłania powiadomień lub uruchamiania procesów biznesowych.

Następny krok

Aby dowiedzieć się więcej o regułach aktywowania, zobacz Tworzenie reguł aktywatora i zarządzanie nimi.

  • Ostatnia aktualizacja o