az stream-analytics output
Nota:
Esta referencia forma parte de la extensión stream-analytics para la CLI de Azure (versión 2.15.0 o posterior). La extensión instalará automáticamente la primera vez que ejecute un comando az stream-analytics output . Obtenga más información sobre las extensiones.
Administrar la salida con Stream Analytics.
Comandos
Nombre | Description | Tipo | Estado |
---|---|---|---|
az stream-analytics output create |
Cree una salida o reemplace una salida ya existente en un trabajo de streaming existente. |
Extensión | GA |
az stream-analytics output delete |
Elimine una salida del trabajo de streaming. |
Extensión | GA |
az stream-analytics output list |
Enumere todas las salidas en el trabajo de streaming especificado. |
Extensión | GA |
az stream-analytics output show |
Obtenga detalles sobre la salida especificada. |
Extensión | GA |
az stream-analytics output test |
Compruebe si el servicio Azure Stream Analytics puede acceder y usar el origen de datos de una salida. |
Extensión | GA |
az stream-analytics output update |
Actualice una salida existente en un trabajo de streaming existente. Esto se puede usar para actualizar parcialmente (es decir, actualizar una o dos propiedades) una salida sin afectar al resto de la definición de trabajo o salida. |
Extensión | GA |
az stream-analytics output wait |
Coloque la CLI en un estado de espera hasta que se cumpla una condición de la salida de stream-analytics. |
Extensión | GA |
az stream-analytics output create
Cree una salida o reemplace una salida ya existente en un trabajo de streaming existente.
az stream-analytics output create --job-name
--name
--resource-group
[--datasource]
[--if-match]
[--if-none-match]
[--serialization]
[--size-window]
[--time-window]
Ejemplos
Creación de una salida de DocumentDB
az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"accountId\":\"someAccountId\",\"accountKey\":\"accountKey==\",\"collectionNamePattern\":\"collection\",\"database\":\"db01\",\"documentId\":\"documentId\",\"partitionKey\":\"key\"}}" --output-name "output3022" --resource-group "sjrg7983"
Creación de una salida de Power BI
az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"someDataset\",\"groupId\":\"ac40305e-3e8d-43ac-8161-c33799f43e95\",\"groupName\":\"MyPowerBIGroup\",\"refreshToken\":\"someRefreshToken==\",\"table\":\"someTable\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --output-name "output3022" --resource-group "sjrg7983"
Creación de una salida de cola de Service Bus con serialización de Avro
az stream-analytics output create --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"queueName\":\"sdkqueue\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"systemPropertyColumns\":{\"MessageId\":\"col3\",\"PartitionKey\":\"col4\"}}}" --serialization "{\"type\":\"Avro\"}" --output-name "output3456" --resource-group "sjrg3410"
Creación de una salida de tema de Service Bus con serialización CSV
az stream-analytics output create --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"topicName\":\"sdktopic\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output7886" --resource-group "sjrg6450"
Creación de una salida de blob con serialización CSV
az stream-analytics output create --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output1623" --resource-group "sjrg5023"
Creación de una salida de Azure Data Lake Store con serialización JSON
az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"someaccount\",\"dateFormat\":\"yyyy/MM/dd\",\"filePathPrefix\":\"{date}/{time}\",\"refreshToken\":\"someRefreshToken==\",\"tenantId\":\"cea4e98b-c798-49e7-8c40-4a2b3beb47dd\",\"timeFormat\":\"HH\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Creación de una salida de base de datos de Azure SQL
az stream-analytics output create --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"database\":\"someDatabase\",\"password\":\"somePassword\",\"server\":\"someServer\",\"table\":\"someTable\",\"user\":\"<user>\"}}" --output-name "output1755" --resource-group "sjrg2157"
Creación de una salida de tabla de Azure
az stream-analytics output create --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\",\"batchSize\":25,\"columnsToRemove\":[\"column1\",\"column2\"],\"partitionKey\":\"partitionKey\",\"rowKey\":\"rowKey\",\"table\":\"samples\"}}" --output-name "output958" --resource-group "sjrg5176"
Creación de una salida del centro de eventos con serialización JSON
az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"eventHubName\":\"sdkeventhub\",\"partitionKey\":\"partitionKey\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Parámetros requeridos
nombre del trabajo de streaming.
Nombre de la salida.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>
.
Parámetros opcionales
Describe el origen de datos en el que se escribirá la salida. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
ETag de la salida. Omita este valor para sobrescribir siempre la salida 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 salida, pero para evitar la actualización de una salida existente. Otros valores darán como resultado una respuesta con error de condición previa 412.
Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
Ventana de tamaño a la que restringir una salida de Stream Analytics.
Período de tiempo para filtrar las salidas del trabajo de Stream Analytics.
Parámetros globales
Aumente el nivel de detalle de registro para mostrar todos los registros de depuración.
Muestre este mensaje de ayuda y salga.
Mostrar solo los errores y suprimir las advertencias.
Formato de salida.
Cadena de consulta de JMESPath. Para más información y ejemplos, consulte http://jmespath.org/.
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 de registro. Use --debug para obtener registros de depuración completos.
az stream-analytics output delete
Elimine una salida del trabajo de streaming.
az stream-analytics output delete --job-name
--name
--resource-group
[--yes]
Ejemplos
Eliminación de una salida
az stream-analytics output delete --job-name "sj6458" --name "output1755" --resource-group "sjrg2157"
Parámetros requeridos
nombre del trabajo de streaming.
Nombre de la salida.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>
.
Parámetros opcionales
No solicita confirmación.
Parámetros globales
Aumente el nivel de detalle de registro para mostrar todos los registros de depuración.
Muestre este mensaje de ayuda y salga.
Mostrar solo los errores y suprimir las advertencias.
Formato de salida.
Cadena de consulta de JMESPath. Para más información y ejemplos, consulte http://jmespath.org/.
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 de registro. Use --debug para obtener registros de depuración completos.
az stream-analytics output list
Enumere todas las salidas en el trabajo de streaming especificado.
az stream-analytics output list --job-name
--resource-group
[--select]
Ejemplos
Enumerar todas las salidas de un trabajo de streaming
az stream-analytics output list --job-name "sj6458" --resource-group "sjrg2157"
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
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 de registro para mostrar todos los registros de depuración.
Muestre este mensaje de ayuda y salga.
Mostrar solo los errores y suprimir las advertencias.
Formato de salida.
Cadena de consulta de JMESPath. Para más información y ejemplos, consulte http://jmespath.org/.
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 de registro. Use --debug para obtener registros de depuración completos.
az stream-analytics output show
Obtenga detalles sobre la salida especificada.
az stream-analytics output show --job-name
--name
--resource-group
Ejemplos
Obtención de una salida de DocumentDB
az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"
Obtención de una salida de Power BI
az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"
Obtención de una salida de cola de Service Bus con serialización de Avro
az stream-analytics output show --job-name "sj5095" --output-name "output3456" --resource-group "sjrg3410"
Obtención de una salida de tema de Service Bus con serialización CSV
az stream-analytics output show --job-name "sj7094" --output-name "output7886" --resource-group "sjrg6450"
Obtención de una salida de blob con serialización CSV
az stream-analytics output show --job-name "sj900" --output-name "output1623" --resource-group "sjrg5023"
Obtención de una salida de Azure Data Lake Store con serialización JSON
az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"
Obtención de una salida de Azure Data Warehouse
az stream-analytics output show --job-name "sjName" --output-name "output958" --resource-group "sjrg"
Obtención de una salida de base de datos de Azure SQL
az stream-analytics output show --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
Obtención de una salida de tabla de Azure
az stream-analytics output show --job-name "sj2790" --output-name "output958" --resource-group "sjrg5176"
Obtención de una salida del centro de eventos con serialización JSON
az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"
Parámetros requeridos
nombre del trabajo de streaming.
Nombre de la salida.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>
.
Parámetros globales
Aumente el nivel de detalle de registro para mostrar todos los registros de depuración.
Muestre este mensaje de ayuda y salga.
Mostrar solo los errores y suprimir las advertencias.
Formato de salida.
Cadena de consulta de JMESPath. Para más información y ejemplos, consulte http://jmespath.org/.
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 de registro. Use --debug para obtener registros de depuración completos.
az stream-analytics output test
Compruebe si el servicio Azure Stream Analytics puede acceder y usar el origen de datos de una salida.
az stream-analytics output test --job-name
--name
--resource-group
[--datasource]
[--no-wait]
[--serialization]
[--size-window]
[--time-window]
Ejemplos
Prueba de la conexión de una salida
az stream-analytics output test --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
Parámetros requeridos
nombre del trabajo de streaming.
Nombre de la salida.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>
.
Parámetros opcionales
Describe el origen de datos en el que se escribirá la salida. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
No espere hasta que finalice la operación de ejecución prolongada.
Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
Ventana de tamaño a la que restringir una salida de Stream Analytics.
Período de tiempo para filtrar las salidas del trabajo de Stream Analytics.
Parámetros globales
Aumente el nivel de detalle de registro para mostrar todos los registros de depuración.
Muestre este mensaje de ayuda y salga.
Mostrar solo los errores y suprimir las advertencias.
Formato de salida.
Cadena de consulta de JMESPath. Para más información y ejemplos, consulte http://jmespath.org/.
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 de registro. Use --debug para obtener registros de depuración completos.
az stream-analytics output update
Actualice una salida existente en un trabajo de streaming existente. Esto se puede usar para actualizar parcialmente (es decir, actualizar una o dos propiedades) una salida sin afectar al resto de la definición de trabajo o salida.
az stream-analytics output update --job-name
--name
--resource-group
[--datasource]
[--if-match]
[--serialization]
[--size-window]
[--time-window]
Ejemplos
Actualización de una salida de DocumentDB
az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output3022" --resource-group "sjrg7983"
Actualización de una salida de Power BI
az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"differentDataset\"}}" --output-name "output3022" --resource-group "sjrg7983"
Actualización de una salida de cola de Service Bus con serialización de Avro
az stream-analytics output update --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"queueName\":\"differentQueueName\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output3456" --resource-group "sjrg3410"
Actualización de una salida de tema de Service Bus con serialización CSV
az stream-analytics output update --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"topicName\":\"differentTopicName\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output7886" --resource-group "sjrg6450"
Actualización de una salida de blob con serialización CSV
az stream-analytics output update --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output1623" --resource-group "sjrg5023"
Actualización de una salida de Azure Data Lake Store con serialización JSON
az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"differentaccount\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Actualización de una salida de base de datos de Azure SQL
az stream-analytics output update --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"table\":\"differentTable\"}}" --output-name "output1755" --resource-group "sjrg2157"
Actualización de una salida de tabla de Azure
az stream-analytics output update --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output958" --resource-group "sjrg5176"
Actualización de una salida del centro de eventos con serialización JSON
az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Parámetros requeridos
nombre del trabajo de streaming.
Nombre de la salida.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>
.
Parámetros opcionales
Describe el origen de datos en el que se escribirá la salida. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
ETag de la salida. Omita este valor para sobrescribir siempre la salida actual. Especifique el valor de ETag visto por última vez para evitar que se sobrescriba accidentalmente los cambios simultáneos.
Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida. Obligatorio en las solicitudes PUT (CreateOrReplace). Valor esperado: json-string/json-file/@json-file.
Ventana de tamaño a la que restringir una salida de Stream Analytics.
Período de tiempo para filtrar las salidas del trabajo de Stream Analytics.
Parámetros globales
Aumente el nivel de detalle de registro para mostrar todos los registros de depuración.
Muestre este mensaje de ayuda y salga.
Mostrar solo los errores y suprimir las advertencias.
Formato de salida.
Cadena de consulta de JMESPath. Para más información y ejemplos, consulte http://jmespath.org/.
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 de registro. Use --debug para obtener registros de depuración completos.
az stream-analytics output wait
Coloque la CLI en un estado de espera hasta que se cumpla una condición de la salida de stream-analytics.
az stream-analytics output wait --job-name
--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 salida de Stream-Analytics se cree correctamente.
az stream-analytics output wait --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912" --created
Parámetros requeridos
nombre del trabajo de streaming.
Nombre de la salida.
Nombre del grupo de recursos. Puede configurar el grupo predeterminado mediante az configure --defaults group=<name>
.
Parámetros opcionales
Espere hasta que se cree con "provisioningState" en "Succeeded".
Espere hasta que la condición cumpla una consulta JMESPath personalizada. Por ejemplo, provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
Espere hasta que se elimine.
Espere hasta que exista el recurso.
Intervalo de sondeo en segundos.
Espera máxima en segundos.
Espere hasta que se actualice con provisioningState en "Succeeded".
Parámetros globales
Aumente el nivel de detalle de registro para mostrar todos los registros de depuración.
Muestre este mensaje de ayuda y salga.
Mostrar solo los errores y suprimir las advertencias.
Formato de salida.
Cadena de consulta de JMESPath. Para más información y ejemplos, consulte http://jmespath.org/.
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 de registro. Use --debug para obtener registros de depuración completos.