Udostępnij przez


Dodawanie źródła zdarzeń usługi Azure Blob Storage do strumienia zdarzeń

W tym artykule pokazano, jak dodać źródło zdarzeń usługi Azure Blob Storage do strumienia zdarzeń. Zdarzenie to najmniejsza ilość informacji, które w pełni opisują coś, co wydarzyło się w systemie. Zdarzenia usługi Azure Blob Storage są wyzwalane, gdy klient tworzy, zastępuje lub usuwa obiekt blob. Strumienie zdarzeń usługi Microsoft Fabric umożliwiają łączenie zdarzeń z usługi Blob Storage ze zdarzeniami platformy Fabric w centrum zdarzeń w czasie rzeczywistym.

Po dodaniu zdarzeń usługi Azure Blob Storage jako źródła strumienia zdarzeń automatycznie tworzone są zdarzenia systemowe na koncie usługi Blob Storage i łączone z zdarzeniami w centrum Fabric w czasie rzeczywistym. Następnie można przekonwertować te zdarzenia na ciągłe strumienie danych i przekształcić je przed kierowaniem ich do różnych miejsc docelowych w Fabric.

Strumienie zdarzeń Fabric obsługują następujące typy zdarzeń usługi Blob Storage:

Nazwa zdarzenia Opis
Microsoft.Storage.BlobCreated (utworzenie obiektu Blob) Wyzwalane, gdy obiekt blob jest utworzony lub zastąpiony.
Microsoft.Storage.BlobUsunięty Wyzwalane po usunięciu blobu.
Microsoft.Storage.BlobZmienionoNazwę Wyzwalane, gdy zmienia się nazwa obiektu blob.
Zmiana poziomu warstwy w Microsoft.Storage.Blob Wyzwalane, gdy zmienia się poziom dostępu do blobu.
Microsoft.Storage.KatalogUtworzony Wyzwalane, gdy zostanie utworzony katalog.
Microsoft.Storage.DirectoryRenamed Wyzwalane po zmianie nazwy katalogu.
Microsoft.Storage.OperacjaAsynchronicznaRozpoczęta Wyzwalane po zainicjowaniu operacji związanej z przenoszeniem lub kopiowaniem danych z archiwum do warstw gorących lub chłodnych.
Microsoft.Storage.KatalogUsunięty Wyzwalane po usunięciu katalogu.
PolitykaInwentaryzacjiBlobówMicrosoft.StorageZakończona Wyzwalany po zakończeniu procesu inwentaryzacji dla reguły definiującej zasady inwentaryzacji.
Microsoft.Storage.ZakończonoPolitykęCykluŻycia Wyzwalane po wykonaniu akcji zdefiniowanych przez zasady zarządzania cyklem życia.

Aby uzyskać więcej informacji na temat dostępnych typów zdarzeń, zobacz Azure Blob Storage as Event Grid source (Usługa Azure Blob Storage jako źródło usługi Event Grid).

Uwaga

Łącznik zdarzeń usługi Azure Blob Storage nie jest obsługiwany w następujących regionach pojemności obszaru roboczego: Centralne USA, Niemcy Zachodnio-Środkowe, South-Central USA, Zachodnie USA 2, Zachodnie USA 3, Indie Zachodnie.

Zdarzenia niestreamowane a streamowane

