Dela via


az stream-analytics input

Note

Den här referensen är en del av stream-analytics-tillägget för Azure CLI (version 2.75.0 eller senare). Tillägget installeras automatiskt första gången du kör ett kommandot az stream-analytics input. Läs mer om tillägg.

Hantera indata med stream analytics.

Kommandon

Name Description Typ Status
az stream-analytics input create

Skapa en indata eller ersätt en redan befintlig indata under ett befintligt direktuppspelningsjobb.

Extension GA
az stream-analytics input delete

Ta bort indata från direktuppspelningsjobbet.

Extension GA
az stream-analytics input list

Visa en lista över alla indata under det angivna direktuppspelningsjobbet.

Extension GA
az stream-analytics input show

Hämta information om angivna indata.

Extension GA
az stream-analytics input test

Testa om en indatas datakälla kan nås och användas av Azure Stream Analytics-tjänsten.

Extension GA
az stream-analytics input update

Uppdatera en befintlig indata under ett befintligt direktuppspelningsjobb. Detta kan användas för att delvis uppdatera (dvs. uppdatera en eller två egenskaper) en indata utan att påverka resten av jobbet eller indatadefinitionen.

Extension GA
az stream-analytics input wait

Placera CLI i vänteläge tills ett villkor för indata för stream-analytics uppfylls.

Extension GA

az stream-analytics input create

Skapa en indata eller ersätt en redan befintlig indata under ett befintligt direktuppspelningsjobb.

az stream-analytics input create --input-name --name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--if-none-match]
                                 [--properties]

Exempel

Skapa en referensblobindata med CSV-serialisering

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"

Skapa en stream Event Hub-indata med JSON-serialisering

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"

Skapa en ström-IoT Hub-indata med Avro-serialisering

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"

Skapa en dataströmblobindata med CSV-serialisering

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"

Obligatoriska parametrar

--input-name --name -n

Namnet på indata.

--job-name

Namnet på strömningsjobbet.

--resource-group -g

Namn på resursgrupp. Du kan konfigurera standardgruppen med hjälp av az configure --defaults group=<name>.

Valfria parametrar

The following parameters are optional, but depending on the context, one or more might become required for the command to execute successfully.

--if-match

ETag för indata. Utelämna det här värdet för att alltid skriva över de aktuella indata. Ange det senast synliga ETag-värdet för att förhindra att samtidiga ändringar skrivs över av misstag.

--if-none-match

Ange till *för att tillåta att nya indata skapas, men för att förhindra uppdatering av befintliga indata. Andra värden resulterar i ett 412-förvillkor misslyckades svar.

--properties

De egenskaper som är associerade med indata. Krävs för PUT-begäranden (CreateOrReplace). Förväntat värde: json-string/json-file/@json-file.

Globala parametrar
--debug

Öka loggningsverositeten för att visa alla felsökningsloggar.

Egenskap Värde
Standardvärde: False
--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

Egenskap Värde
Standardvärde: False
--output -o

Utdataformat.

Egenskap Värde
Standardvärde: json
Godkända värden: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath-frågesträng. Mer http://jmespath.org/ information och exempel finns i.

--subscription

Namn eller ID för prenumeration. Du kan konfigurera standardprenumerationen med hjälp av az account set -s NAME_OR_ID.

--verbose

Öka loggningsverbositeten. Använd --debug för fullständiga felsökningsloggar.

Egenskap Värde
Standardvärde: False

az stream-analytics input delete

Ta bort indata från direktuppspelningsjobbet.

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

Exempel

Ta bort indata

az stream-analytics input delete --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Obligatoriska parametrar

--input-name --name -n

Namnet på indata.

--job-name

Namnet på strömningsjobbet.

--resource-group -g

Namn på resursgrupp. Du kan konfigurera standardgruppen med hjälp av az configure --defaults group=<name>.

Valfria parametrar

The following parameters are optional, but depending on the context, one or more might become required for the command to execute successfully.

--yes -y

Fråga inte efter bekräftelse.

Egenskap Värde
Standardvärde: False
Globala parametrar
--debug

Öka loggningsverositeten för att visa alla felsökningsloggar.

Egenskap Värde
Standardvärde: False
--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

Egenskap Värde
Standardvärde: False
--output -o

Utdataformat.

Egenskap Värde
Standardvärde: json
Godkända värden: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath-frågesträng. Mer http://jmespath.org/ information och exempel finns i.

--subscription

Namn eller ID för prenumeration. Du kan konfigurera standardprenumerationen med hjälp av az account set -s NAME_OR_ID.

--verbose

Öka loggningsverbositeten. Använd --debug för fullständiga felsökningsloggar.

