Pobieranie danych ze strumienia zdarzeń

Z tego artykułu dowiesz się, jak pobrać dane z istniejącego strumienia zdarzeń do nowej lub istniejącej tabeli.

Dane można pozyskiwać z domyślnych lub pochodnych strumieni. Strumień pochodny jest tworzony przez dodanie serii operacji strumienia do strumienia zdarzeń, takich jak Filtrowanie lub Zarządzanie polami. Aby uzyskać więcej informacji, zobacz Pojęcia dotyczące strumienia zdarzeń.

Aby pobrać dane z nowego strumienia zdarzeń, zobacz Pobieranie danych z nowego strumienia zdarzeń.

Warunki wstępne

• Obszar roboczy z pojemnością obsługiwaną przez Microsoft Fabric.
• Baza danych KQL z uprawnieniami do edycji.
• Strumień zdarzeń ze źródłem danych.

Krok 1. Źródło

Aby pobrać dane z strumienia zdarzeń, wybierz strumień zdarzeń jako źródło danych. Wybierz strumień zdarzeń w następujący sposób:

Na wstążce bazy danych KQL, wykonaj jedną z następujących czynności:

• Z opcji Pobierz dane na wstążce wybierz kafelek Eventstream .

• Z menu rozwijanego Pobierz dane wybierz pozycję Eventstream>Istniejący strumień zdarzeń.

• Z menu rozwijanego Pobierz dane wybierz centrum danych w czasie rzeczywistym i wybierz strumień zdarzeń z listy.

Krok 2. Konfigurowanie

1. Wybierz tabelę docelową. Aby pozyskać dane do nowej tabeli, wybierz pozycję + Nowa tabela i wprowadź nazwę tabeli.

   Notatka

   Nazwy tabel mogą zawierać maksymalnie 1024 znaki, w tym spacje, alfanumeryczne, łączniki i podkreślenia. Znaki specjalne nie są obsługiwane przez system.

2. W obszarze Konfigurowanie źródła danych wypełnij ustawienia, korzystając z informacji w poniższej tabeli:

   • Po wybraniu Eventstream jako źródła, określ Obszar roboczy, Eventstream i domyślny lub pochodny Strumień.

   Ważny

   Funkcja pobierania danych ze strumieni pochodnych jest dostępna w wersji zapoznawczej.

   

   • Po wybraniu hubaReal-Time jako źródła, wybierasz domyślny lub pochodny strumień z listy, a Workspace, Eventstream i Stream są wypełniane automatycznie i nie wymagają konfiguracji.

   

   ustawienie	opis
   Obszar roboczy	Lokalizacja przestrzeni roboczej strumienia zdarzeń. Wybierz obszar roboczy z listy rozwijanej.
   Eventstream	Nazwa strumienia zdarzeń. Wybierz strumień zdarzeń z listy rozwijanej.
   Stream	Nazwa domyślnego lub pochodnego strumienia. Wybierz strumień z listy rozwijanej. * W przypadku domyślnych strumieni format nazwy strumienia to Eventstream-stream. * W przypadku strumieni pochodnych nazwa została zdefiniowana podczas tworzenia strumienia.
   Przetwarzanie zdarzenia przed przyjęciem w strumieniu zdarzeń	Ta opcja umożliwia skonfigurowanie przetwarzania danych przed ich załadowaniem do tabeli docelowej. W przypadku wybrania opcji kontynuuj proces pozyskiwania danych w usłudze Eventstream. Aby uzyskać więcej informacji, zobacz "Procesowanie zdarzenia przed przetworzeniem w Eventstream".
   Nazwa połączenia danych	Nazwa używana do odniesienia się do łącza danych i zarządzania nim w obszarze roboczym. Nazwa połączenia danych jest wypełniana automatycznie i można edytować nazwę, aby uprościć zarządzanie połączeniem danych w obszarze roboczym. Nazwa może zawierać tylko znaki alfanumeryczne, kreskowe i kropkowe oraz maksymalnie 40 znaków.

3. Wybierz przycisk Dalej, aby kontynuować.

Przetwarzanie zdarzenia przed przyjęciem w strumieniu zdarzeń

Opcja Process przed wprowadzeniem danych w usłudze Eventstream umożliwia przetwarzanie danych przed ich wprowadzeniem do tabeli docelowej. Dzięki tej opcji proces pobierania danych jest bezproblemowo kontynuowany w usłudze Eventstream, a szczegóły tabeli docelowej i źródła danych są wypełniane automatycznie.