Zdarzenia usługi Azure Blob Storage to odrębne zdarzenia z wyraźnymi punktami początkowymi i końcowymi. Centra czasu rzeczywistego Fabric mogą przechwytywać te zdarzenia w dwóch formatach:

  • Zdarzenia bez transmisji strumieniowej. Te zdarzenia są reprezentowane w ich nieprzetworzonym formacie jako zdarzenia dyskretne. Jeśli zdarzenia usługi Azure Blob Storage nie są przesyłane do strumienia zdarzeń, nie są z nim bezpośrednio połączone, a domyślny strumień nie jest tworzony.

    Ten stan wskazuje, że zdarzenia są powiązane z wydarzeniami systemu Fabric w centrum przetwarzania w czasie rzeczywistym i czekają na dalsze działania. Akcje obejmują tworzenie alertów za pomocą Fabric Activator, które wykonują elementy zadań Fabric, takie jak Pipeline lub Notebook, na karcie Fabric events w hubie czasu rzeczywistego.

    Zrzut ekranu przedstawiający nieprzesyłane strumieniowo zdarzenia usługi Azure Blob Storage z przyciskiem do przesyłania strumieniowego zdarzeń.

  • Zdarzenia przesyłane strumieniowo. Te zdarzenia są przekształcane w zdarzenia ciągłe, co umożliwia ich przekształcanie i kierowanie w czasie rzeczywistym do różnych miejsc docelowych w systemie Fabric w celu dalszej analizy. W strumieniu zdarzeń, wybranie przycisku Stream events na nieprzetworzonym źródle Azure Blob Storage konwertuje zdarzenia na zdarzenia ciągłe. Strumień zdarzeń jest następnie przypisywany do domyślnego strumienia, umożliwiając dodawanie operacji i kierowanie ich do innych miejsc docelowych w Fabric.

    Zrzut ekranu przedstawiający zdarzenia z Azure Blob Storage przesyłane strumieniowo w strumieniu zdarzeń.

Wymagania wstępne

  • Dostęp do obszaru roboczego w trybie licencji Fabric Capacity (lub) w trybie licencji próbnej z uprawnieniami współautora lub wyższymi.
  • Dostęp do konta Azure Blob Storage StorageV2 (ogólnego przeznaczenia v2), BlockBlobStorage lub BlobStorage. Typ magazynu (wersja 1 ogólnego przeznaczenia) nie obsługuje integracji z strumieniami zdarzeń Fabric.
  • Jeśli nie masz strumienia zdarzeń, utwórz strumień zdarzeń.

Dodawanie zdarzeń usługi Azure Blob Storage jako źródła

Jeśli jeszcze nie dodano żadnego źródła do strumienia zdarzeń, wybierz kafelek Użyj źródła zewnętrznego .

Zrzut ekranu przedstawiający wybór kafelka do korzystania z zewnętrznego źródła.

Jeśli dodajesz źródło do już opublikowanego strumienia zdarzeń, przełącz się na tryb edycji. Na wstążce wybierz pozycję Dodaj źródła>zewnętrzne.

Zrzut ekranu przedstawiający opcje dodawania źródeł zewnętrznych.

Na stronie Wybieranie źródła danych wyszukaj i wybierz pozycję Połącz na kafelku Zdarzenia usługi Azure Blob Storage.

Zrzut ekranu przedstawiający wybór zdarzeń usługi Azure Blob Storage jako typu źródła w oknie Wybieranie źródła danych.

Konfigurowanie zdarzeń usługi Azure Blob Storage i nawiązywanie z nimi połączenia

  1. Na ekranie Połącz wykonaj następujące czynności:

    1. Wybierz subskrypcję Azure, która ma konto magazynowe.
    2. Wybierz konto magazynowania, które chcesz przechwycić do strumienia zdarzeń.
    3. Następnie wybierz pozycję Dalej w dolnej części strony.

    Zrzut ekranu ekranu Connect.

  2. Na ekranie Przeglądanie i łączenie przejrzyj podsumowanie, a następnie wybierz pozycję Połącz , aby ukończyć konfigurację zdarzeń usługi Azure Blob Storage.

    Zrzut ekranu ekranu Przegląd + Połącz.

  3. Następnie na następnej stronie wybierz pozycję Dodaj , aby dodać źródło do strumienia zdarzeń.

    Zrzut ekranu przedstawiający ekran dodawania.

