az stream-analytics input
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
Nome dell'input.
Nome del processo di streaming.
Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>
.
Parametri facoltativi
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.
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.
Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace). Valore previsto: json-string/json-file/@json-file.
Parametri globali
Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.
Visualizza questo messaggio della guida ed esce.
Mostra solo gli errori, eliminando gli avvisi.
Formato di output.
Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.
Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID
.
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
Nome dell'input.
Nome del processo di streaming.
Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>
.
Parametri facoltativi
Indica che non è richiesta la conferma.
Parametri globali
Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.
Visualizza questo messaggio della guida ed esce.
Mostra solo gli errori, eliminando gli avvisi.
Formato di output.
Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.
Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID
.
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
Nome del processo di streaming.
Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>
.
Parametri facoltativi
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
Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.
Visualizza questo messaggio della guida ed esce.
Mostra solo gli errori, eliminando gli avvisi.
Formato di output.
Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.
Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID
.
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
Nome dell'input.
Nome del processo di streaming.
Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>
.
Parametri globali
Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.
Visualizza questo messaggio della guida ed esce.
Mostra solo gli errori, eliminando gli avvisi.
Formato di output.
Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.
Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID
.
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
Nome dell'input.
Nome del processo di streaming.
Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>
.
Parametri facoltativi
Indica che non è necessario attendere il termine dell'operazione a esecuzione prolungata.
Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace). Valore previsto: json-string/json-file/@json-file.
Parametri globali
Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.
Visualizza questo messaggio della guida ed esce.
Mostra solo gli errori, eliminando gli avvisi.
Formato di output.
Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.
Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID
.
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
Nome dell'input.
Nome del processo di streaming.
Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>
.
Parametri facoltativi
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.
Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace). Valore previsto: json-string/json-file/@json-file.
Parametri globali
Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.
Visualizza questo messaggio della guida ed esce.
Mostra solo gli errori, eliminando gli avvisi.
Formato di output.
Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.
Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID
.
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
Nome dell'input.
Nome del processo di streaming.
Nome del gruppo di risorse. È possibile configurare il gruppo predefinito con az configure --defaults group=<name>
.
Parametri facoltativi
Attendere fino a quando non viene creato con 'provisioningState' in 'Succeeded'.
Attendere che la condizione soddisfi una query JMESPath personalizzata. Ad esempio provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
Attendere l'eliminazione.
Attendere che la risorsa esista.
Intervallo di polling in secondi.
Attesa massima in secondi.
Attendere fino a quando non viene aggiornato con provisioningState in 'Succeeded'.
Parametri globali
Aumenta il livello di dettaglio della registrazione per mostrare tutti i log di debug.
Visualizza questo messaggio della guida ed esce.
Mostra solo gli errori, eliminando gli avvisi.
Formato di output.
Stringa di query JMESPath. Per altre informazioni ed esempi, vedere http://jmespath.org/.
Nome o ID della sottoscrizione. È possibile configurare la sottoscrizione predefinita usando az account set -s NAME_OR_ID
.
Aumenta il livello di dettaglio della registrazione. Usare --debug per log di debug completi.