Share via

az stream-analytics input

  • Referência

Nota

Essa referência faz parte da extensão de análise de fluxo para a CLI do Azure (versão 2.15.0 ou superior). A extensão será instalada automaticamente na primeira vez que você executar um comando de entrada az stream-analytics. Saiba mais sobre extensões.

Gerencie a entrada com análises de fluxo.

Comandos

Name Description Tipo Estado
az stream-analytics input create

Crie uma entrada ou substitua uma entrada já existente em um trabalho de streaming existente.

 Extensão Disponibilidade Geral
az stream-analytics input delete

Exclua uma entrada do trabalho de streaming.

 Extensão Disponibilidade Geral
az stream-analytics input list

Liste todas as entradas no trabalho de streaming especificado.

 Extensão Disponibilidade Geral
az stream-analytics input show

Obtenha detalhes sobre a entrada especificada.

 Extensão Disponibilidade Geral
az stream-analytics input test

Teste se a fonte de dados de uma entrada é acessível e utilizável pelo serviço Azure Stream Analytics.

 Extensão Disponibilidade Geral
az stream-analytics input update

Atualize uma entrada existente em um trabalho de streaming existente. Isso pode ser usado para atualizar parcialmente (ou seja, atualizar uma ou duas propriedades) uma entrada sem afetar o resto do trabalho ou a definição de entrada.

 Extensão Disponibilidade Geral
az stream-analytics input wait

Coloque a CLI em um estado de espera até que uma condição da entrada de análise de fluxo seja atendida.

 Extensão Disponibilidade Geral

az stream-analytics input create

Crie uma entrada ou substitua uma entrada já existente em um trabalho de streaming existente.

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

Exemplos

Criar uma entrada de blob de referência com serialização 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"

Criar uma entrada de fluxo do Hub de Eventos com serialização 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"

Criar uma entrada de fluxo do Hub IoT com serialização 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"

Criar uma entrada de blob de fluxo com serialização 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"

Parâmetros Obrigatórios

--input-name --name -n

O nome da entrada.

--job-name

O nome do trabalho de streaming.

--resource-group -g

o nome do grupo de recursos. Você pode configurar o grupo padrão usando az configure --defaults group=<name>.

Parâmetros Opcionais

--if-match

O ETag da entrada. Omita esse valor para sempre substituir a entrada atual. Especifique o valor ETag visto pela última vez para evitar a substituição acidental de alterações simultâneas.

--if-none-match

Defina como '*' para permitir que uma nova entrada seja criada, mas para impedir a atualização de uma entrada existente. Outros valores resultarão em uma resposta com falha na pré-condição 412.

--properties

As propriedades associadas a uma entrada. Necessário em solicitações PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.

Parâmetros de Globais
--debug

Aumente a verbosidade do log para mostrar todos os logs de depuração.

--help -h

Mostrar esta mensagem de ajuda e sair.

--only-show-errors

Mostrar apenas erros, suprimindo avisos.

--output -o

Formato de saída.

valores aceites: json, jsonc, none, table, tsv, yaml, yamlc
valor predefinido: json
--query

Cadeia de caracteres de consulta JMESPath. Consulte http://jmespath.org/ para obter mais informações e exemplos.

--subscription

o nome ou o ID da subscrição. Você pode configurar a assinatura padrão usando az account set -s NAME_OR_IDo .

--verbose

Aumente a verbosidade do registro. Use --debug para logs de depuração completos.

az stream-analytics input delete

Exclua uma entrada do trabalho de streaming.

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

Exemplos

Excluir uma entrada

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

Parâmetros Obrigatórios

--input-name --name -n

O nome da entrada.

--job-name

O nome do trabalho de streaming.

--resource-group -g

o nome do grupo de recursos. Você pode configurar o grupo padrão usando az configure --defaults group=<name>.

Parâmetros Opcionais

--yes -y

Não solicite confirmação.

valor predefinido: False
Parâmetros de Globais
--debug

Aumente a verbosidade do log para mostrar todos os logs de depuração.

--help -h

Mostrar esta mensagem de ajuda e sair.

--only-show-errors

Mostrar apenas erros, suprimindo avisos.

--output -o

Formato de saída.

