az stream-analytics input
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 input . Dowiedz się więcej o rozszerzeniach.
Zarządzanie danymi wejściowymi za pomocą usługi Stream Analytics.
Polecenia
Nazwa | Opis | Typ | Stan |
---|---|---|---|
az stream-analytics input create |
Utwórz dane wejściowe lub zastępuje już istniejące dane wejściowe w ramach istniejącego zadania przesyłania strumieniowego. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics input delete |
Usuń dane wejściowe z zadania przesyłania strumieniowego. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics input list |
Wyświetl listę wszystkich danych wejściowych w ramach określonego zadania przesyłania strumieniowego. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics input show |
Uzyskaj szczegółowe informacje o określonych danych wejściowych. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics input test |
Przetestuj, czy źródło danych wejściowych jest osiągalne i możliwe do użycia przez usługę Azure Stream Analytics. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics input update |
Zaktualizuj istniejące dane wejściowe w ramach 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) danych wejściowych bez wpływu na pozostałe zadanie lub definicję danych wejściowych. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics input wait |
Umieść interfejs wiersza polecenia w stanie oczekiwania do momentu spełnienia warunku danych wejściowych usługi Stream Analytics. |
Numer wewnętrzny | Ogólna dostępność |
az stream-analytics input create
Utwórz dane wejściowe lub zastępuje już istniejące dane wejściowe w ramach istniejącego zadania przesyłania strumieniowego.
az stream-analytics input create --input-name
--job-name
--resource-group
[--if-match]
[--if-none-match]
[--properties]
Przykłady
Tworzenie referencyjnych danych wejściowych obiektu blob za pomocą serializacji CSV
az stream-analytics input create --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Tworzenie danych wejściowych centrum zdarzeń strumienia za pomocą serializacji JSON
az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"eventHubName\":\"sdkeventhub\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"someSharedAccessPolicyKey==\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}},\"serialization\":{\"type\":\"Json\",\"properties\":{\"encoding\":\"UTF8\"}}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"
Tworzenie danych wejściowych usługi IoT Hub strumienia przy użyciu serializacji Avro
az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"endpoint\":\"messages/events\",\"iotHubNamespace\":\"iothub\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"owner\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"
Tworzenie danych wejściowych strumieniowych obiektów blob za pomocą serializacji CSV
az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"sourcePartitionCount\":16,\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"
Parametry wymagane
Nazwa danych wejściowych.
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
Element ETag danych wejściowych. Pomiń tę wartość, aby zawsze zastępować bieżące dane wejściowe. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.
Ustaw wartość "*", aby zezwolić na utworzenie nowych danych wejściowych, ale aby zapobiec aktualizowaniu istniejących danych wejściowych. Inne wartości spowodują odpowiedź 412 Warunek wstępny Niepowodzenie.
Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.
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 input delete
Usuń dane wejściowe z zadania przesyłania strumieniowego.
az stream-analytics input delete --input-name
--job-name
--resource-group
[--yes]
Przykłady
Usuwanie danych wejściowych
az stream-analytics input delete --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Parametry wymagane
Nazwa danych wejściowych.
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 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 input list
Wyświetl listę wszystkich danych wejściowych w ramach określonego zadania przesyłania strumieniowego.
az stream-analytics input list --job-name
--resource-group
[--select]
Przykłady
Wyświetlanie listy wszystkich danych wejściowych w zadaniu przesyłania strumieniowego
az stream-analytics input list --job-name "sj9597" --resource-group "sjrg8440"
Wyświetlanie listy wszystkich danych wejściowych w zadaniu przesyłania strumieniowego i dołączanie informacji diagnostycznych przy użyciu parametru zapytania OData $select
az stream-analytics input list --select "*" --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 $select. Jest to rozdzielona przecinkami lista właściwości strukturalnych do uwzględnienia w odpowiedzi lub "" w celu uwzględnienia wszystkich właściwości. Domyślnie wszystkie właściwości są zwracane z wyjątkiem diagnostyki. Obecnie akceptuje tylko wartość "" jako prawidłową wartość.
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 input show
Uzyskaj szczegółowe informacje o określonych danych wejściowych.
az stream-analytics input show --input-name
--job-name
--resource-group
Przykłady
Pobieranie danych wejściowych obiektu blob referencyjnego za pomocą serializacji CSV
az stream-analytics input show --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Pobieranie danych wejściowych centrum zdarzeń strumienia za pomocą serializacji JSON
az stream-analytics input show --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"
Pobieranie danych wejściowych usługi IoT Hub strumienia za pomocą serializacji Avro
az stream-analytics input show --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"
Pobieranie danych wejściowych strumieniowych obiektów blob za pomocą serializacji CSV
az stream-analytics input show --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"
Parametry wymagane
Nazwa danych wejściowych.
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 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 input test
Przetestuj, czy źródło danych wejściowych jest osiągalne i możliwe do użycia przez usługę Azure Stream Analytics.
az stream-analytics input test --input-name
--job-name
--resource-group
[--no-wait]
[--properties]
Przykłady
Testowanie połączenia dla danych wejściowych
az stream-analytics input test --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Parametry wymagane
Nazwa danych wejściowych.
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.
Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.
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 input update
Zaktualizuj istniejące dane wejściowe w ramach 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) danych wejściowych bez wpływu na pozostałe zadanie lub definicję danych wejściowych.
az stream-analytics input update --input-name
--job-name
--resource-group
[--if-match]
[--properties]
Przykłady
Aktualizowanie danych wejściowych obiektu blob referencyjnego
az stream-analytics input update --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Aktualizowanie danych wejściowych centrum zdarzeń strumienia
az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"differentConsumerGroupName\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"
Aktualizowanie danych wejściowych usługi IoT Hub w strumieniu
az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"endpoint\":\"messages/operationsMonitoringEvents\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"
Aktualizowanie danych wejściowych strumienia obiektu blob
az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"sourcePartitionCount\":32}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"
Parametry wymagane
Nazwa danych wejściowych.
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
Element ETag danych wejściowych. Pomiń tę wartość, aby zawsze zastępować bieżące dane wejściowe. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.
Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.
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 input wait
Umieść interfejs wiersza polecenia w stanie oczekiwania do momentu spełnienia warunku danych wejściowych usługi Stream Analytics.
az stream-analytics input wait --input-name
--job-name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--interval]
[--timeout]
[--updated]
Przykłady
Wstrzymaj wykonywanie następnego wiersza skryptu interfejsu wiersza polecenia do momentu pomyślnego utworzenia danych wejściowych usługi Stream Analytics.
az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created
Parametry wymagane
Nazwa danych wejściowych.
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.
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.