Jak uruchomić zadanie usługi Azure Stream Analytics

  • Artykuł

Zadanie usługi Azure Stream Analytics można uruchomić przy użyciu Azure Portal, programu Visual Studio i programu PowerShell. Po uruchomieniu zadania należy wybrać godzinę rozpoczęcia tworzenia danych wyjściowych zadania. Azure Portal, Visual Studio i PowerShell mają różne metody ustawiania czasu rozpoczęcia. Te metody zostały opisane poniżej.

Opcje uruchamiania

Dostępne są trzy następujące opcje uruchamiania zadania. Należy pamiętać, że wszystkie czasy wymienione poniżej to te określone w znaczniku TIMESTAMP BY. Jeśli parametr TIMESTAMP BY nie zostanie określony, zostanie użyty czas przybycia.

  • Teraz: powoduje, że punkt początkowy strumienia zdarzeń wyjściowych jest taki sam, jak w przypadku uruchomienia zadania. Jeśli jest używany operator czasowy (np. przedział czasu, LAG lub JOIN), usługa Azure Stream Analytics automatycznie przyjrzy się danym w źródle wejściowym. Jeśli na przykład uruchomisz zadanie "Teraz", a zapytanie użyje 5-minutowego okna wirowania, usługa Azure Stream Analytics będzie wyszukiwać dane z 5 minut temu w danych wejściowych. Pierwsze możliwe zdarzenie wyjściowe będzie miało znacznik czasu równy lub większy niż bieżący czas, a usługa ASA gwarantuje, że wszystkie zdarzenia wejściowe, które mogą logicznie przyczynić się do danych wyjściowych, zostały uwzględnione. Na przykład nie są generowane żadne częściowe agregacje okienne. Jest to zawsze kompletna zagregowana wartość.

  • Niestandardowy: możesz wybrać punkt początkowy danych wyjściowych. Podobnie jak w przypadku opcji Teraz usługa Azure Stream Analytics automatycznie odczytuje dane przed tym czasem, jeśli jest używany operator czasowy

  • Kiedy ostatnio zatrzymano. Ta opcja jest dostępna, gdy zadanie zostało wcześniej uruchomione, ale zostało zatrzymane ręcznie lub nie powiodło się. Po wybraniu tej opcji usługa Azure Stream Analytics użyje czasu ostatniego wyjścia, aby ponownie uruchomić zadanie, aby nie utracić danych. Podobnie jak w przypadku poprzednich opcji usługa Azure Stream Analytics automatycznie odczytuje dane przed tym czasem, jeśli jest używany operator czasowy. Ponieważ kilka partycji wejściowych może mieć inny czas, jest używany najwcześniejszy czas zatrzymania wszystkich partycji, w wyniku czego niektóre duplikaty mogą być widoczne w danych wyjściowych. Więcej informacji o dokładnie jednokrotnym przetwarzaniu jest dostępnych na stronie Gwarancje dostarczania zdarzeń.

Azure Portal

Przejdź do zadania w Azure Portal i wybierz pozycję Rozpocznij na stronie przeglądu. Wybierz godzinę rozpoczęcia danych wyjściowych zadania , a następnie wybierz pozycję Uruchom.

Wybierz jedną z opcji czasu rozpoczęcia danych wyjściowych zadania. Opcje to Teraz, Niestandardowy i, jeśli zadanie zostało wcześniej uruchomione, Po ostatnim zatrzymaniu. Zobacz powyżej, aby uzyskać więcej informacji na temat tych opcji.

Visual Studio

W widoku zadania wybierz zielony przycisk strzałki, aby uruchomić zadanie. Ustaw tryb uruchamiania danych wyjściowych zadania i wybierz pozycję Uruchom. Stan zadania zmieni się na Uruchomiono.

Istnieją trzy opcje dla trybu uruchamiania danych wyjściowych zadania: JobStartTime, CustomTime i LastOutputEventTime. Jeśli ta właściwość jest nieobecna, wartość domyślna to JobStartTime. Zobacz powyżej, aby uzyskać więcej informacji na temat tych opcji.

PowerShell

Użyj następującego polecenia cmdlet, aby uruchomić zadanie przy użyciu programu PowerShell:

Start-AzStreamAnalyticsJob `
  -ResourceGroupName $resourceGroup `
  -Name $jobName `
  -OutputStartMode 'JobStartTime'

Istnieją trzy opcje dla elementu OutputStartMode: JobStartTime, CustomTime i LastOutputEventTime. Jeśli ta właściwość jest nieobecna, wartość domyślna to JobStartTime. Zobacz powyżej, aby uzyskać więcej informacji na temat tych opcji.

Aby uzyskać więcej informacji na temat polecenia cmdlet, zobacz dokumentację zadania Start-AzStreamAnalyticsJob.Start-AzStreamAnalyitcsJob

Następne kroki