az stream-analytics input

  • Odwołanie

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

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 delete

Usuń dane wejściowe z zadania przesyłania strumieniowego.
az stream-analytics input list

Wyświetl listę wszystkich danych wejściowych w ramach określonego zadania przesyłania strumieniowego.
az stream-analytics input show

Uzyskaj szczegółowe informacje o określonych danych wejściowych.
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 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. zaktualizować jedną lub dwie właściwości) dane wejściowe bez wpływu na pozostałe zadanie lub definicję danych wejściowych.
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 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 z 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 strumienia IoT Hub danych wejściowych za pomocą 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

--input-name --name -n

Nazwa danych wejściowych.

--job-name

Nazwa zadania przesyłania strumieniowego.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--if-match

Element ETag danych wejściowych. Pomiń tę wartość, aby zawsze zastąpić bieżące dane wejściowe. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.

--if-none-match

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.

--properties

Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

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

--input-name --name -n

Nazwa danych wejściowych.

--job-name

Nazwa zadania przesyłania strumieniowego.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--yes -y

Nie monituj o potwierdzenie.

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świetl listę wszystkich danych wejściowych w zadaniu przesyłania strumieniowego i uwzględnij informacje diagnostyczne przy użyciu parametru zapytania OData $select

az stream-analytics input list --select "*" --job-name "sj7804" --resource-group "sjrg3276"

Parametry wymagane

--job-name

Nazwa zadania przesyłania strumieniowego.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--select

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ść.

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 referencyjnych danych wejściowych obiektu blob 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 strumienia IoT Hub danych wejściowych 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

--input-name --name -n

Nazwa danych wejściowych.

--job-name

Nazwa zadania przesyłania strumieniowego.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

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

--input-name --name -n

Nazwa danych wejściowych.

--job-name

Nazwa zadania przesyłania strumieniowego.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--no-wait

Nie czekaj na zakończenie długotrwałej operacji.

--properties

Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

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. zaktualizować jedną lub dwie właściwości) dane wejściowe 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 strumienia IoT Hub danych wejściowych

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

--input-name --name -n

Nazwa danych wejściowych.

--job-name

Nazwa zadania przesyłania strumieniowego.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--if-match

Element ETag danych wejściowych. Pomiń tę wartość, aby zawsze zastąpić bieżące dane wejściowe. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.

--properties

Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

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

--input-name --name -n

Nazwa danych wejściowych.

--job-name

Nazwa zadania przesyłania strumieniowego.

--resource-group -g

Nazwa grupy zasobów. Grupę domyślną można skonfigurować przy użyciu polecenia az configure --defaults group=<name>.

Parametry opcjonalne

--created

Zaczekaj na utworzenie polecenia "provisioningState" w lokalizacji "Succeeded".

--custom

Zaczekaj, aż warunek spełnia niestandardowe zapytanie JMESPath. Na przykład provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

--deleted

Zaczekaj na usunięcie.

--exists

Zaczekaj, aż zasób istnieje.

--interval

Interwał sondowania w sekundach.

wartość domyślna: 30
--timeout

Maksymalny czas oczekiwania w sekundach.

wartość domyślna: 3600
--updated

Zaczekaj na zaktualizowanie parametru provisioningState o godzinie "Succeeded".