Przetwarzanie danych z centrum zdarzeń przy użyciu usługi Azure Stream Analytics

Usługa Azure Stream Analytics ułatwia pozyskiwanie, przetwarzanie i analizowanie danych przesyłanych strumieniowo z Azure Event Hubs, co umożliwia uzyskiwanie zaawansowanych szczegółowych informacji w celu kierowania akcjami w czasie rzeczywistym. Za pomocą Azure Portal można wizualizować dane przychodzące i zapisywać zapytanie usługi Stream Analytics. Gdy zapytanie będzie gotowe, możesz przenieść je do środowiska produkcyjnego za pomocą zaledwie kilku kliknięć.

Najważniejsze korzyści

Poniżej przedstawiono najważniejsze korzyści wynikające z integracji Azure Event Hubs i usługi Azure Stream Analytics:

• Podgląd danych — możesz wyświetlić podgląd danych przychodzących z centrum zdarzeń w Azure Portal.
• Przetestuj zapytanie — przygotuj zapytanie przekształcenia i przetestuj je bezpośrednio w Azure Portal. Składnia języka zapytań można znaleźć w dokumentacji języka zapytań usługi Stream Analytics .
• Wdrażanie zapytania w środowisku produkcyjnym — zapytanie można wdrożyć w środowisku produkcyjnym, tworząc i uruchamiając zadanie usługi Azure Stream Analytics.

Pełny przepływ

Ważne

Jeśli nie jesteś członkiem ról właściciela lub współautora na poziomie subskrypcji platformy Azure, musisz być członkiem roli testera zapytań usługi Stream Analytics na poziomie subskrypcji platformy Azure, aby pomyślnie wykonać kroki opisane w tej sekcji. Ta rola umożliwia wykonywanie zapytań testowych bez uprzedniego utworzenia zadania usługi Stream Analytics. Aby uzyskać instrukcje dotyczące przypisywania roli do użytkownika, zobacz Przypisywanie ról usługi AD do użytkowników.

1. Zaloguj się w witrynie Azure Portal.

2. Przejdź do przestrzeni nazw usługi Event Hubs , a następnie przejdź do centrum zdarzeń zawierającego dane przychodzące.

3. Wybierz pozycję Przetwarzanie danych na stronie centrum zdarzeń lub wybierz pozycję Przetwarzanie danych w menu po lewej stronie.

   

4. Wybierz pozycję Rozpocznij na kafelku Włącz szczegółowe informacje w czasie rzeczywistym na podstawie zdarzeń .

   

5. Zostanie wyświetlona strona zapytania z wartościami już ustawionymi dla następujących pól:

   1. Centrum zdarzeń jako dane wejściowe zapytania.

   2. Przykładowe zapytanie SQL z instrukcją SELECT.

   3. Alias danych wyjściowych odwołujący się do wyników testu zapytania.

      

      Uwaga

      Gdy używasz tej funkcji po raz pierwszy, na tej stronie zostanie wyświetlona prośba o zgodę na utworzenie grupy odbiorców i zasad dotyczących centrum zdarzeń w celu wyświetlenia podglądu danych przychodzących.

6. Wybierz pozycję Utwórz w okienku Podgląd danych wejściowych , jak pokazano na powyższym obrazie.

7. Na tej karcie natychmiast zostanie wyświetlona migawka najnowszych danych przychodzących.

   • Typ serializacji w danych jest automatycznie wykrywany (JSON/CSV). Można ją również ręcznie zmienić na format JSON/CSV/AVRO.

   • Podgląd danych przychodzących można wyświetlić w formacie tabeli lub formacie nieprzetworzonym.

   • Jeśli wyświetlane dane nie są aktualne, wybierz pozycję Odśwież , aby wyświetlić najnowsze zdarzenia.

     Oto przykład danych w formacie tabeli:

     

     Oto przykład danych w formacie nieprzetworzonym:

     

8. Wybierz pozycję Zapytanie testowe , aby wyświetlić migawkę wyników testu zapytania na karcie Wyniki testu . Możesz również pobrać wyniki.

   

9. Napisz własne zapytanie, aby przekształcić dane. Zobacz Dokumentacja języka zapytań usługi Stream Analytics.

