Dela via

az stream-analytics input

  • Referens

Kommentar

Den här referensen är en del av stream-analytics-tillägget för Azure CLI (version 2.15.0 eller senare). Tillägget installeras automatiskt första gången du kör ett az stream-analytics-indatakommando . 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.

 Anknytning GA
az stream-analytics input delete

Ta bort indata från direktuppspelningsjobbet.

 Anknytning GA
az stream-analytics input list

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

 Anknytning GA
az stream-analytics input show

Hämta information om angivna indata.

 Anknytning GA
az stream-analytics input test

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

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

 Anknytning GA
az stream-analytics input wait

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

 Anknytning 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
                                 --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

Namnet på resursgruppen. Du kan konfigurera standardgruppen med .az configure --defaults group=<name>

Valfria parametrar

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

--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

--output -o

Utdataformat.

accepterade värden: json, jsonc, none, table, tsv, yaml, yamlc
standardvärde: json
--query

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

--subscription

Namn eller ID för prenumerationen. Du kan konfigurera standardprenumerationen med .az account set -s NAME_OR_ID

--verbose

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

az stream-analytics input delete

Ta bort indata från direktuppspelningsjobbet.

az stream-analytics input delete --input-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

Namnet på resursgruppen. Du kan konfigurera standardgruppen med .az configure --defaults group=<name>

Valfria parametrar

--yes -y

Fråga inte efter bekräftelse.

standardvärde: False
Globala parametrar
--debug

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

--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

--output -o

Utdataformat.

accepterade värden: json, jsonc, none, table, tsv, yaml, yamlc
standardvärde: json
--query

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

--subscription

Namn eller ID för prenumerationen. Du kan konfigurera standardprenumerationen med .az account set -s NAME_OR_ID

--verbose

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

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

Namnet på resursgruppen. Du kan konfigurera standardgruppen med .az configure --defaults group=<name>

Valfria parametrar

--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. Accepterar för närvarande endast "" som ett giltigt värde.

Globala parametrar
--debug

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

--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

--output -o

Utdataformat.

accepterade värden: json, jsonc, none, table, tsv, yaml, yamlc
standardvärde: json
--query

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

--subscription

Namn eller ID för prenumerationen. Du kan konfigurera standardprenumerationen med .az account set -s NAME_OR_ID

--verbose

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

az stream-analytics input show

Hämta information om angivna indata.

az stream-analytics input show --input-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

Namnet på resursgruppen. Du kan konfigurera standardgruppen med .az configure --defaults group=<name>

Globala parametrar
--debug

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

--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

--output -o

Utdataformat.

accepterade värden: json, jsonc, none, table, tsv, yaml, yamlc
standardvärde: json
--query

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

--subscription

Namn eller ID för prenumerationen. Du kan konfigurera standardprenumerationen med .az account set -s NAME_OR_ID

--verbose

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

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

Namnet på resursgruppen. Du kan konfigurera standardgruppen med .az configure --defaults group=<name>

Valfria parametrar

--no-wait

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

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.

--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

--output -o

Utdataformat.

accepterade värden: json, jsonc, none, table, tsv, yaml, yamlc
standardvärde: json
--query

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

--subscription

Namn eller ID för prenumerationen. Du kan konfigurera standardprenumerationen med .az account set -s NAME_OR_ID

--verbose

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

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

Namnet på resursgruppen. Du kan konfigurera standardgruppen med .az configure --defaults group=<name>

Valfria parametrar

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

--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

--output -o

Utdataformat.

accepterade värden: json, jsonc, none, table, tsv, yaml, yamlc
standardvärde: json
--query

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

--subscription

Namn eller ID för prenumerationen. Du kan konfigurera standardprenumerationen med .az account set -s NAME_OR_ID

--verbose

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

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

Namnet på resursgruppen. Du kan konfigurera standardgruppen med .az configure --defaults group=<name>

Valfria parametrar

--created

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

standardvärde: False
--custom

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

--deleted

Vänta tills den har tagits bort.

standardvärde: False
--exists

Vänta tills resursen finns.

standardvärde: False
--interval

Avsökningsintervall i sekunder.

standardvärde: 30
--timeout

Maximal väntetid i sekunder.

standardvärde: 3600
--updated

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

standardvärde: False
Globala parametrar
--debug

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

--help -h

Visa det här hjälpmeddelandet och avsluta.

--only-show-errors

Visa bara fel och ignorera varningar.

--output -o

Utdataformat.

accepterade värden: json, jsonc, none, table, tsv, yaml, yamlc
standardvärde: json
--query

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

--subscription

Namn eller ID för prenumerationen. Du kan konfigurera standardprenumerationen med .az account set -s NAME_OR_ID

--verbose

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