Share via

az stream-analytics input

  • Riferimento

Nota

Questo riferimento fa parte dell'estensione analisi di flusso per l'interfaccia della riga di comando di Azure (versione 2.15.0 o successiva). L'estensione installerà automaticamente la prima volta che si esegue un comando az stream-analytics input . Altre informazioni sulle estensioni.

Gestire l'input con l'analisi di flusso.

Comandi

Nome Descrizione Tipo Stato
az stream-analytics input create

Creare un input o sostituire un input già esistente in un processo di streaming esistente.

 Estensione Disponibilità generale
az stream-analytics input delete

Eliminare un input dal processo di streaming.

 Estensione Disponibilità generale
az stream-analytics input list

Elencare tutti gli input nel processo di streaming specificato.

 Estensione Disponibilità generale
az stream-analytics input show

Ottenere informazioni dettagliate sull'input specificato.

 Estensione Disponibilità generale
az stream-analytics input test

Verificare se l'origine dati di un input è raggiungibile e utilizzabile dal servizio Analisi di flusso di Azure.

 Estensione Disponibilità generale
az stream-analytics input update

Aggiornare un input esistente in un processo di streaming esistente. Può essere usato per aggiornare parzialmente (ad esempio, aggiornare una o due proprietà) un input senza influire sul resto del processo o della definizione di input.

 Estensione Disponibilità generale
az stream-analytics input wait

Posizionare l'interfaccia della riga di comando in uno stato di attesa fino a quando non viene soddisfatta una condizione dell'input di Analisi di flusso.

 Estensione Disponibilità generale

az stream-analytics input create

Creare un input o sostituire un input già esistente in un processo di streaming esistente.

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

Esempio

Creare un input BLOB di riferimento con la serializzazione 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"

Creare un input dell'hub eventi di flusso con la serializzazione 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"

Creare un flusso hub IoT input con la serializzazione 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"

Creare un input BLOB di flusso con la serializzazione 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"

Parametri necessari

--input-name --name -n

Nome dell'input.

--job-name

Nome del processo di streaming.

--resource-group -g

Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>.

Parametri facoltativi

--if-match

ETag dell'input. Omettere questo valore per sovrascrivere sempre l'input corrente. Specificare l'ultimo valore ETag visualizzato per impedire la sovrascrittura accidentale delle modifiche simultanee.

--if-none-match

Impostare su '*' per consentire la creazione di un nuovo input, ma per impedire l'aggiornamento di un input esistente. Gli altri valori generano una risposta 412 Pre-condition Failed.

--properties

Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace). Valore previsto: json-string/json-file/@json-file.

Parametri globali
--debug

Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.

--help -h

Visualizza questo messaggio della guida ed esce.

--only-show-errors

Mostra solo gli errori, eliminando gli avvisi.

--output -o

Formato di output.

valori accettati: json, jsonc, none, table, tsv, yaml, yamlc
valore predefinito: json
--query

Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.

--subscription

Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID.

--verbose

Aumenta il livello di dettaglio della registrazione. Usare --debug per log di debug completi.

az stream-analytics input delete

Eliminare un input dal processo di streaming.

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

Esempio

Eliminare un input

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

Parametri necessari

--input-name --name -n

Nome dell'input.

--job-name

Nome del processo di streaming.

--resource-group -g

Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>.

Parametri facoltativi

--yes -y

Indica che non è richiesta la conferma.

valore predefinito: False
Parametri globali
--debug

Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.

--help -h

Visualizza questo messaggio della guida ed esce.

--only-show-errors

Mostra solo gli errori, eliminando gli avvisi.

--output -o

Formato di output.

valori accettati: json, jsonc, none, table, tsv, yaml, yamlc
valore predefinito: json
--query

Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.

--subscription

Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID.

--verbose

Aumenta il livello di dettaglio della registrazione. Usare --debug per log di debug completi.

az stream-analytics input list

Elencare tutti gli input nel processo di streaming specificato.

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

Esempio

Elencare tutti gli input in un processo di streaming

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

Elencare tutti gli input in un processo di streaming e includere le informazioni di diagnostica usando il parametro di query OData $select

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

Parametri necessari

--job-name

Nome del processo di streaming.

--resource-group -g

Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>.

Parametri facoltativi

--select

Parametro di query OData $select. Si tratta di un elenco delimitato da virgole di proprietà strutturali da includere nella risposta o "" per includere tutte le proprietà. Per impostazione predefinita, vengono restituite tutte le proprietà tranne la diagnostica. Attualmente accetta solo '' come valore valido.

Parametri globali
--debug

Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.

--help -h

Visualizza questo messaggio della guida ed esce.

--only-show-errors

Mostra solo gli errori, eliminando gli avvisi.

--output -o

Formato di output.

valori accettati: json, jsonc, none, table, tsv, yaml, yamlc
valore predefinito: json
--query

Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.

--subscription

Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID.

--verbose

Aumenta il livello di dettaglio della registrazione. Usare --debug per log di debug completi.

