az stream-analytics job
Uwaga
Ta dokumentacja jest częścią rozszerzenia stream-analytics dla interfejsu wiersza polecenia platformy Azure (wersja 2.15.0 lub nowsza). Rozszerzenie zostanie automatycznie zainstalowane przy pierwszym uruchomieniu polecenia az stream-analytics job . Dowiedz się więcej o rozszerzeniach.
Zarządzanie zadaniem przesyłania strumieniowego za pomocą usługi Stream Analytics.
Polecenia
Nazwa | Opis | Typ | Stan |
---|---|---|---|
az stream-analytics job create |
Utwórz zadanie przesyłania strumieniowego lub zastępuje już istniejące zadanie przesyłania strumieniowego. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job delete |
Usuwanie zadania przesyłania strumieniowego. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job list |
Wyświetl listę wszystkich zadań przesyłania strumieniowego w określonej grupie zasobów. Lista wszystkich zadań przesyłania strumieniowego w danej subskrypcji. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job scale |
Skaluj zadanie przesyłania strumieniowego, gdy zadanie jest uruchomione. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job show |
Uzyskaj szczegółowe informacje o określonym zadaniu przesyłania strumieniowego. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job start |
Uruchom zadanie przesyłania strumieniowego. Po uruchomieniu zadania rozpocznie przetwarzanie zdarzeń wejściowych i generuje dane wyjściowe. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job stop |
Zatrzymaj uruchomione zadanie przesyłania strumieniowego. Spowoduje to zatrzymanie przetwarzania zdarzeń wejściowych i generowanie danych wyjściowych przez uruchomione zadanie przesyłania strumieniowego. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job update |
Aktualizowanie istniejącego zadania przesyłania strumieniowego. Może to służyć do częściowej aktualizacji (tj. zaktualizowania jednej lub dwóch właściwości) zadania przesyłania strumieniowego bez wpływu na pozostałą definicję zadania. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job wait |
Umieść interfejs wiersza polecenia w stanie oczekiwania do momentu spełnienia warunku zadania stream-analytics. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics job create
Utwórz zadanie przesyłania strumieniowego lub zastępuje już istniejące zadanie przesyłania strumieniowego.
az stream-analytics job create --job-name
--resource-group
[--arrival-max-delay]
[--compatibility-level {1.0, 1.2}]
[--content-storage-policy {JobStorageAccount, SystemAccount}]
[--data-locale]
[--functions]
[--id]
[--identity]
[--if-match]
[--if-none-match]
[--inputs]
[--job-storage-account]
[--job-type {Cloud, Edge}]
[--location]
[--no-wait]
[--order-max-delay]
[--out-of-order-policy {Adjust, Drop}]
[--output-error-policy {Drop, Stop}]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]
[--outputs]
[--tags]
[--transformation]
Przykłady
Utwórz pełne zadanie przesyłania strumieniowego (zadanie przesyłania strumieniowego z przekształceniem, co najmniej 1 dane wejściowe i co najmniej 1 dane wyjściowe)
az stream-analytics job create --job-name "sj7804" --resource-group "sjrg3276" --location "West US" --compatibility-level "1.0" --data-locale "en-US" --arrival-max-delay 5 --order-max-delay 0 --out-of-order-policy "Drop" --functions "[]" --inputs "[{\"name\":\"inputtest\",\"properties\":{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"containerName\",\"pathPattern\":\"\",\"storageAccounts\":[{\"accountKey\":\"yourAccountKey==\",\"accountName\":\"yourAccountName\"}]}},\"serialization\":{\"type\":\"Json\",\"properties\":{\"encoding\":\"UTF8\"}}}}]" --output-error-policy "Drop" --outputs "[{\"name\":\"outputtest\",\"datasource\":{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"database\":\"databaseName\",\"password\":\"userPassword\",\"server\":\"serverName\",\"table\":\"tableName\",\"user\":\"<user>\"}}}]" --transformation name="transformationtest" streaming-units=1 query="Select Id, Name from inputtest" --tags key1="value1" key3="value3" randomKey="randomValue"
Tworzenie powłoki zadań przesyłania strumieniowego (zadanie przesyłania strumieniowego bez danych wejściowych, danych wyjściowych, transformacji lub funkcji)
az stream-analytics job create --job-name "sj59" --resource-group "sjrg6936" --location "West US" --compatibility-level "1.0" --data-locale "en-US" --arrival-max-delay 16 --order-max-delay 5 --out-of-order-policy "Drop" --functions "[]" --inputs "[]" --output-error-policy "Drop" --outputs "[]" --tags key1="value1" key3="value3" randomKey="randomValue"
Parametry wymagane
Nazwa zadania przesyłania strumieniowego.
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry opcjonalne
Maksymalne tolerowane opóźnienie w sekundach, w których mogą być uwzględniane zdarzenia przychodzące późno. Obsługiwany zakres to -1 do 1814399 (20.23:59:59 dni) i -1 służy do określania oczekiwania na czas nieokreślony. Jeśli właściwość jest nieobecna, interpretowana jest wartość -1.
Steruje pewnymi zachowaniami środowiska uruchomieniowego zadania przesyłania strumieniowego.
Prawidłowe wartości to JobStorageAccount i SystemAccount. Jeśli ustawiono wartość JobStorageAccount, wymaga to również od użytkownika określenia właściwości jobStorageAccount. .
Ustawienia regionalne danych zadania usługi Stream Analytics. Wartość powinna być nazwą obsługiwanej kultury .NET z zestawu https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Wartość domyślna to "en-US", jeśli żadna z nich nie została określona.
Lista co najmniej jednej funkcji zadania przesyłania strumieniowego. Właściwość name dla każdej funkcji jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych przekształceń. Oczekiwana wartość: json-string/json-file/@json-file.
Identyfikator zasobu klastra.
Opisz przypisaną przez system tożsamość zarządzaną przypisaną do tego zadania, która może służyć do uwierzytelniania przy użyciu danych wejściowych i wyjściowych.
Użycie: --identity tenant-id=XX principal-id=XX type=XX
tenant-id: identity tenantId principal-id: Typ identyfikatora jednostki tożsamości: typ tożsamości.
Element ETag zadania przesyłania strumieniowego. Pomiń tę wartość, aby zawsze zastępować bieżący zestaw rekordów. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.
Ustaw wartość "*", aby zezwolić na utworzenie nowego zadania przesyłania strumieniowego, ale aby zapobiec aktualizowaniu istniejącego zestawu rekordów. Inne wartości spowodują odpowiedź 412 Warunek wstępny Niepowodzenie.
Lista co najmniej jednego wejściowego zadania przesyłania strumieniowego. Właściwość name dla każdego danych wejściowych jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych danych wejściowych. Oczekiwana wartość: json-string/json-file/@json-file.
Właściwości skojarzone z kontem usługi Azure Storage z tożsamością usługi zarządzanej.
Użycie: --job-storage-account authentication-mode=XX account-name=XX account-key=XX
tryb uwierzytelniania: tryb uwierzytelniania. account-name: nazwa konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace). account-key: klucz konta dla konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
Opisuje typ zadania. Prawidłowe tryby to Cloud
i "Edge".
Lokalizacja. Wartości z: az account list-locations
. Lokalizację domyślną można skonfigurować przy użyciu polecenia az configure --defaults location=<location>
.
Nie czekaj na zakończenie długotrwałej operacji.
Maksymalne tolerowane opóźnienie w sekundach, w których zdarzenia poza kolejnością można dostosować, aby wrócić do kolejności.
Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają poza kolejność w strumieniu zdarzeń wejściowych.
Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają do danych wyjściowych i nie mogą być zapisywane w magazynie zewnętrznym z powodu nieprawidłowego utworzenia (brakujące wartości kolumn, wartości kolumn niewłaściwego typu lub rozmiaru).
Ta właściwość powinna być używana tylko wtedy, gdy jest to wymagane, aby zadanie zostało uruchomione natychmiast po utworzeniu. Wartością może być JobStartTime, CustomTime lub LastOutputEventTime, aby wskazać, czy punkt początkowy strumienia zdarzeń wyjściowych powinien być uruchamiany za każdym razem, gdy zadanie zostanie uruchomione, rozpocznij od niestandardowej sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpocznij od ostatniego czasu wyjściowego zdarzenia.
Wartość to sygnatura czasowa w formacie ISO-8601 wskazująca punkt początkowy strumienia zdarzeń wyjściowych lub wartość null wskazująca, że strumień zdarzeń wyjściowych zostanie uruchomiony przy każdym uruchomieniu zadania przesyłania strumieniowego. Ta właściwość musi mieć wartość, jeśli parametr outputStartMode jest ustawiony na Wartość CustomTime.
Lista co najmniej jednego wyjścia zadania przesyłania strumieniowego. Właściwość name dla każdego danych wyjściowych jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych danych wyjściowych. Oczekiwana wartość: json-string/json-file/@json-file.
Tagi rozdzielone spacjami: klucz[=wartość] [key[=value] ...]. Użyj ciągu "", aby wyczyścić istniejące tagi.
Wskaż zapytanie i liczbę jednostek przesyłania strumieniowego do użycia dla zadania przesyłania strumieniowego. Właściwość name przekształcenia jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych przekształceń.
Użycie: --transformation streaming-units=XX valid-streaming-units=XX query=XX name=XX name=XX
jednostki przesyłania strumieniowego: określa liczbę jednostek przesyłania strumieniowego używanych przez zadanie przesyłania strumieniowego. valid-streaming-units: określa prawidłowe jednostki przesyłania strumieniowego, do których można skalować zadanie przesyłania strumieniowego. zapytanie: określa zapytanie, które będzie uruchamiane w zadaniu przesyłania strumieniowego. Więcej informacji na temat języka zapytań usługi Stream Analytics (SAQL) można znaleźć tutaj: https://msdn.microsoft.com/library/azure/dn834998 . Wymagane w żądaniach PUT (CreateOrReplace). name: Nazwa zasobu.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
az stream-analytics job delete
Usuwanie zadania przesyłania strumieniowego.
az stream-analytics job delete --job-name
--resource-group
[--no-wait]
[--yes]
Przykłady
Usuwanie zadania przesyłania strumieniowego
az stream-analytics job delete --job-name "sj59" --resource-group "sjrg6936"
Parametry wymagane
Nazwa zadania przesyłania strumieniowego.
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry opcjonalne
Nie czekaj na zakończenie długotrwałej operacji.
Nie monituj o potwierdzenie.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
az stream-analytics job list
Wyświetl listę wszystkich zadań przesyłania strumieniowego w określonej grupie zasobów. Lista wszystkich zadań przesyłania strumieniowego w danej subskrypcji.
az stream-analytics job list [--expand]
[--resource-group]
Przykłady
Wyświetl listę wszystkich zadań przesyłania strumieniowego w grupie zasobów i nie używaj parametru zapytania OData $expand
az stream-analytics job list --resource-group "sjrg6936"
Wyświetl listę wszystkich zadań przesyłania strumieniowego w grupie zasobów i użyj parametru zapytania OData $expand, aby rozwinąć dane wejściowe, dane wyjściowe, przekształcenia i funkcje
az stream-analytics job list --expand "inputs,outputs,transformation,functions" --resource-group "sjrg3276"
Wyświetlanie listy wszystkich zadań przesyłania strumieniowego w subskrypcji i nie używaj parametru zapytania OData $expand
az stream-analytics job list
Wyświetl listę wszystkich zadań przesyłania strumieniowego w subskrypcji i użyj parametru zapytania OData $expand, aby rozwinąć dane wejściowe, dane wyjściowe, przekształcenia i funkcje
az stream-analytics job list --expand "inputs,outputs,transformation,functions"
Parametry opcjonalne
Parametr zapytania OData $expand. Jest to rozdzielona przecinkami lista dodatkowych właściwości zadania przesyłania strumieniowego do uwzględnienia w odpowiedzi, poza domyślnym zestawem zwracanym, gdy ten parametr jest nieobecny. Domyślny zestaw to wszystkie właściwości zadania przesyłania strumieniowego inne niż "inputs", "transformation", "outputs" i "functions".
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
az stream-analytics job scale
Skaluj zadanie przesyłania strumieniowego, gdy zadanie jest uruchomione.
az stream-analytics job scale --job-name
--resource-group
[--no-wait]
[--streaming-units]
Przykłady
Skalowanie zadania przesyłania strumieniowego
az stream-analytics job scale --job-name "sj59" --resource-group "sjrg6936" --streaming-units 36
Parametry wymagane
Nazwa zadania przesyłania strumieniowego.
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry opcjonalne
Nie czekaj na zakończenie długotrwałej operacji.
Określa liczbę jednostek przesyłania strumieniowego, do których będzie skalowane zadanie przesyłania strumieniowego.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
az stream-analytics job show
Uzyskaj szczegółowe informacje o określonym zadaniu przesyłania strumieniowego.
az stream-analytics job show --job-name
--resource-group
[--expand]
Przykłady
Pobieranie zadania przesyłania strumieniowego i nie używaj parametru zapytania OData $expand
az stream-analytics job show --job-name "sj59" --resource-group "sjrg6936"
Pobierz zadanie przesyłania strumieniowego i użyj parametru zapytania OData $expand, aby rozwinąć dane wejściowe, dane wyjściowe, przekształcenia i funkcje
az stream-analytics job show --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276"
Parametry wymagane
Nazwa zadania przesyłania strumieniowego.
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry opcjonalne
Parametr zapytania OData $expand. Jest to rozdzielona przecinkami lista dodatkowych właściwości zadania przesyłania strumieniowego do uwzględnienia w odpowiedzi, poza domyślnym zestawem zwracanym, gdy ten parametr jest nieobecny. Domyślny zestaw to wszystkie właściwości zadania przesyłania strumieniowego inne niż "inputs", "transformation", "outputs" i "functions".
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
az stream-analytics job start
Uruchom zadanie przesyłania strumieniowego. Po uruchomieniu zadania rozpocznie przetwarzanie zdarzeń wejściowych i generuje dane wyjściowe.
az stream-analytics job start --job-name
--resource-group
[--no-wait]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]
Przykłady
Uruchamianie zadania przesyłania strumieniowego przy użyciu trybu uruchamiania danych wyjściowych CustomTime
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "CustomTime" --output-start-time "2012-12-12T12:12:12Z"
Uruchamianie zadania przesyłania strumieniowego za pomocą trybu uruchamiania danych wyjściowych JobStartTime
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "JobStartTime"
Uruchamianie zadania przesyłania strumieniowego przy użyciu trybu uruchamiania danych wyjściowych LastOutputEventTime
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "LastOutputEventTime"
Parametry wymagane
Nazwa zadania przesyłania strumieniowego.
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry opcjonalne
Nie czekaj na zakończenie długotrwałej operacji.
Wartością może być JobStartTime, CustomTime lub LastOutputEventTime, aby wskazać, czy punkt początkowy strumienia zdarzeń wyjściowych powinien być uruchamiany za każdym razem, gdy zadanie zostanie uruchomione, rozpocznij od niestandardowej sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpocznij od ostatniego czasu wyjściowego zdarzenia.
Wartość to sygnatura czasowa w formacie ISO-8601 wskazująca punkt początkowy strumienia zdarzeń wyjściowych lub wartość null wskazująca, że strumień zdarzeń wyjściowych zostanie uruchomiony przy każdym uruchomieniu zadania przesyłania strumieniowego. Ta właściwość musi mieć wartość, jeśli parametr outputStartMode jest ustawiony na Wartość CustomTime.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
az stream-analytics job stop
Zatrzymaj uruchomione zadanie przesyłania strumieniowego. Spowoduje to zatrzymanie przetwarzania zdarzeń wejściowych i generowanie danych wyjściowych przez uruchomione zadanie przesyłania strumieniowego.
az stream-analytics job stop --job-name
--resource-group
[--no-wait]
Przykłady
Zatrzymywanie zadania przesyłania strumieniowego
az stream-analytics job stop --job-name "sj59" --resource-group "sjrg6936"
Parametry wymagane
Nazwa zadania przesyłania strumieniowego.
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry opcjonalne
Nie czekaj na zakończenie długotrwałej operacji.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
az stream-analytics job update
Aktualizowanie istniejącego zadania przesyłania strumieniowego. Może to służyć do częściowej aktualizacji (tj. zaktualizowania jednej lub dwóch właściwości) zadania przesyłania strumieniowego bez wpływu na pozostałą definicję zadania.
az stream-analytics job update --job-name
--resource-group
[--arrival-max-delay]
[--compatibility-level {1.0, 1.2}]
[--content-storage-policy {JobStorageAccount, SystemAccount}]
[--data-locale]
[--functions]
[--id]
[--identity]
[--if-match]
[--inputs]
[--job-storage-account]
[--job-type {Cloud, Edge}]
[--location]
[--order-max-delay]
[--out-of-order-policy {Adjust, Drop}]
[--output-error-policy {Drop, Stop}]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]
[--outputs]
[--tags]
[--transformation]
Przykłady
Aktualizowanie zadania przesyłania strumieniowego
az stream-analytics job update --job-name "sj59" --resource-group "sjrg6936" --arrival-max-delay 13 --order-max-delay 21
Parametry wymagane
Nazwa zadania przesyłania strumieniowego.
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry opcjonalne
Maksymalne tolerowane opóźnienie w sekundach, w których mogą być uwzględniane zdarzenia przychodzące późno. Obsługiwany zakres to -1 do 1814399 (20.23:59:59 dni) i -1 służy do określania oczekiwania na czas nieokreślony. Jeśli właściwość jest nieobecna, interpretowana jest wartość -1.
Steruje pewnymi zachowaniami środowiska uruchomieniowego zadania przesyłania strumieniowego.
Prawidłowe wartości to JobStorageAccount i SystemAccount. Jeśli ustawiono wartość JobStorageAccount, wymaga to również od użytkownika określenia właściwości jobStorageAccount. .
Ustawienia regionalne danych zadania usługi Stream Analytics. Wartość powinna być nazwą obsługiwanej kultury .NET z zestawu https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Wartość domyślna to "en-US", jeśli żadna z nich nie została określona.
Lista co najmniej jednej funkcji zadania przesyłania strumieniowego. Właściwość name dla każdej funkcji jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych przekształceń. Oczekiwana wartość: json-string/json-file/@json-file.
Identyfikator zasobu klastra.
Opisz przypisaną przez system tożsamość zarządzaną przypisaną do tego zadania, która może służyć do uwierzytelniania przy użyciu danych wejściowych i wyjściowych.
Użycie: --identity tenant-id=XX principal-id=XX type=XX
tenant-id: identity tenantId principal-id: Typ identyfikatora jednostki tożsamości: typ tożsamości.
Element ETag zadania przesyłania strumieniowego. Pomiń tę wartość, aby zawsze zastępować bieżący zestaw rekordów. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.
Lista co najmniej jednego wejściowego zadania przesyłania strumieniowego. Właściwość name dla każdego danych wejściowych jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych danych wejściowych. Oczekiwana wartość: json-string/json-file/@json-file.
Właściwości skojarzone z kontem usługi Azure Storage z tożsamością usługi zarządzanej.
Użycie: --job-storage-account authentication-mode=XX account-name=XX account-key=XX
tryb uwierzytelniania: tryb uwierzytelniania. account-name: nazwa konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace). account-key: klucz konta dla konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
Opisuje typ zadania. Prawidłowe tryby to Cloud
i "Edge".
Lokalizacja. Wartości z: az account list-locations
. Lokalizację domyślną można skonfigurować przy użyciu polecenia az configure --defaults location=<location>
.
Maksymalne tolerowane opóźnienie w sekundach, w których zdarzenia poza kolejnością można dostosować, aby wrócić do kolejności.
Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają poza kolejność w strumieniu zdarzeń wejściowych.
Wskazuje zasady, które mają być stosowane do zdarzeń, które docierają do danych wyjściowych i nie mogą być zapisywane w magazynie zewnętrznym z powodu nieprawidłowego utworzenia (brakujące wartości kolumn, wartości kolumn niewłaściwego typu lub rozmiaru).
Ta właściwość powinna być używana tylko wtedy, gdy jest to wymagane, aby zadanie zostało uruchomione natychmiast po utworzeniu. Wartością może być JobStartTime, CustomTime lub LastOutputEventTime, aby wskazać, czy punkt początkowy strumienia zdarzeń wyjściowych powinien być uruchamiany za każdym razem, gdy zadanie zostanie uruchomione, rozpocznij od niestandardowej sygnatury czasowej użytkownika określonej za pośrednictwem właściwości outputStartTime lub rozpocznij od ostatniego czasu wyjściowego zdarzenia.
Wartość to sygnatura czasowa w formacie ISO-8601 wskazująca punkt początkowy strumienia zdarzeń wyjściowych lub wartość null wskazująca, że strumień zdarzeń wyjściowych zostanie uruchomiony przy każdym uruchomieniu zadania przesyłania strumieniowego. Ta właściwość musi mieć wartość, jeśli parametr outputStartMode jest ustawiony na Wartość CustomTime.
Lista co najmniej jednego wyjścia zadania przesyłania strumieniowego. Właściwość name dla każdego danych wyjściowych jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych danych wyjściowych. Oczekiwana wartość: json-string/json-file/@json-file.
Tagi rozdzielone spacjami: klucz[=wartość] [key[=value] ...]. Użyj ciągu "", aby wyczyścić istniejące tagi.
Wskaż zapytanie i liczbę jednostek przesyłania strumieniowego do użycia dla zadania przesyłania strumieniowego. Właściwość name przekształcenia jest wymagana podczas określania tej właściwości w żądaniu PUT. Tej właściwości nie można modyfikować za pomocą operacji PATCH. Musisz użyć interfejsu API PATCH dostępnego dla poszczególnych przekształceń.
Użycie: --transformation streaming-units=XX valid-streaming-units=XX query=XX name=XX name=XX
jednostki przesyłania strumieniowego: określa liczbę jednostek przesyłania strumieniowego używanych przez zadanie przesyłania strumieniowego. valid-streaming-units: określa prawidłowe jednostki przesyłania strumieniowego, do których można skalować zadanie przesyłania strumieniowego. zapytanie: określa zapytanie, które będzie uruchamiane w zadaniu przesyłania strumieniowego. Więcej informacji na temat języka zapytań usługi Stream Analytics (SAQL) można znaleźć tutaj: https://msdn.microsoft.com/library/azure/dn834998 . Wymagane w żądaniach PUT (CreateOrReplace). name: Nazwa zasobu.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
az stream-analytics job wait
Umieść interfejs wiersza polecenia w stanie oczekiwania do momentu spełnienia warunku zadania stream-analytics.
az stream-analytics job wait --job-name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--expand]
[--interval]
[--timeout]
[--updated]
Przykłady
Wstrzymaj wykonywanie następnego wiersza skryptu interfejsu wiersza polecenia do momentu pomyślnego utworzenia zadania stream-analytics.
az stream-analytics job wait --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276" --created
Wstrzymaj wykonywanie następnego wiersza skryptu interfejsu wiersza polecenia do momentu pomyślnego usunięcia zadania stream-analytics.
az stream-analytics job wait --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276" --deleted
Parametry wymagane
Nazwa zadania przesyłania strumieniowego.
Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>
.
Parametry opcjonalne
Zaczekaj na utworzenie polecenia "provisioningState" o godzinie "Succeeded".
Poczekaj, aż warunek spełnia niestandardowe zapytanie JMESPath. Np. provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
Poczekaj na usunięcie.
Zaczekaj, aż zasób istnieje.
Parametr zapytania OData $expand. Jest to rozdzielona przecinkami lista dodatkowych właściwości zadania przesyłania strumieniowego do uwzględnienia w odpowiedzi, poza domyślnym zestawem zwracanym, gdy ten parametr jest nieobecny. Domyślny zestaw to wszystkie właściwości zadania przesyłania strumieniowego inne niż "inputs", "transformation", "outputs" i "functions".
Interwał sondowania w sekundach.
Maksymalny czas oczekiwania w sekundach.
Zaczekaj na zaktualizowanie stanu provisioningState o 'Powodzenie'.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
Format danych wyjściowych.
Ciąg zapytania JMESPath. Zobacz http://jmespath.org/ , aby uzyskać więcej informacji i przykładów.
Nazwa lub identyfikator subskrypcji. Subskrypcję domyślną można skonfigurować przy użyciu polecenia az account set -s NAME_OR_ID
.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.