Konfigurowanie danych wejściowych i wyjściowych
Wszystkie zadania usługi Azure Stream Analytics obejmują co najmniej jedno dane wejściowe i wyjściowe. W większości przypadków dane wejściowe odwołują się do źródeł danych przesyłanych strumieniowo (chociaż można również zdefiniować dane wejściowe dla statycznych danych referencyjnych w celu rozszerzenia strumieniowych danych zdarzenia). Dane wyjściowe określają, gdzie będą wysyłane wyniki zapytania przetwarzania strumienia. W przypadku pozyskiwania danych do usługi Azure Synapse Analytics dane wyjściowe zwykle odwołują się do kontenera usługi Azure Data Lake Storage Gen2 lub tabeli w dedykowanej bazie danych puli SQL.
Wejścia danych przesyłanych strumieniowo
Dane wejściowe dla danych przesyłanych strumieniowo używanych przez usługę Azure Stream Analytics mogą obejmować:
- Azure Event Hubs
- Azure IoT Hubs
- Azure Blob lub Data Lake Gen 2 Storage
W zależności od określonego typu danych wejściowych dane dla każdego zdarzenia przesyłanego strumieniowo zawierają pola danych zdarzenia, a także pola metadanych specyficzne dla danych wejściowych. Na przykład dane używane z danych wejściowych usługi Azure Event Hubs obejmują pole EventEnqueuedUtcTime wskazujące czas odebrania zdarzenia w centrum zdarzeń.
Uwaga
Aby uzyskać więcej informacji na temat danych wejściowych przesyłania strumieniowego, zobacz Stream data as input into Stream Analytics (Przesyłanie strumieniowe jako dane wejściowe do usługi Stream Analytics) w dokumentacji usługi Azure Stream Analytics .
Dane wyjściowe usługi Azure Synapse Analytics
Jeśli musisz załadować wyniki przetwarzania strumienia do tabeli w dedykowanej puli SQL, użyj danych wyjściowych usługi Azure Synapse Analytics . Konfiguracja danych wyjściowych obejmuje tożsamość dedykowanej puli SQL w obszarze roboczym usługi Azure Synapse Analytics, szczegółowe informacje o tym, jak zadanie usługi Azure Stream Analytics powinno nawiązać z nim uwierzytelnione połączenie, oraz istniejącą tabelę, do której mają zostać załadowane dane.
Uwierzytelnianie w usłudze Azure Synapse Analytics jest zwykle realizowane za pomocą uwierzytelniania programu SQL Server, które wymaga nazwy użytkownika i hasła. Alternatywnie możesz użyć tożsamości zarządzanej do uwierzytelniania. W przypadku korzystania z danych wyjściowych usługi Azure Synapse Analytics konfiguracja zadania usługi Azure Stream Analytics musi zawierać konto usługi Azure Storage, w którym metadane uwierzytelniania dla zadania są przechowywane bezpiecznie.
Uwaga
Aby uzyskać więcej informacji na temat korzystania z danych wyjściowych usługi Azure Synapse Analytics, zobacz Dane wyjściowe usługi Azure Synapse Analytics z usługi Azure Stream Analytics w dokumentacji usługi Azure Stream Analytics .
Dane wyjściowe usługi Azure Data Lake Storage Gen2
Jeśli musisz napisać wyniki przetwarzania strumieniowego do kontenera usługi Azure Data Lake Storage Gen2, który hostuje magazyn danych typu data lake w obszarze roboczym usługi Azure Synapse Analytics, użyj danych wyjściowych usługi Blob Storage/ADLS Gen2 . Konfiguracja danych wyjściowych zawiera szczegóły konta magazynu, w którym zdefiniowano kontener, ustawienia uwierzytelniania umożliwiające nawiązanie z nim połączenia oraz szczegółowe informacje o plikach, które mają zostać utworzone. Można określić format pliku, w tym format CSV, JSON, Parquet i Delta. Można również określić wzorce niestandardowe, aby zdefiniować hierarchię folderów, w której są zapisywane pliki — na przykład przy użyciu wzorca, takiego jak RRRR/MM/DD , aby wygenerować hierarchię folderów na podstawie bieżącego roku, miesiąca i dnia.
Można określić minimalną i maksymalną liczbę wierszy dla każdej partii, która określa liczbę wygenerowanych plików wyjściowych (każda partia tworzy nowy plik). Można również skonfigurować tryb zapisu, aby kontrolować, kiedy dane są zapisywane dla przedziału czasu — dołączając każdy wiersz po nadejściu lub zapisując wszystkie wiersze raz (co zapewnia "dokładnie jednokrotne" dostarczanie).
Uwaga
Aby uzyskać więcej informacji na temat korzystania z danych wyjściowych usługi Blob Storage/ADLS Gen2, zobacz Blob Storage i Azure Data Lake Gen2 output from Azure Stream Analytics (Dane wyjściowe usługi Azure Stream Analytics) w dokumentacji usługi Azure Stream Analytics .