az stream-analytics output

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 output . Dowiedz się więcej o rozszerzeniach.

Zarządzanie danymi wyjściowymi za pomocą usługi Stream Analytics.

Polecenia

az stream-analytics output create

Utwórz dane wyjściowe lub zastępuje już istniejące dane wyjściowe w ramach istniejącego zadania przesyłania strumieniowego.

az stream-analytics output delete

Usuń dane wyjściowe z zadania przesyłania strumieniowego.

az stream-analytics output list

Wyświetl listę wszystkich danych wyjściowych w ramach określonego zadania przesyłania strumieniowego.

az stream-analytics output show

Uzyskaj szczegółowe informacje o określonych danych wyjściowych.

az stream-analytics output test

Przetestuj, czy źródło danych wyjściowych jest osiągalne i możliwe do użycia przez usługę Azure Stream Analytics.

az stream-analytics output update

Zaktualizuj istniejące dane wyjściowe w ramach istniejącego zadania przesyłania strumieniowego. Może to służyć do częściowej aktualizacji (tj. zaktualizuj jedną lub dwie właściwości) dane wyjściowe bez wpływu na pozostałą część zadania lub definicję danych wyjściowych.

az stream-analytics output wait

Umieść interfejs wiersza polecenia w stanie oczekiwania do momentu spełnienia warunku danych wyjściowych usługi Stream Analytics.

az stream-analytics output create

Utwórz dane wyjściowe lub zastępuje już istniejące dane wyjściowe w ramach istniejącego zadania przesyłania strumieniowego.

az stream-analytics output create --job-name
                                  --name
                                  --resource-group
                                  [--datasource]
                                  [--if-match]
                                  [--if-none-match]
                                  [--serialization]
                                  [--size-window]
                                  [--time-window]

Przykłady

Tworzenie danych wyjściowych usługi DocumentDB

az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"accountId\":\"someAccountId\",\"accountKey\":\"accountKey==\",\"collectionNamePattern\":\"collection\",\"database\":\"db01\",\"documentId\":\"documentId\",\"partitionKey\":\"key\"}}" --output-name "output3022" --resource-group "sjrg7983"

Tworzenie danych wyjściowych Power BI

az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"someDataset\",\"groupId\":\"ac40305e-3e8d-43ac-8161-c33799f43e95\",\"groupName\":\"MyPowerBIGroup\",\"refreshToken\":\"someRefreshToken==\",\"table\":\"someTable\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --output-name "output3022" --resource-group "sjrg7983"

Tworzenie danych wyjściowych kolejki Service Bus przy użyciu serializacji Avro

az stream-analytics output create --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"queueName\":\"sdkqueue\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"systemPropertyColumns\":{\"MessageId\":\"col3\",\"PartitionKey\":\"col4\"}}}" --serialization "{\"type\":\"Avro\"}" --output-name "output3456" --resource-group "sjrg3410"

Tworzenie danych wyjściowych tematu Service Bus przy użyciu serializacji CSV

az stream-analytics output create --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"topicName\":\"sdktopic\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output7886" --resource-group "sjrg6450"

Tworzenie danych wyjściowych obiektu blob za pomocą serializacji CSV

az stream-analytics output create --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output1623" --resource-group "sjrg5023"

Tworzenie danych wyjściowych usługi Azure Data Lake Store przy użyciu serializacji JSON

az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"someaccount\",\"dateFormat\":\"yyyy/MM/dd\",\"filePathPrefix\":\"{date}/{time}\",\"refreshToken\":\"someRefreshToken==\",\"tenantId\":\"cea4e98b-c798-49e7-8c40-4a2b3beb47dd\",\"timeFormat\":\"HH\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"

Tworzenie danych wyjściowych bazy danych Azure SQL

az stream-analytics output create --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"database\":\"someDatabase\",\"password\":\"somePassword\",\"server\":\"someServer\",\"table\":\"someTable\",\"user\":\"<user>\"}}" --output-name "output1755" --resource-group "sjrg2157"

Tworzenie danych wyjściowych tabeli platformy Azure

