az stream-analytics input
Note
Esta referencia forma parte de la extensión stream-analytics para la CLI de Azure (versión 2.75.0 o posterior). La extensión instalará automáticamente la primera vez que ejecute un comando az stream-analytics input. Obtenga más información sobre las extensiones.
Administre la entrada con Stream Analytics.
Comandos
| Nombre | Description | Tipo | Estado |
|---|---|---|---|
| az stream-analytics input create |
Cree una entrada o reemplace una entrada ya existente en un trabajo de streaming existente. |
Extension | GA |
| az stream-analytics input delete |
Elimine una entrada del trabajo de streaming. |
Extension | GA |
| az stream-analytics input list |
Enumere todas las entradas del trabajo de streaming especificado. |
Extension | GA |
| az stream-analytics input show |
Obtenga detalles sobre la entrada especificada. |
Extension | GA |
| az stream-analytics input test |
Compruebe si el servicio Azure Stream Analytics puede acceder al origen de datos de una entrada y puede usarse. |
Extension | GA |
| az stream-analytics input update |
Actualice una entrada existente en un trabajo de streaming existente. Esto se puede usar para actualizar parcialmente (es decir, actualizar una o dos propiedades) una entrada sin afectar al resto de la definición de entrada o trabajo. |
Extension | GA |
| az stream-analytics input wait |
Coloque la CLI en un estado de espera hasta que se cumpla una condición de la entrada de stream-analytics. |
Extension | GA |
az stream-analytics input create
Cree una entrada o reemplace una entrada ya existente en un trabajo de streaming existente.
az stream-analytics input create --input-name --name
--job-name
--resource-group
[--if-match]
[--if-none-match]
[--properties]
Ejemplos
Creación de una entrada de blob de referencia con serialización 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"
Creación de una entrada del centro de eventos de flujo con serialización 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"
Creación de una entrada de IoT Hub de flujo con serialización de 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"
Creación de una entrada de blob de flujo con serialización 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 requeridos
Nombre de la entrada.
Nombre del trabajo de streaming.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>.
Parámetros opcionales
Los parámetros siguientes son opcionales, pero dependiendo del contexto, es posible que se requiera uno o varios para que el comando se ejecute correctamente.
ETag de la entrada. Omita este valor para sobrescribir siempre la entrada actual. Especifique el valor de ETag visto por última vez para evitar que se sobrescriba accidentalmente los cambios simultáneos.
Establézcalo en "*" para permitir la creación de una nueva entrada, pero evitar la actualización de una entrada existente. Otros valores darán como resultado una respuesta con error de condición previa 412.
Propiedades asociadas a una entrada. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
Parámetros globales
Aumente el nivel de detalle del registro para mostrar todos los registros de depuración.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Mostrar este mensaje de ayuda y salir.
Solo se muestran errores, suprimiendo advertencias.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Formato de salida.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | json |
| Valores aceptados: | json, jsonc, none, table, tsv, yaml, yamlc |
Cadena de consulta JMESPath. Consulte http://jmespath.org/ para obtener más información y ejemplos.
Nombre o identificador de la suscripción. Puede configurar la suscripción predeterminada mediante az account set -s NAME_OR_ID.
Aumente el nivel de detalle del registro. Usa --debug para ver registros de depuración completos.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
az stream-analytics input delete
Elimine una entrada del trabajo de streaming.
az stream-analytics input delete --input-name --name
--job-name
--resource-group
[--yes]
Ejemplos
Eliminar una entrada
az stream-analytics input delete --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Parámetros requeridos
Nombre de la entrada.
Nombre del trabajo de streaming.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>.
Parámetros opcionales
Los parámetros siguientes son opcionales, pero dependiendo del contexto, es posible que se requiera uno o varios para que el comando se ejecute correctamente.
No solicita confirmación.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Parámetros globales
Aumente el nivel de detalle del registro para mostrar todos los registros de depuración.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Mostrar este mensaje de ayuda y salir.
Solo se muestran errores, suprimiendo advertencias.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Formato de salida.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | json |
| Valores aceptados: | json, jsonc, none, table, tsv, yaml, yamlc |
Cadena de consulta JMESPath. Consulte http://jmespath.org/ para obtener más información y ejemplos.
Nombre o identificador de la suscripción. Puede configurar la suscripción predeterminada mediante az account set -s NAME_OR_ID.
Aumente el nivel de detalle del registro. Usa --debug para ver registros de depuración completos.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
az stream-analytics input list
Enumere todas las entradas del trabajo de streaming especificado.
az stream-analytics input list --job-name
--resource-group
[--select]
Ejemplos
Enumerar todas las entradas de un trabajo de streaming
az stream-analytics input list --job-name "sj9597" --resource-group "sjrg8440"
Enumerar todas las entradas de un trabajo de streaming e incluir información de diagnóstico mediante el parámetro de consulta de OData $select
az stream-analytics input list --select "*" --job-name "sj7804" --resource-group "sjrg3276"
Parámetros requeridos
Nombre del trabajo de streaming.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>.
Parámetros opcionales
Los parámetros siguientes son opcionales, pero dependiendo del contexto, es posible que se requiera uno o varios para que el comando se ejecute correctamente.
Parámetro de consulta $select OData. Se trata de una lista separada por comas de propiedades estructurales que se van a incluir en la respuesta, o "" para incluir todas las propiedades. De forma predeterminada, se devuelven todas las propiedades excepto los diagnósticos. Actualmente solo acepta "" como un valor válido.
Parámetros globales
Aumente el nivel de detalle del registro para mostrar todos los registros de depuración.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Mostrar este mensaje de ayuda y salir.
Solo se muestran errores, suprimiendo advertencias.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Formato de salida.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | json |
| Valores aceptados: | json, jsonc, none, table, tsv, yaml, yamlc |
Cadena de consulta JMESPath. Consulte http://jmespath.org/ para obtener más información y ejemplos.
Nombre o identificador de la suscripción. Puede configurar la suscripción predeterminada mediante az account set -s NAME_OR_ID.
Aumente el nivel de detalle del registro. Usa --debug para ver registros de depuración completos.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
az stream-analytics input show
Obtenga detalles sobre la entrada especificada.
az stream-analytics input show --input-name --name
--job-name
--resource-group
Ejemplos
Obtención de una entrada de blob de referencia con serialización CSV
az stream-analytics input show --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Obtención de una entrada del centro de eventos de flujo con serialización JSON
az stream-analytics input show --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"
Obtención de una entrada de IoT Hub de flujo con serialización de Avro
az stream-analytics input show --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"
Obtención de una entrada de blob de flujo con serialización CSV
az stream-analytics input show --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"
Parámetros requeridos
Nombre de la entrada.
Nombre del trabajo de streaming.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>.
Parámetros globales
Aumente el nivel de detalle del registro para mostrar todos los registros de depuración.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Mostrar este mensaje de ayuda y salir.
Solo se muestran errores, suprimiendo advertencias.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Formato de salida.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | json |
| Valores aceptados: | json, jsonc, none, table, tsv, yaml, yamlc |
Cadena de consulta JMESPath. Consulte http://jmespath.org/ para obtener más información y ejemplos.
Nombre o identificador de la suscripción. Puede configurar la suscripción predeterminada mediante az account set -s NAME_OR_ID.
Aumente el nivel de detalle del registro. Usa --debug para ver registros de depuración completos.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
az stream-analytics input test
Compruebe si el servicio Azure Stream Analytics puede acceder al origen de datos de una entrada y puede usarse.
az stream-analytics input test --input-name --name
--job-name
--resource-group
[--no-wait]
[--properties]
Ejemplos
Prueba de la conexión de una entrada
az stream-analytics input test --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Parámetros requeridos
Nombre de la entrada.
Nombre del trabajo de streaming.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>.
Parámetros opcionales
Los parámetros siguientes son opcionales, pero dependiendo del contexto, es posible que se requiera uno o varios para que el comando se ejecute correctamente.
No espere a que finalice la operación de ejecución prolongada.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Propiedades asociadas a una entrada. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
Parámetros globales
Aumente el nivel de detalle del registro para mostrar todos los registros de depuración.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Mostrar este mensaje de ayuda y salir.
Solo se muestran errores, suprimiendo advertencias.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Formato de salida.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | json |
| Valores aceptados: | json, jsonc, none, table, tsv, yaml, yamlc |
Cadena de consulta JMESPath. Consulte http://jmespath.org/ para obtener más información y ejemplos.
Nombre o identificador de la suscripción. Puede configurar la suscripción predeterminada mediante az account set -s NAME_OR_ID.
Aumente el nivel de detalle del registro. Usa --debug para ver registros de depuración completos.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
az stream-analytics input update
Actualice una entrada existente en un trabajo de streaming existente. Esto se puede usar para actualizar parcialmente (es decir, actualizar una o dos propiedades) una entrada sin afectar al resto de la definición de entrada o trabajo.
az stream-analytics input update --input-name --name
--job-name
--resource-group
[--if-match]
[--properties]
Ejemplos
Actualización de una entrada de blob de referencia
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"
Actualización de una entrada del centro de eventos de flujo
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"
Actualización de una entrada de IoT Hub de flujo
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"
Actualización de una entrada de blob de flujo
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 requeridos
Nombre de la entrada.
Nombre del trabajo de streaming.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>.
Parámetros opcionales
Los parámetros siguientes son opcionales, pero dependiendo del contexto, es posible que se requiera uno o varios para que el comando se ejecute correctamente.
ETag de la entrada. Omita este valor para sobrescribir siempre la entrada actual. Especifique el valor de ETag visto por última vez para evitar que se sobrescriba accidentalmente los cambios simultáneos.
Propiedades asociadas a una entrada. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
Parámetros globales
Aumente el nivel de detalle del registro para mostrar todos los registros de depuración.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Mostrar este mensaje de ayuda y salir.
Solo se muestran errores, suprimiendo advertencias.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Formato de salida.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | json |
| Valores aceptados: | json, jsonc, none, table, tsv, yaml, yamlc |
Cadena de consulta JMESPath. Consulte http://jmespath.org/ para obtener más información y ejemplos.
Nombre o identificador de la suscripción. Puede configurar la suscripción predeterminada mediante az account set -s NAME_OR_ID.
Aumente el nivel de detalle del registro. Usa --debug para ver registros de depuración completos.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
az stream-analytics input wait
Coloque la CLI en un estado de espera hasta que se cumpla una condición de la entrada de stream-analytics.
az stream-analytics input wait --input-name --name
--job-name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--interval]
[--timeout]
[--updated]
Ejemplos
Pause la ejecución de la siguiente línea de script de la CLI hasta que la entrada de Stream-Analytics se cree correctamente.
az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created
Parámetros requeridos
Nombre de la entrada.
Nombre del trabajo de streaming.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>.
Parámetros opcionales
Los parámetros siguientes son opcionales, pero dependiendo del contexto, es posible que se requiera uno o varios para que el comando se ejecute correctamente.
Espere hasta que se cree con "provisioningState" en "Succeeded".
| Propiedad | Valor |
|---|---|
| Grupo de parámetros: | Wait Condition Arguments |
| Valor predeterminado: | False |
Espere hasta que la condición cumpla una consulta JMESPath personalizada. Por ejemplo, provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
| Propiedad | Valor |
|---|---|
| Grupo de parámetros: | Wait Condition Arguments |
Espere hasta que se elimine.
| Propiedad | Valor |
|---|---|
| Grupo de parámetros: | Wait Condition Arguments |
| Valor predeterminado: | False |
Espere hasta que exista el recurso.
| Propiedad | Valor |
|---|---|
| Grupo de parámetros: | Wait Condition Arguments |
| Valor predeterminado: | False |
Intervalo de sondeo en segundos.
| Propiedad | Valor |
|---|---|
| Grupo de parámetros: | Wait Condition Arguments |
| Valor predeterminado: | 30 |
Espera máxima en segundos.
| Propiedad | Valor |
|---|---|
| Grupo de parámetros: | Wait Condition Arguments |
| Valor predeterminado: | 3600 |
Espere hasta que se actualice con provisioningState en "Succeeded".
| Propiedad | Valor |
|---|---|
| Grupo de parámetros: | Wait Condition Arguments |
| Valor predeterminado: | False |
Parámetros globales
Aumente el nivel de detalle del registro para mostrar todos los registros de depuración.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Mostrar este mensaje de ayuda y salir.
Solo se muestran errores, suprimiendo advertencias.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |
Formato de salida.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | json |
| Valores aceptados: | json, jsonc, none, table, tsv, yaml, yamlc |
Cadena de consulta JMESPath. Consulte http://jmespath.org/ para obtener más información y ejemplos.
Nombre o identificador de la suscripción. Puede configurar la suscripción predeterminada mediante az account set -s NAME_OR_ID.
Aumente el nivel de detalle del registro. Usa --debug para ver registros de depuración completos.
| Propiedad | Valor |
|---|---|
| Valor predeterminado: | False |