Aby przetworzyć zdarzenie przed wczytaniem do Eventstreamu:

1. Na karcie Konfigurowanie wybierz pozycję Przetwarzaj zdarzenie przed pozyskiwaniem w Eventstream.

2. W oknie dialogowym Przetwarzanie zdarzeń w strumieniu zdarzeń wybierz pozycję Kontynuuj w strumieniu zdarzeń.

   Ważny

   Wybranie Kontynuuj w Eventstream kończy proces pobierania danych w funkcji Analizy w czasie rzeczywistym i kontynuuje w Eventstream, automatycznie uzupełniając szczegóły tabeli docelowej i źródła danych.

   

3. W obszarze Eventstream wybierz węzeł docelowy Baza Danych KQL, a w okienku Baza Danych KQL sprawdź, czy opcja Przetwarzanie zdarzeń przed pozyskaniem została wybrana i czy szczegóły lokalizacji docelowej są poprawne.

   

4. Wybierz pozycję Otwórz procesor zdarzeń, aby skonfigurować przetwarzanie danych, a następnie wybierz pozycję Zapisz. Aby uzyskać więcej informacji, zobacz Przetwarzanie danych zdarzeń za pomocą edytora procesora zdarzeń.

5. W okienku Baza danych KQL wybierz pozycję Dodaj , aby ukończyć konfigurację węzła docelowego bazy danych KQL.

6. Sprawdź, czy dane są wczytywane do tabeli docelowej.

Krok 3. Inspekcja

Karta Inspekcja zawiera podgląd danych.

Wybierz Zakończ, aby ukończyć proces przetwarzania.

Opcjonalnie:

• Użyj listy rozwijanej Typ pliku, aby zapoznać się z opcjami zaawansowanymi na podstawie typu danych.

• Użyj listy rozwijanej Table_mapping , aby zdefiniować nowe mapowanie.

• Wybierz </> , aby otworzyć przeglądarkę poleceń, aby wyświetlić i skopiować automatyczne polecenia wygenerowane na podstawie danych wejściowych. Możesz również otworzyć polecenia w zestawie zapytań.

• Wybierz ikonę ołówka, aby edytować kolumny.

Edytowanie kolumn

Zmiany, które można wprowadzić w tabeli, zależą od następujących parametrów:

• typ tabeli jest nowy lub istniejący
• Typ mapowania to nowy lub istniejący

Mapowanie transformacji

Niektóre mapowania formatów danych (Parquet, JSON i Avro) obsługują proste transformacje podczas wczytywania danych. Aby zastosować przekształcenia mapowania, utwórz lub zaktualizuj kolumnę w oknie Edytuj kolumny.

Przekształcenia mapowania można wykonać na kolumnie typu ciąg znaków lub data/godzina, przy czym źródło może mieć typ danych int lub long. Aby uzyskać więcej informacji, zobacz pełną listę obsługiwanych transformacji mapowania.

Opcje zaawansowane oparte na typie danych

Tabelaryczny (CSV, TSV i PSV):

• Jeśli wczytujesz formaty tabelaryczne w istniejącej tabeli, możesz wybrać Table_mapping>Użyj istniejącego mapowania. Dane tabelaryczne nie zawsze zawierają nazwy kolumn używane do mapowania danych źródłowych na istniejące kolumny. Po zaznaczeniu tej opcji mapowanie odbywa się według kolejności, a schemat tabeli pozostaje taki sam. Jeśli ta opcja nie jest zaznaczona, nowe kolumny są tworzone dla danych przychodzących, niezależnie od struktury danych.

JSON:

• Wybierz Poziomy zagnieżdżone, aby określić podział kolumn danych JSON z zakresu od 1 do 100.

Krok 4. Podsumowanie

W oknie Podsumowanie wszystkie kroki są oznaczone jako ukończone po pomyślnym zakończeniu pozyskiwania danych. Wybierz kartę, aby eksplorować dane, usunąć pozyskane dane lub utworzyć pulpit nawigacyjny z kluczowymi metrykami. Wybierz pozycję Zamknij, aby zamknąć okno.

Powiązana zawartość

• Aby zarządzać bazą danych, zobacz Zarządzanie danymi.
• Aby tworzyć, przechowywać i eksportować zapytania, zobacz Wykonywanie zapytań w zestawie zapytań języka KQL.