valores aceites: json, jsonc, none, table, tsv, yaml, yamlc
valor predefinido: json
--query

Cadeia de caracteres de consulta JMESPath. Consulte http://jmespath.org/ para obter mais informações e exemplos.

--subscription

o nome ou o ID da subscrição. Você pode configurar a assinatura padrão usando az account set -s NAME_OR_IDo .

--verbose

Aumente a verbosidade do registro. Use --debug para logs de depuração completos.

az stream-analytics input list

Liste todas as entradas no trabalho de streaming especificado.

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

Exemplos

Listar todas as entradas em um trabalho de streaming

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

Listar todas as entradas em um trabalho de streaming e incluir informações de diagnóstico usando o parâmetro de consulta OData $select

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

Parâmetros Obrigatórios

--job-name

O nome do trabalho de streaming.

--resource-group -g

o nome do grupo de recursos. Você pode configurar o grupo padrão usando az configure --defaults group=<name>.

Parâmetros Opcionais

--select

O $select parâmetro de consulta OData. Esta é uma lista separada por vírgulas de propriedades estruturais para incluir na resposta, ou "" para incluir todas as propriedades. Por padrão, todas as propriedades são retornadas, exceto diagnósticos. Atualmente só aceita '' como um valor válido.

Parâmetros de Globais
--debug

Aumente a verbosidade do log para mostrar todos os logs de depuração.

--help -h

Mostrar esta mensagem de ajuda e sair.

--only-show-errors

Mostrar apenas erros, suprimindo avisos.

--output -o

Formato de saída.

valores aceites: json, jsonc, none, table, tsv, yaml, yamlc
valor predefinido: json
--query

Cadeia de caracteres de consulta JMESPath. Consulte http://jmespath.org/ para obter mais informações e exemplos.

--subscription

o nome ou o ID da subscrição. Você pode configurar a assinatura padrão usando az account set -s NAME_OR_IDo .

--verbose

Aumente a verbosidade do registro. Use --debug para logs de depuração completos.

az stream-analytics input show

Obtenha detalhes sobre a entrada especificada.

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

Exemplos

Obter uma entrada de blob de referência com serialização CSV

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

Obter uma entrada de fluxo do Hub de Eventos com serialização JSON

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

Obter uma entrada de fluxo do Hub IoT com a serialização Avro

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

Obter uma entrada de blob de fluxo com serialização CSV

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

Parâmetros Obrigatórios

--input-name --name -n

O nome da entrada.

--job-name

O nome do trabalho de streaming.

--resource-group -g

o nome do grupo de recursos. Você pode configurar o grupo padrão usando az configure --defaults group=<name>.

Parâmetros de Globais
--debug

Aumente a verbosidade do log para mostrar todos os logs de depuração.

--help -h

Mostrar esta mensagem de ajuda e sair.

--only-show-errors

Mostrar apenas erros, suprimindo avisos.

--output -o

Formato de saída.

valores aceites: json, jsonc, none, table, tsv, yaml, yamlc
valor predefinido: json
--query

Cadeia de caracteres de consulta JMESPath. Consulte http://jmespath.org/ para obter mais informações e exemplos.

--subscription

o nome ou o ID da subscrição. Você pode configurar a assinatura padrão usando az account set -s NAME_OR_IDo .

--verbose

Aumente a verbosidade do registro. Use --debug para logs de depuração completos.

az stream-analytics input test

Teste se a fonte de dados de uma entrada é acessível e utilizável pelo serviço Azure Stream Analytics.

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

Exemplos

Testar a conexão para uma entrada

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

Parâmetros Obrigatórios

--input-name --name -n

O nome da entrada.

--job-name

O nome do trabalho de streaming.

--resource-group -g

o nome do grupo de recursos. Você pode configurar o grupo padrão usando az configure --defaults group=<name>.

Parâmetros Opcionais

--no-wait

Não espere que a operação de longa duração termine.

valor predefinido: False
--properties

As propriedades associadas a uma entrada. Necessário em solicitações PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.

Parâmetros de Globais
--debug

Aumente a verbosidade do log para mostrar todos os logs de depuração.

--help -h

Mostrar esta mensagem de ajuda e sair.

--only-show-errors