Egenskap Värde
Standardvärde: False

az stream-analytics input list

Visa en lista över alla indata under det angivna direktuppspelningsjobbet.

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

Exempel

Visa en lista över alla indata i ett direktuppspelningsjobb

az stream-analytics input list --job-name "sj9597" --resource-group "sjrg8440"

Visa en lista över alla indata i ett direktuppspelningsjobb och inkludera diagnostikinformation med frågeparametern $select OData

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

Obligatoriska parametrar

--job-name

Namnet på strömningsjobbet.

--resource-group -g

Namn på resursgrupp. Du kan konfigurera standardgruppen med hjälp av az configure --defaults group=<name>.

Valfria parametrar

The following parameters are optional, but depending on the context, one or more might become required for the command to execute successfully.

--select

Frågeparametern $select OData. Det här är en kommaavgränsad lista över strukturella egenskaper som ska inkluderas i svaret, eller "" för att inkludera alla egenskaper. Som standard returneras alla egenskaper utom diagnostik. För närvarande accepteras endast "" som ett giltigt värde.

Globala parametrar
--debug

Öka loggningsverositeten för att visa alla felsökningsloggar.

Egenskap Värde
Standardvärde: False
--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

Egenskap Värde
Standardvärde: False
--output -o

Utdataformat.

Egenskap Värde
Standardvärde: json
Godkända värden: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath-frågesträng. Mer http://jmespath.org/ information och exempel finns i.

--subscription

Namn eller ID för prenumeration. Du kan konfigurera standardprenumerationen med hjälp av az account set -s NAME_OR_ID.

--verbose

Öka loggningsverbositeten. Använd --debug för fullständiga felsökningsloggar.

Egenskap Värde
Standardvärde: False

az stream-analytics input show

Hämta information om angivna indata.

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

Exempel

Hämta en referensblobindata med CSV-serialisering

az stream-analytics input show --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Hämta en händelsehubbindataström med JSON-serialisering

az stream-analytics input show --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Hämta en IoT Hub-indataström med Avro-serialisering

az stream-analytics input show --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Hämta en dataströmblobindata med CSV-serialisering

az stream-analytics input show --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Obligatoriska parametrar

--input-name --name -n

Namnet på indata.

--job-name

Namnet på strömningsjobbet.

--resource-group -g

Namn på resursgrupp. Du kan konfigurera standardgruppen med hjälp av az configure --defaults group=<name>.

Globala parametrar
--debug

Öka loggningsverositeten för att visa alla felsökningsloggar.

Egenskap Värde
Standardvärde: False
--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

Egenskap Värde
Standardvärde: False
--output -o

Utdataformat.

Egenskap Värde
Standardvärde: json
Godkända värden: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath-frågesträng. Mer http://jmespath.org/ information och exempel finns i.

--subscription

Namn eller ID för prenumeration. Du kan konfigurera standardprenumerationen med hjälp av az account set -s NAME_OR_ID.

--verbose

Öka loggningsverbositeten. Använd --debug för fullständiga felsökningsloggar.

Egenskap Värde
Standardvärde: False

az stream-analytics input test

Testa om en indatas datakälla kan nås och användas av Azure Stream Analytics-tjänsten.

az stream-analytics input test --input-name --name
                               --job-name
                               --resource-group
                               [--no-wait]
                               [--properties]

Exempel

Testa anslutningen för indata

az stream-analytics input test --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Obligatoriska parametrar

--input-name --name -n

Namnet på indata.

--job-name

Namnet på strömningsjobbet.

--resource-group -g

Namn på resursgrupp. Du kan konfigurera standardgruppen med hjälp av az configure --defaults group=<name>.

Valfria parametrar

The following parameters are optional, but depending on the context, one or more might become required for the command to execute successfully.

--no-wait

Vänta inte tills den långvariga åtgärden har slutförts.

Egenskap Värde
Standardvärde: False
--properties

De egenskaper som är associerade med indata. Krävs för PUT-begäranden (CreateOrReplace). Förväntat värde: json-string/json-file/@json-file.

Globala parametrar
--debug

Öka loggningsverositeten för att visa alla felsökningsloggar.

Egenskap Värde
Standardvärde: False
--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

Egenskap Värde
Standardvärde: False
--output -o

Utdataformat.

Egenskap Värde
Standardvärde: json
Godkända värden: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath-frågesträng. Mer http://jmespath.org/ information och exempel finns i.

--subscription

Namn eller ID för prenumeration. Du kan konfigurera standardprenumerationen med hjälp av az account set -s NAME_OR_ID.

--verbose

