az stream-analytics input
Note
Ta dokumentacja jest częścią rozszerzenia stream-analytics dla interfejsu wiersza polecenia platformy Azure (wersja 2.75.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. |
Extension | ogólna dostępność |
| az stream-analytics input delete |
Usuń dane wejściowe z zadania przesyłania strumieniowego. |
Extension | ogólna dostępność |
| az stream-analytics input list |
Wyświetl listę wszystkich danych wejściowych w ramach określonego zadania przesyłania strumieniowego. |
Extension | ogólna dostępność |
| az stream-analytics input show |
Uzyskaj szczegółowe informacje o określonych danych wejściowych. |
Extension | 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. |
Extension | 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. |
Extension | 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. |
Extension | 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 --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 az configure --defaults group=<name>.
Parametry opcjonalne
Poniższe parametry są opcjonalne, ale w zależności od kontekstu co najmniej jeden może być wymagany do pomyślnego wykonania polecenia.
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.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Format danych wyjściowych.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | json |
| Dopuszczalne wartości: | json, jsonc, none, table, tsv, yaml, yamlc |
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 az account set -s NAME_OR_ID.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
az stream-analytics input delete
Usuń dane wejściowe z zadania przesyłania strumieniowego.
az stream-analytics input delete --input-name --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 az configure --defaults group=<name>.
Parametry opcjonalne
Poniższe parametry są opcjonalne, ale w zależności od kontekstu co najmniej jeden może być wymagany do pomyślnego wykonania polecenia.
Nie monituj o potwierdzenie.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Format danych wyjściowych.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | json |
| Dopuszczalne wartości: | json, jsonc, none, table, tsv, yaml, yamlc |
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 az account set -s NAME_OR_ID.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
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 az configure --defaults group=<name>.
Parametry opcjonalne
Poniższe parametry są opcjonalne, ale w zależności od kontekstu co najmniej jeden może być wymagany do pomyślnego wykonania polecenia.
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.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Format danych wyjściowych.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | json |
| Dopuszczalne wartości: | json, jsonc, none, table, tsv, yaml, yamlc |
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 az account set -s NAME_OR_ID.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
az stream-analytics input show
Uzyskaj szczegółowe informacje o określonych danych wejściowych.
az stream-analytics input show --input-name --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 az configure --defaults group=<name>.
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Format danych wyjściowych.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | json |
| Dopuszczalne wartości: | json, jsonc, none, table, tsv, yaml, yamlc |
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 az account set -s NAME_OR_ID.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
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 --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 az configure --defaults group=<name>.
Parametry opcjonalne
Poniższe parametry są opcjonalne, ale w zależności od kontekstu co najmniej jeden może być wymagany do pomyślnego wykonania polecenia.
Nie czekaj na zakończenie długotrwałej operacji.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
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.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Format danych wyjściowych.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | json |
| Dopuszczalne wartości: | json, jsonc, none, table, tsv, yaml, yamlc |
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 az account set -s NAME_OR_ID.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
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 --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 az configure --defaults group=<name>.
Parametry opcjonalne
Poniższe parametry są opcjonalne, ale w zależności od kontekstu co najmniej jeden może być wymagany do pomyślnego wykonania polecenia.
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.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Format danych wyjściowych.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | json |
| Dopuszczalne wartości: | json, jsonc, none, table, tsv, yaml, yamlc |
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 az account set -s NAME_OR_ID.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
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 --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 az configure --defaults group=<name>.
Parametry opcjonalne
Poniższe parametry są opcjonalne, ale w zależności od kontekstu co najmniej jeden może być wymagany do pomyślnego wykonania polecenia.
Zaczekaj na utworzenie polecenia "provisioningState" o godzinie "Succeeded".
| Właściwość | Wartość |
|---|---|
| Grupa parametrów: | Wait Condition Arguments |
| Domyślna wartość: | False |
Poczekaj, aż warunek spełnia niestandardowe zapytanie JMESPath. Np. provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
| Właściwość | Wartość |
|---|---|
| Grupa parametrów: | Wait Condition Arguments |
Poczekaj na usunięcie.
| Właściwość | Wartość |
|---|---|
| Grupa parametrów: | Wait Condition Arguments |
| Domyślna wartość: | False |
Zaczekaj, aż zasób istnieje.
| Właściwość | Wartość |
|---|---|
| Grupa parametrów: | Wait Condition Arguments |
| Domyślna wartość: | False |
Interwał sondowania w sekundach.
| Właściwość | Wartość |
|---|---|
| Grupa parametrów: | Wait Condition Arguments |
| Domyślna wartość: | 30 |
Maksymalny czas oczekiwania w sekundach.
| Właściwość | Wartość |
|---|---|
| Grupa parametrów: | Wait Condition Arguments |
| Domyślna wartość: | 3600 |
Zaczekaj na zaktualizowanie stanu provisioningState o 'Powodzenie'.
| Właściwość | Wartość |
|---|---|
| Grupa parametrów: | Wait Condition Arguments |
| Domyślna wartość: | False |
Parametry globalne
Zwiększ szczegółowość rejestrowania, aby wyświetlić wszystkie dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Pokaż ten komunikat pomocy i zakończ pracę.
Pokaż tylko błędy, pomijając ostrzeżenia.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |
Format danych wyjściowych.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | json |
| Dopuszczalne wartości: | json, jsonc, none, table, tsv, yaml, yamlc |
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 az account set -s NAME_OR_ID.
Zwiększ szczegółowość rejestrowania. Użyj --debuguj, aby uzyskać pełne dzienniki debugowania.
| Właściwość | Wartość |
|---|---|
| Domyślna wartość: | False |