Wyświetlanie zaktualizowanego strumienia zdarzeń

  1. Po utworzeniu połączenia zobaczysz źródło zdarzeń Azure Blob Storage dodane do strumienia zdarzeń w trybie edycji. Wybierz pozycję Publikuj , aby opublikować strumień zdarzeń i rozpocząć przechwytywanie zdarzeń usługi Azure Blob Storage.

    Zrzut ekranu pokazujący źródło zdarzeń usługi Azure Blob Storage dodane do strumienia zdarzeń.

    Uwaga

    Węzeł Eventstream w edytorze nie ma utworzonego domyślnego strumienia. Dzieje się tak, ponieważ zdarzenia usługi Blob Storage są nadal w postaci zdarzeń dyskretnych i nie są jeszcze konwertowane na strumień lub połączone ze strumieniem zdarzeń.

  2. Jeśli chcesz przekształcić zdarzenia w przestrzeni roboczej Fabric, otwórz strumień zdarzeń i wybierz Edytuj, aby wejść w Tryb edycji. Następnie możesz dodać operacje, aby przekształcić zdarzenia obszaru roboczego Fabric lub przekierować je do miejsca docelowego, takiego jak Lakehouse.

    Zrzut ekranu przedstawiający transmisję strumieniową zdarzeń w trybie na żywo.

Transformacja zdarzeń usługi Azure Blob Storage

Po połączeniu zdarzeń usługi Azure Blob Storage z zdarzeniami Fabric w centrum Real-Time hub można przekonwertować te zdarzenia na strumień i wykonać przekształcenia w strumieniach zdarzeń.

  1. Po dodaniu źródła zdarzeń usługi Azure Blob Storage w trybie edytowania, wybierz pozycję Strumieniowanie zdarzeń, aby przekonwertować zdarzenia usługi Blob Storage na strumień danych.

    Zrzut ekranu przedstawiający źródło zdarzeń nieprzesyłanych strumieniowo w trybie edycji, z wyróżnionymi zdarzeniami przesyłanymi strumieniowo.

  2. Odpowiedz tak na komunikat z pytaniem, czy chcesz streamować zdarzenia Blob Storage do strumienia zdarzeń.

    Zrzut ekranu potwierdzającego okienka dla wydarzeń przesyłanych strumieniowo.

  3. W edytorze domyślny strumień jest tworzony wewnątrz węzła strumienia zdarzeń, co oznacza, że zdarzenia z Blob Storage są konwertowane na strumień i stają się strumieniem domyślnym.

    Zrzut ekranu strumienia zdarzeń w trybie edycji przedstawiający strumień domyślny.

  4. Opublikuj strumień zdarzeń, a następnie upewnij się, że z usługi Azure Blob Storage jest wyzwalane co najmniej jedno zdarzenie, aby kontynuować przekształcanie lub routing.

    Zrzut ekranu przedstawiający opublikowany strumień zdarzeń w widoku na żywo.

  5. Gdy zdarzenia przepływają do strumienia zdarzeń, wejdź w tryb Edit mode i dodaj operacje, aby przekształcić zdarzenia przesyłane do Blob Storage. W poniższym przykładzie pokazano, że zdarzenia usługi Blob Storage są agregowane i kierowane do bazy danych KQL.

    Zrzut ekranu przedstawiający przekształcony strumień zdarzeń w trybie edycji.

  6. Po opublikowaniu zmian przesyłane strumieniowo zdarzenia usługi Azure Blob Storage są przekształcane i kierowane do wyznaczonego celu w Azure Fabric.

    Zrzut ekranu przedstawiający przekształcony strumień wydarzeń w trybie na żywo oraz domyślny strumień.

    Możesz również wyświetlić strumień danych na karcie Moje strumienie danych w centrum czasu rzeczywistego w celu weryfikacji.

    Zrzut ekranu przedstawiający strumień zdarzeń wymieniony w obszarze Strumienie danych w centrum czasu rzeczywistego.

Znane ograniczenia

  • Obecnie komunikaty o błędach nie są dostępne, gdy wystąpi błąd w źródłach zdarzeń dyskretnych.
  • Obecnie funkcja podglądu danych nie jest dostępna dla odrębnych źródeł zdarzeń.