az stream-analytics output create --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\",\"batchSize\":25,\"columnsToRemove\":[\"column1\",\"column2\"],\"partitionKey\":\"partitionKey\",\"rowKey\":\"rowKey\",\"table\":\"samples\"}}" --output-name "output958" --resource-group "sjrg5176"

Tworzenie danych wyjściowych centrum zdarzeń za pomocą serializacji JSON

az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"eventHubName\":\"sdkeventhub\",\"partitionKey\":\"partitionKey\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"

Parametry wymagane

--job-name

Nazwa zadania przesyłania strumieniowego.

--name --output-name -n

Nazwa danych wyjściowych.

--resource-group -g

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

Parametry opcjonalne

--datasource

Opisuje źródło danych, do którego zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

--if-match

Element ETag danych wyjściowych. Pomiń tę wartość, aby zawsze zastąpić bieżące dane wyjś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 wyjściowych, ale aby zapobiec aktualizowaniu istniejących danych wyjściowych. Inne wartości spowodują odpowiedź 412 Warunek wstępny Niepowodzenie.

--serialization

Opisuje, jak dane z danych wejściowych są serializowane lub jak dane są serializowane podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

--size-window

Okno rozmiaru ograniczające dane wyjściowe usługi Stream Analytics.

--time-window

Przedział czasu filtrowania danych wyjściowych zadania usługi Stream Analytics.

az stream-analytics output delete

Usuń dane wyjściowe z zadania przesyłania strumieniowego.

az stream-analytics output delete --job-name
                                  --name
                                  --resource-group
                                  [--yes]

Przykłady

Usuwanie danych wyjściowych

az stream-analytics output delete --job-name "sj6458" --name "output1755" --resource-group "sjrg2157"

Parametry wymagane

--job-name

Nazwa zadania przesyłania strumieniowego.

--name --output-name -n

Nazwa danych wyjściowych.

--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 output list

Wyświetl listę wszystkich danych wyjściowych w ramach określonego zadania przesyłania strumieniowego.

az stream-analytics output list --job-name
                                --resource-group
                                [--select]

Przykłady

Wyświetlanie listy wszystkich danych wyjściowych w zadaniu przesyłania strumieniowego

az stream-analytics output list --job-name "sj6458" --resource-group "sjrg2157"

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 output show

Uzyskaj szczegółowe informacje o określonych danych wyjściowych.

az stream-analytics output show --job-name
                                --name
                                --resource-group

Przykłady

Pobieranie danych wyjściowych usługi DocumentDB

az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"

Pobieranie danych wyjściowych Power BI

az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"

Pobieranie danych wyjściowych kolejki Service Bus za pomocą serializacji Avro

az stream-analytics output show --job-name "sj5095" --output-name "output3456" --resource-group "sjrg3410"

Pobieranie danych wyjściowych tematu Service Bus przy użyciu serializacji CSV

az stream-analytics output show --job-name "sj7094" --output-name "output7886" --resource-group "sjrg6450"

Pobieranie danych wyjściowych obiektu blob z serializacji CSV

az stream-analytics output show --job-name "sj900" --output-name "output1623" --resource-group "sjrg5023"

Pobieranie danych wyjściowych usługi Azure Data Lake Store przy użyciu serializacji JSON

az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"

Pobieranie danych wyjściowych usługi Azure Data Warehouse

az stream-analytics output show --job-name "sjName" --output-name "output958" --resource-group "sjrg"

Pobieranie danych wyjściowych bazy danych Azure SQL

az stream-analytics output show --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"

Pobieranie danych wyjściowych tabeli platformy Azure

az stream-analytics output show --job-name "sj2790" --output-name "output958" --resource-group "sjrg5176"

Pobieranie danych wyjściowych centrum zdarzeń za pomocą serializacji JSON

az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"

Parametry wymagane

--job-name

Nazwa zadania przesyłania strumieniowego.

--name --output-name -n

Nazwa danych wyjściowych.

--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 output test

