Delen via

az stream-analytics input

  • Referentie

Notitie

Deze verwijzing maakt deel uit van de stream-analytics-extensie voor de Azure CLI (versie 2.15.0 of hoger). De extensie installeert automatisch de eerste keer dat u een az stream-analytics-invoeropdracht uitvoert. Meer informatie over extensies.

Beheer invoer met Stream Analytics.

Opdracht

Name Description Type Status
az stream-analytics input create

Maak een invoer of vervang een al bestaande invoer onder een bestaande streamingtaak.

 Toestel GA
az stream-analytics input delete

Verwijder een invoer uit de streamingtaak.

 Toestel GA
az stream-analytics input list

Geef alle invoer weer onder de opgegeven streamingtaak.

 Toestel GA
az stream-analytics input show

Meer informatie over de opgegeven invoer.

 Toestel GA
az stream-analytics input test

Test of de gegevensbron van een invoer bereikbaar en bruikbaar is door de Azure Stream Analytics-service.

 Toestel GA
az stream-analytics input update

Werk een bestaande invoer bij onder een bestaande streamingtaak. Dit kan worden gebruikt om een invoer gedeeltelijk bij te werken (bijvoorbeeld om een of twee eigenschappen bij te werken) zonder dat dit van invloed is op de rest van de taak of invoerdefinitie.

 Toestel GA
az stream-analytics input wait

Plaats de CLI in een wachtstatus totdat aan een voorwaarde van de stream-analytics-invoer wordt voldaan.

 Toestel GA

az stream-analytics input create

Maak een invoer of vervang een al bestaande invoer onder een bestaande streamingtaak.

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

Voorbeelden

Een verwijzingsblobinvoer maken met CSV-serialisatie

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"

Een Event Hub-stroominvoer maken met JSON-serialisatie

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"

Een IoT Hub-stroominvoer maken met Avro-serialisatie

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"

Een stroomblobinvoer maken met CSV-serialisatie

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"

Vereiste parameters

--input-name --name -n

De naam van de invoer.

--job-name

De naam van de streamingtaak.

--resource-group -g

De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.

Optionele parameters

--if-match

De ETag van de invoer. Laat deze waarde weg om altijd de huidige invoer te overschrijven. Geef de laatst geziene ETag-waarde op om te voorkomen dat gelijktijdige wijzigingen per ongeluk worden overschreven.

--if-none-match

Stel deze optie in op *om toe te staan dat er nieuwe invoer wordt gemaakt, maar om te voorkomen dat een bestaande invoer wordt bijgewerkt. Andere waarden resulteren in een reactie van 412 Pre-condition Failed.

--properties

De eigenschappen die zijn gekoppeld aan een invoer. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.

Globale parameters
--debug

Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.

--help -h

Dit Help-bericht weergeven en afsluiten.

--only-show-errors

Alleen fouten weergeven, waarschuwingen onderdrukken.

--output -o

Uitvoerindeling.

geaccepteerde waarden: json, jsonc, none, table, tsv, yaml, yamlc
standaardwaarde: json
--query

JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.

--subscription

Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.

--verbose

Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.

az stream-analytics input delete

Verwijder een invoer uit de streamingtaak.

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

Voorbeelden

Een invoer verwijderen

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

Vereiste parameters

--input-name --name -n

De naam van de invoer.

--job-name

De naam van de streamingtaak.

--resource-group -g

De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.

Optionele parameters

--yes -y

Niet vragen om bevestiging.

standaardwaarde: False
Globale parameters
--debug

Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.

--help -h

Dit Help-bericht weergeven en afsluiten.

--only-show-errors

Alleen fouten weergeven, waarschuwingen onderdrukken.

--output -o

Uitvoerindeling.

geaccepteerde waarden: json, jsonc, none, table, tsv, yaml, yamlc
standaardwaarde: json
--query

JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.

--subscription

Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.

--verbose

Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.

az stream-analytics input list

Geef alle invoer weer onder de opgegeven streamingtaak.

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

Voorbeelden

Alle invoer in een streamingtaak weergeven

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

Alle invoer in een streamingtaak weergeven en diagnostische gegevens opnemen met behulp van de $select OData-queryparameter

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

Vereiste parameters

--job-name

De naam van de streamingtaak.

--resource-group -g

De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.

Optionele parameters

--select

De $select OData-queryparameter. Dit is een door komma's gescheiden lijst met structurele eigenschappen die moeten worden opgenomen in het antwoord of '' om alle eigenschappen op te nemen. Standaard worden alle eigenschappen geretourneerd, behalve diagnostische gegevens. Accepteert momenteel alleen '' als een geldige waarde.

Globale parameters
--debug

Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.

--help -h

Dit Help-bericht weergeven en afsluiten.

--only-show-errors

Alleen fouten weergeven, waarschuwingen onderdrukken.

--output -o

Uitvoerindeling.

geaccepteerde waarden: json, jsonc, none, table, tsv, yaml, yamlc
standaardwaarde: json
--query

JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.

--subscription

Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.

--verbose

Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.

az stream-analytics input show

Meer informatie over de opgegeven invoer.

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

Voorbeelden

Een verwijzingsblobinvoer ophalen met CSV-serialisatie

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

Een Event Hub-stroominvoer ophalen met JSON-serialisatie

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

Een IoT Hub-stroominvoer ophalen met Avro-serialisatie

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

Een stroomblobinvoer ophalen met CSV-serialisatie

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

Vereiste parameters

--input-name --name -n

De naam van de invoer.

--job-name

De naam van de streamingtaak.

--resource-group -g

De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.

Globale parameters
--debug

Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.

--help -h

Dit Help-bericht weergeven en afsluiten.

--only-show-errors

Alleen fouten weergeven, waarschuwingen onderdrukken.

--output -o

Uitvoerindeling.

geaccepteerde waarden: json, jsonc, none, table, tsv, yaml, yamlc
standaardwaarde: json
--query

JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.

--subscription

Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.

--verbose

Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.

az stream-analytics input test

Test of de gegevensbron van een invoer bereikbaar en bruikbaar is door de Azure Stream Analytics-service.

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

Voorbeelden

De verbinding voor een invoer testen

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

Vereiste parameters

--input-name --name -n

De naam van de invoer.

--job-name

De naam van de streamingtaak.

--resource-group -g

De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.

Optionele parameters

--no-wait

Wacht niet totdat de langdurige bewerking is voltooid.

standaardwaarde: False
--properties

De eigenschappen die zijn gekoppeld aan een invoer. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.

Globale parameters
--debug

Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.

--help -h

Dit Help-bericht weergeven en afsluiten.

--only-show-errors

Alleen fouten weergeven, waarschuwingen onderdrukken.

--output -o

Uitvoerindeling.

geaccepteerde waarden: json, jsonc, none, table, tsv, yaml, yamlc
standaardwaarde: json
--query

JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.

--subscription

Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.

--verbose

Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.

az stream-analytics input update

Werk een bestaande invoer bij onder een bestaande streamingtaak. Dit kan worden gebruikt om een invoer gedeeltelijk bij te werken (bijvoorbeeld om een of twee eigenschappen bij te werken) zonder dat dit van invloed is op de rest van de taak of invoerdefinitie.

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

Voorbeelden

Een verwijzingsblobinvoer bijwerken

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"

Een Event Hub-invoer voor een stream bijwerken

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"

Een IoT Hub-invoer voor een stream bijwerken

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"

Een stroomblobinvoer bijwerken

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"

Vereiste parameters

--input-name --name -n

De naam van de invoer.

--job-name

De naam van de streamingtaak.

--resource-group -g

De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.

Optionele parameters

--if-match

De ETag van de invoer. Laat deze waarde weg om altijd de huidige invoer te overschrijven. Geef de laatst geziene ETag-waarde op om te voorkomen dat gelijktijdige wijzigingen per ongeluk worden overschreven.

--properties

De eigenschappen die zijn gekoppeld aan een invoer. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.

Globale parameters
--debug

Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.

--help -h

Dit Help-bericht weergeven en afsluiten.

--only-show-errors

Alleen fouten weergeven, waarschuwingen onderdrukken.

--output -o

Uitvoerindeling.

geaccepteerde waarden: json, jsonc, none, table, tsv, yaml, yamlc
standaardwaarde: json
--query

JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.

--subscription

Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.

--verbose

Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.

az stream-analytics input wait

Plaats de CLI in een wachtstatus totdat aan een voorwaarde van de stream-analytics-invoer wordt voldaan.

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

Voorbeelden

Pauzeer het uitvoeren van de volgende regel van het CLI-script totdat de stream-analytics-invoer is gemaakt.

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

Vereiste parameters

--input-name --name -n

De naam van de invoer.

--job-name

De naam van de streamingtaak.

--resource-group -g

De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.

Optionele parameters

--created

Wacht totdat u 'provisioningState' hebt gemaakt bij 'Succeeded'.

standaardwaarde: False
--custom

Wacht tot de voorwaarde voldoet aan een aangepaste JMESPath-query. Bijvoorbeeld provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

--deleted

Wacht totdat deze is verwijderd.

standaardwaarde: False
--exists

Wacht tot de resource bestaat.

standaardwaarde: False
--interval

Polling-interval in seconden.

standaardwaarde: 30
--timeout

Maximale wachttijd in seconden.

standaardwaarde: 3600
--updated

Wacht totdat deze is bijgewerkt met provisioningState op 'Succeeded'.

standaardwaarde: False
Globale parameters
--debug

Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.

--help -h

Dit Help-bericht weergeven en afsluiten.

--only-show-errors

Alleen fouten weergeven, waarschuwingen onderdrukken.

--output -o

Uitvoerindeling.

geaccepteerde waarden: json, jsonc, none, table, tsv, yaml, yamlc
standaardwaarde: json
--query

JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.

--subscription

Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.

--verbose

Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.