az stream-analytics input show

Ottenere informazioni dettagliate sull'input specificato.

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

Esempio

Ottenere un input BLOB di riferimento con la serializzazione CSV

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

Ottenere un input dell'hub eventi di flusso con la serializzazione JSON

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

Ottenere un input hub IoT flusso con la serializzazione Avro

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

Ottenere un input blob di flusso con la serializzazione CSV

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

Parametri necessari

--input-name --name -n

Nome dell'input.

--job-name

Nome del processo di streaming.

--resource-group -g

Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>.

Parametri globali
--debug

Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.

--help -h

Visualizza questo messaggio della guida ed esce.

--only-show-errors

Mostra solo gli errori, eliminando gli avvisi.

--output -o

Formato di output.

valori accettati: json, jsonc, none, table, tsv, yaml, yamlc
valore predefinito: json
--query

Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.

--subscription

Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID.

--verbose

Aumenta il livello di dettaglio della registrazione. Usare --debug per log di debug completi.

az stream-analytics input test

Verificare se l'origine dati di un input è raggiungibile e utilizzabile dal servizio Analisi di flusso di Azure.

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

Esempio

Testare la connessione per un input

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

Parametri necessari

--input-name --name -n

Nome dell'input.

--job-name

Nome del processo di streaming.

--resource-group -g

Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>.

Parametri facoltativi

--no-wait

Indica che non è necessario attendere il termine dell'operazione a esecuzione prolungata.

valore predefinito: False
--properties

Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace). Valore previsto: json-string/json-file/@json-file.

Parametri globali
--debug

Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.

--help -h

Visualizza questo messaggio della guida ed esce.

--only-show-errors

Mostra solo gli errori, eliminando gli avvisi.

--output -o

Formato di output.

valori accettati: json, jsonc, none, table, tsv, yaml, yamlc
valore predefinito: json
--query

Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.

--subscription

Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID.

--verbose

Aumenta il livello di dettaglio della registrazione. Usare --debug per log di debug completi.

az stream-analytics input update

Aggiornare un input esistente in un processo di streaming esistente. Può essere usato per aggiornare parzialmente (ad esempio, aggiornare una o due proprietà) un input senza influire sul resto del processo o della definizione di input.

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

Esempio

Aggiornare un input BLOB di riferimento

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"

Aggiornare un input dell'hub eventi di flusso

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"

Aggiornare un input hub IoT flusso

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"

Aggiornare un input blob di flusso

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"

Parametri necessari

--input-name --name -n

Nome dell'input.

--job-name

Nome del processo di streaming.

--resource-group -g

Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>.

Parametri facoltativi

--if-match

ETag dell'input. Omettere questo valore per sovrascrivere sempre l'input corrente. Specificare l'ultimo valore ETag visualizzato per impedire la sovrascrittura accidentale delle modifiche simultanee.

--properties

Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace). Valore previsto: json-string/json-file/@json-file.

Parametri globali
--debug

Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.

--help -h

Visualizza questo messaggio della guida ed esce.

--only-show-errors

Mostra solo gli errori, eliminando gli avvisi.

--output -o

Formato di output.

valori accettati: json, jsonc, none, table, tsv, yaml, yamlc
valore predefinito: json
--query

Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.

--subscription

Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID.

--verbose

Aumenta il livello di dettaglio della registrazione. Usare --debug per log di debug completi.

az stream-analytics input wait

Posizionare l'interfaccia della riga di comando in uno stato di attesa fino a quando non viene soddisfatta una condizione dell'input di Analisi di flusso.

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

Esempio

Sospendere l'esecuzione della riga di comando successiva dello script dell'interfaccia della riga di comando fino a quando non viene creato correttamente l'input di Analisi di flusso.

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

Parametri necessari

--input-name --name -n

Nome dell'input.

--job-name

Nome del processo di streaming.

--resource-group -g

Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>.

Parametri facoltativi

--created

Attendere fino a quando non viene creato con 'provisioningState' in 'Succeeded'.

valore predefinito: False
--custom

Attendere che la condizione soddisfi una query JMESPath personalizzata. Ad esempio provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

--deleted

Attendere l'eliminazione.

valore predefinito: False
--exists

Attendere che la risorsa esista.

valore predefinito: False
--interval

Intervallo di polling in secondi.

valore predefinito: 30
--timeout

Attesa massima in secondi.

valore predefinito: 3600
--updated

Attendere fino a quando non viene aggiornato con provisioningState in 'Succeeded'.

valore predefinito: False
Parametri globali
--debug

Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.

--help -h

Visualizza questo messaggio della guida ed esce.

--only-show-errors

Mostra solo gli errori, eliminando gli avvisi.

--output -o

Formato di output.

valori accettati: json, jsonc, none, table, tsv, yaml, yamlc
valore predefinito: json
--query

Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.

--subscription

Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID.

--verbose

Aumenta il livello di dettaglio della registrazione. Usare --debug per log di debug completi.