Mostrar apenas erros, suprimindo avisos.

--output -o

Formato de saída.

valores aceites: json, jsonc, none, table, tsv, yaml, yamlc
valor predefinido: json
--query

Cadeia de caracteres de consulta JMESPath. Consulte http://jmespath.org/ para obter mais informações e exemplos.

--subscription

o nome ou o ID da subscrição. Você pode configurar a assinatura padrão usando az account set -s NAME_OR_IDo .

--verbose

Aumente a verbosidade do registro. Use --debug para logs de depuração completos.

az stream-analytics input update

Atualize uma entrada existente em um trabalho de streaming existente. Isso pode ser usado para atualizar parcialmente (ou seja, atualizar uma ou duas propriedades) uma entrada sem afetar o resto do trabalho ou a definição de entrada.

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

Exemplos

Atualizar uma entrada de blob de referência

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"

Atualizar uma entrada do Hub de Eventos de fluxo

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"

Atualizar uma entrada do Hub IoT de fluxo

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"

Atualizar uma entrada de blob de fluxo

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"

Parâmetros Obrigatórios

--input-name --name -n

O nome da entrada.

--job-name

O nome do trabalho de streaming.

--resource-group -g

o nome do grupo de recursos. Você pode configurar o grupo padrão usando az configure --defaults group=<name>.

Parâmetros Opcionais

--if-match

O ETag da entrada. Omita esse valor para sempre substituir a entrada atual. Especifique o valor ETag visto pela última vez para evitar a substituição acidental de alterações simultâneas.

--properties

As propriedades associadas a uma entrada. Necessário em solicitações PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.

Parâmetros de Globais
--debug

Aumente a verbosidade do log para mostrar todos os logs de depuração.

--help -h

Mostrar esta mensagem de ajuda e sair.

--only-show-errors

Mostrar apenas erros, suprimindo avisos.

--output -o

Formato de saída.

valores aceites: json, jsonc, none, table, tsv, yaml, yamlc
valor predefinido: json
--query

Cadeia de caracteres de consulta JMESPath. Consulte http://jmespath.org/ para obter mais informações e exemplos.

--subscription

o nome ou o ID da subscrição. Você pode configurar a assinatura padrão usando az account set -s NAME_OR_IDo .

--verbose

Aumente a verbosidade do registro. Use --debug para logs de depuração completos.

az stream-analytics input wait

Coloque a CLI em um estado de espera até que uma condição da entrada de análise de fluxo seja atendida.

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

Exemplos

Pause a execução da próxima linha do script CLI até que a entrada do stream-analytics seja criada com êxito.

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

Parâmetros Obrigatórios

--input-name --name -n

O nome da entrada.

--job-name

O nome do trabalho de streaming.

--resource-group -g

o nome do grupo de recursos. Você pode configurar o grupo padrão usando az configure --defaults group=<name>.

Parâmetros Opcionais

--created

Aguarde até ser criado com 'provisioningState' em 'Succeeded'.

valor predefinido: False
--custom

Aguarde até que a condição satisfaça uma consulta JMESPath personalizada. Por exemplo, provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

--deleted

Aguarde até ser excluído.

valor predefinido: False
--exists

Aguarde até que o recurso exista.

valor predefinido: False
--interval

Intervalo de sondagem em segundos.

valor predefinido: 30
--timeout

Espera máxima em segundos.

valor predefinido: 3600
--updated

Aguarde até ser atualizado com provisioningState em 'Succeeded'.

valor predefinido: False
Parâmetros de Globais
--debug

Aumente a verbosidade do log para mostrar todos os logs de depuração.

--help -h

Mostrar esta mensagem de ajuda e sair.

--only-show-errors

Mostrar apenas erros, suprimindo avisos.

--output -o

Formato de saída.

valores aceites: json, jsonc, none, table, tsv, yaml, yamlc
valor predefinido: json
--query

Cadeia de caracteres de consulta JMESPath. Consulte http://jmespath.org/ para obter mais informações e exemplos.

--subscription

o nome ou o ID da subscrição. Você pode configurar a assinatura padrão usando az account set -s NAME_OR_IDo .

--verbose

Aumente a verbosidade do registro. Use --debug para logs de depuração completos.