10. Po przetestowaniu zapytania i przeniesieniu go do środowiska produkcyjnego wybierz pozycję Utwórz zadanie usługi Stream Analytics.

    

11. Na stronie Nowe zadanie usługi Stream Analytics wykonaj następujące kroki:

    1. Określ nazwę zadania.

    2. Wybierz subskrypcję platformy Azure , w której chcesz utworzyć zadanie.

    3. Wybierz grupę zasobów dla zasobu zadania usługi Stream Analytics.

    4. Wybierz lokalizację zadania.

    5. W polu Nazwa zasad usługi Event Hubs utwórz nowe zasady lub wybierz istniejącą.

    6. W przypadku grupy odbiorców usługi Event Hubs utwórz nową grupę odbiorców lub wybierz istniejącą grupę odbiorców.

    7. Wybierz pozycję Utwórz , aby utworzyć zadanie usługi Stream Analytics.

       

       Uwaga

       Zalecamy utworzenie grupy odbiorców i zasad dla każdego nowego zadania usługi Azure Stream Analytics utworzonego na stronie usługi Event Hubs. Grupy odbiorców zezwalają tylko na pięć równoczesnych czytników, dlatego udostępnienie dedykowanej grupy odbiorców dla każdego zadania pozwoli uniknąć błędów, które mogą wynikać z przekroczenia tego limitu. Dedykowane zasady umożliwiają obracanie klucza lub odwoływanie uprawnień bez wpływu na inne zasoby.

12. Zadanie usługi Stream Analytics jest teraz tworzone, gdzie zapytanie jest takie samo, jak przetestowane, a dane wejściowe to centrum zdarzeń.

    

13. Dodaj wybrane dane wyjściowe .

14. Wróć do strony zadania usługi Stream Analytics, klikając nazwę zadania w linku do stron nadrzędnych.

15. Wybierz pozycję Edytuj zapytanie powyżej okna Zapytanie .

16. Zaktualizuj [OutputAlias] element przy użyciu nazwy wyjściowej, a następnie wybierz pozycję Zapisz link zapytania powyżej zapytania. Zamknij stronę Zapytanie, wybierając pozycję X w prawym górnym rogu.

17. Teraz na stronie zadania usługi Stream Analytics wybierz pozycję Uruchom na pasku narzędzi, aby uruchomić zadanie.

    

Access

Problem : Użytkownik nie może uzyskać dostępu do danych w wersji zapoznawczej, ponieważ nie ma odpowiednich uprawnień do subskrypcji.

Opcja 1. Użytkownik, który chce wyświetlać podgląd danych przychodzących, musi zostać dodany jako współautor subskrypcji.

Opcja 2. Użytkownik musi zostać dodany jako rola testera zapytań usługi Stream Analytics w subskrypcji. Przejdź do pozycji Kontrola dostępu dla subskrypcji. Dodaj nowe przypisanie roli dla użytkownika jako rolę "Tester zapytań usługi Stream Analytics".

Opcja 3. Użytkownik może utworzyć zadanie usługi Azure Stream Analytics. Ustaw dane wejściowe jako to centrum zdarzeń i przejdź do pozycji "Zapytanie", aby wyświetlić podgląd danych przychodzących z tego centrum zdarzeń.

Opcja 4. Administrator może utworzyć rolę niestandardową w subskrypcji. Dodaj następujące uprawnienia do roli niestandardowej, a następnie dodaj użytkownika do nowej roli niestandardowej.

Jednostki przesyłania strumieniowego

Zadanie usługi Azure Stream Analytics domyślnie jest domyślnie ustawione na trzy jednostki przesyłania strumieniowego (SU). Aby dostosować to ustawienie, wybierz pozycję Skaluj w menu po lewej stronie zadania usługi Stream Analytics w Azure Portal. Aby dowiedzieć się więcej na temat jednostek przesyłania strumieniowego, zobacz Omówienie i dostosowywanie jednostek przesyłania strumieniowego.

Następne kroki

Aby dowiedzieć się więcej na temat zapytań usługi Stream Analytics, zobacz Język zapytań usługi Stream Analytics