Öka loggningsverbositeten. Använd --debug för fullständiga felsökningsloggar.

Egenskap Värde
Standardvärde: False

az stream-analytics input update

Uppdatera en befintlig indata under ett befintligt direktuppspelningsjobb. Detta kan användas för att delvis uppdatera (dvs. uppdatera en eller två egenskaper) en indata utan att påverka resten av jobbet eller indatadefinitionen.

az stream-analytics input update --input-name --name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--properties]

Exempel

Uppdatera en referensblobindata

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"

Uppdatera indata för en dataströmhändelsehubb

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"

Uppdatera en ström-IoT Hub-indata

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"

Uppdatera indata för en dataströmblob

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"

Obligatoriska parametrar

--input-name --name -n

Namnet på indata.

--job-name

Namnet på strömningsjobbet.

--resource-group -g

Namn på resursgrupp. Du kan konfigurera standardgruppen med hjälp av az configure --defaults group=<name>.

Valfria parametrar

The following parameters are optional, but depending on the context, one or more might become required for the command to execute successfully.

--if-match

ETag för indata. Utelämna det här värdet för att alltid skriva över de aktuella indata. Ange det senast synliga ETag-värdet för att förhindra att samtidiga ändringar skrivs över av misstag.

--properties

De egenskaper som är associerade med indata. Krävs för PUT-begäranden (CreateOrReplace). Förväntat värde: json-string/json-file/@json-file.

Globala parametrar
--debug

Öka loggningsverositeten för att visa alla felsökningsloggar.

Egenskap Värde
Standardvärde: False
--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

Egenskap Värde
Standardvärde: False
--output -o

Utdataformat.

Egenskap Värde
Standardvärde: json
Godkända värden: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath-frågesträng. Mer http://jmespath.org/ information och exempel finns i.

--subscription

Namn eller ID för prenumeration. Du kan konfigurera standardprenumerationen med hjälp av az account set -s NAME_OR_ID.

--verbose

Öka loggningsverbositeten. Använd --debug för fullständiga felsökningsloggar.

Egenskap Värde
Standardvärde: False

az stream-analytics input wait

Placera CLI i vänteläge tills ett villkor för indata för stream-analytics uppfylls.

az stream-analytics input wait --input-name --name
                               --job-name
                               --resource-group
                               [--created]
                               [--custom]
                               [--deleted]
                               [--exists]
                               [--interval]
                               [--timeout]
                               [--updated]

Exempel

Pausa körningen av nästa rad i CLI-skriptet tills stream-analytics-indata har skapats.

az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created

Obligatoriska parametrar

--input-name --name -n

Namnet på indata.

--job-name

Namnet på strömningsjobbet.

--resource-group -g

Namn på resursgrupp. Du kan konfigurera standardgruppen med hjälp av az configure --defaults group=<name>.

Valfria parametrar

The following parameters are optional, but depending on the context, one or more might become required for the command to execute successfully.

--created

Vänta tills du har skapat med "provisioningState" på "Lyckades".

Egenskap Värde
Parameter group: Wait Condition Arguments
Standardvärde: False
--custom

Vänta tills villkoret uppfyller en anpassad JMESPath-fråga. T.ex. provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

Egenskap Värde
Parameter group: Wait Condition Arguments
--deleted

Vänta tills den har tagits bort.

Egenskap Värde
Parameter group: Wait Condition Arguments
Standardvärde: False
--exists

Vänta tills resursen finns.

Egenskap Värde
Parameter group: Wait Condition Arguments
Standardvärde: False
--interval

Avsökningsintervall i sekunder.

Egenskap Värde
Parameter group: Wait Condition Arguments
Standardvärde: 30
--timeout

Maximal väntetid i sekunder.

Egenskap Värde
Parameter group: Wait Condition Arguments
Standardvärde: 3600
--updated

Vänta tills det har uppdaterats med provisioningState på Lyckades.

Egenskap Värde
Parameter group: Wait Condition Arguments
Standardvärde: False
Globala parametrar
--debug

Öka loggningsverositeten för att visa alla felsökningsloggar.

Egenskap Värde
Standardvärde: False
--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

Egenskap Värde
Standardvärde: False
--output -o

Utdataformat.

Egenskap Värde
Standardvärde: json
Godkända värden: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath-frågesträng. Mer http://jmespath.org/ information och exempel finns i.

--subscription

Namn eller ID för prenumeration. Du kan konfigurera standardprenumerationen med hjälp av az account set -s NAME_OR_ID.

--verbose

Öka loggningsverbositeten. Använd --debug för fullständiga felsökningsloggar.

Egenskap Värde
Standardvärde: False