Udostępnij za pośrednictwem

Jak uruchomić zadanie usługi Azure Stream Analytics

  • Artykuł

Zadanie usługi Azure Stream Analytics można uruchomić przy użyciu witryny Azure Portal, programu Visual Studio i programu PowerShell. Po uruchomieniu zadania należy wybrać godzinę rozpoczęcia tworzenia danych wyjściowych zadania. Każda witryna Azure Portal, program Visual Studio i program 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 wymienione poniżej czasy są tymi określonymi w znaczniku TIMESTAMP BY. Jeśli parametr TIMESTAMP BY nie zostanie określony, zostanie użyty czas przybycia.

  • Teraz: sprawia, że punkt początkowy strumienia zdarzeń wyjściowych jest taki sam jak w momencie uruchomienia zadania. Jeśli jest używany operator czasowy (np. przedział czasu, OPÓŹNIENIE lub JOIN), usługa Azure Stream Analytics automatycznie sprawdzi dane w źródle wejściowym. Jeśli na przykład uruchomisz zadanie "Teraz", a zapytanie używa 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 mieć 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. Zawsze jest to 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ę. Podczas wybierania tej opcji usługa Azure Stream Analytics użyje ostatniego czasu wyjściowego, aby ponownie uruchomić zadanie, aby żadne dane nie zostaną utracone. 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, używany jest 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 witrynie 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 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'

Dostępne są trzy opcje 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ę Start-AzStreamAnalyticsJob Start-AzStreamAnalyticsJob.

Następne kroki