Przetestuj, czy źródło danych wyjściowych jest osiągalne i możliwe do użycia przez usługę Azure Stream Analytics.

az stream-analytics output test --job-name
                                --name
                                --resource-group
                                [--datasource]
                                [--no-wait]
                                [--serialization]
                                [--size-window]
                                [--time-window]

Przykłady

Testowanie połączenia dla danych wyjściowych

az stream-analytics output test --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"

Parametry wymagane

--job-name

Nazwa zadania przesyłania strumieniowego.

--name --output-name -n

Nazwa danych wyjściowych.

--resource-group -g

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

Parametry opcjonalne

--datasource

Opisuje źródło danych, do którego zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

--no-wait

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

--serialization

Opisuje, jak dane z danych wejściowych są serializowane lub jak dane są serializowane podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

--size-window

Okno rozmiaru ograniczające dane wyjściowe usługi Stream Analytics.

--time-window

Przedział czasu filtrowania danych wyjściowych zadania usługi Stream Analytics.

az stream-analytics output update

Zaktualizuj istniejące dane wyjściowe w ramach istniejącego zadania przesyłania strumieniowego. Może to służyć do częściowej aktualizacji (tj. zaktualizuj jedną lub dwie właściwości) dane wyjściowe bez wpływu na pozostałą część zadania lub definicję danych wyjściowych.

az stream-analytics output update --job-name
                                  --name
                                  --resource-group
                                  [--datasource]
                                  [--if-match]
                                  [--serialization]
                                  [--size-window]
                                  [--time-window]

Przykłady

Aktualizowanie danych wyjściowych usługi DocumentDB

az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output3022" --resource-group "sjrg7983"

Aktualizowanie danych wyjściowych Power BI

az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"differentDataset\"}}" --output-name "output3022" --resource-group "sjrg7983"

Aktualizowanie danych wyjściowych kolejki Service Bus za pomocą serializacji Avro

az stream-analytics output update --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"queueName\":\"differentQueueName\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output3456" --resource-group "sjrg3410"

Aktualizowanie danych wyjściowych tematu Service Bus przy użyciu serializacji CSV

az stream-analytics output update --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"topicName\":\"differentTopicName\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output7886" --resource-group "sjrg6450"

Aktualizowanie danych wyjściowych obiektu blob przy użyciu serializacji CSV

az stream-analytics output update --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output1623" --resource-group "sjrg5023"

Aktualizowanie danych wyjściowych usługi Azure Data Lake Store przy użyciu serializacji JSON

az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"differentaccount\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"

Aktualizowanie danych wyjściowych bazy danych Azure SQL

az stream-analytics output update --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"table\":\"differentTable\"}}" --output-name "output1755" --resource-group "sjrg2157"

Aktualizowanie danych wyjściowych tabeli platformy Azure

az stream-analytics output update --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output958" --resource-group "sjrg5176"

Aktualizowanie danych wyjściowych centrum zdarzeń przy użyciu serializacji JSON

az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"

Parametry wymagane

--job-name

Nazwa zadania przesyłania strumieniowego.

--name --output-name -n

Nazwa danych wyjściowych.

--resource-group -g

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

Parametry opcjonalne

--datasource

Opisuje źródło danych, do którego zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

--if-match

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

--serialization

Opisuje, jak dane z danych wejściowych są serializowane lub jak dane są serializowane podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace). Oczekiwana wartość: json-string/json-file/@json-file.

--size-window

Okno rozmiaru ograniczające dane wyjściowe usługi Stream Analytics.

--time-window

Przedział czasu filtrowania danych wyjściowych zadania usługi Stream Analytics.

az stream-analytics output wait

Umieść interfejs wiersza polecenia w stanie oczekiwania do momentu spełnienia warunku danych wyjściowych usługi Stream Analytics.

az stream-analytics output wait --job-name
                                --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 wyjściowych usługi Stream Analytics.

az stream-analytics output wait --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912" --created

Parametry wymagane

--job-name

Nazwa zadania przesyłania strumieniowego.

--name --output-name -n

Nazwa danych wyjściowych.

--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".