Salida de colas de Service Bus desde Azure Stream Analytics

  • Artículo

Las colas de Service Bus ofrecen una entrega de mensajes según el modelo FIFO a uno o más consumidores simultáneos. Normalmente, los receptores reciben y procesan los mensajes en el orden temporal en el que se agregaron a la cola. Un único consumidor de mensajes recibe y procesa cada mensaje.

En el nivel de compatibilidad 1.2, Azure Stream Analytics usa el protocolo de mensajería Advanced Message Queuing Protocol (AMQP) para escribir en colas y temas de Service Bus. AMQP le permite construir aplicaciones híbridas, entre plataformas, utilizando un protocolo estándar abierto.

Configuración de salida

En la siguiente tabla se enumeran los nombres de propiedad y su descripción para crear una salida de cola.

Nombre de propiedad Descripción
Alias de salida Nombre descriptivo usado en las consultas para dirigir la salida de la consulta a esta cola de Service Bus.
Espacio de nombres de Service Bus Contenedor para un conjunto de entidades de mensajería.
Nombre de cola Nombre de la cola de Service Bus.
Nombre de la directiva de colas Cuando crea una cola, también puede crear directivas de acceso compartidas en la pestaña Configurar de dicha cola. Cada directiva de acceso compartido tiene un nombre, los permisos establecidos y las claves de acceso.
Clave de la directiva de colas La clave de acceso compartido que se usa para autenticar el acceso al espacio de nombres de Service Bus.
Formato de serialización de eventos Formato de serialización para los datos de salida. Se admiten JSON, CSV y Avro.
Encoding Por el momento, UTF-8 es el único formato de codificación compatible para CSV y JSON.
Delimitador Solo se aplica para la serialización de CSV. Stream Analytics admite un número de delimitadores comunes para la serialización de datos en formato CSV. Los valores admitidos son la coma, punto y coma, espacio, tabulador y barra vertical.
Formato Solo se aplica para el tipo JSON. La opción Separado por líneas especifica que en el formato de la salida cada objeto JSON está separado por una línea nueva. Si selecciona Separado por líneas, el objeto JSON se lee un objeto a la vez. El contenido total en sí mismo no sería un JSON válido. La opción Matriz especifica que el formato de la salida es una matriz de objetos JSON.
Columnas de propiedades Opcional. Columnas separadas por comas que necesitan agregarse como propiedades de usuario del mensaje saliente, en lugar de la carga útil. Puede obtener más información sobre esta característica en la sección Propiedades de metadatos personalizadas para la salida.
Columnas de propiedades del sistema Opcional. Pares de clave-valor de las propiedades del sistema y los nombres de columna correspondientes que se deben adjuntar al mensaje saliente en lugar de a la carga.

El número de particiones se basa en la SKU y el tamaño de Service Bus. La clave de partición es un valor entero único para cada partición.

Creación de particiones

La creación de particiones se elige automáticamente. El número de particiones se basa en la SKU y el tamaño de Service Bus. La clave de partición es un valor entero único para cada partición. El número de escritores de salida es el mismo que el número de particiones en la cola de salida.

Tamaño de lote de salida

El tamaño máximo del mensaje es 256 KB por mensaje para el nivel Estándar y 1 MB para el nivel Premium. Para más información, consulte los límites de Service Bus. Para optimizar, use un evento único por mensaje.

Propiedades de metadatos personalizadas para la salida

Puede asociar las columnas de la consulta como propiedades de usuario a los mensajes salientes. Estas columnas no se envían a la carga útil. Las propiedades están presentes como diccionario en el mensaje de salida. Key es el nombre de columna y value es el valor de columna en el diccionario de propiedades. Se admiten todos los tipos de datos de Stream Analytics, excepto los tipos de registro y matriz.

En el ejemplo siguiente, los campos DeviceId y DeviceStatus se agregan a los metadatos.

  1. Use la consulta siguiente:

    select *, DeviceId, DeviceStatus from iotHubInput

  2. Configure DeviceId,DeviceStatus como columnas de propiedades en la salida.

    Property columns

En la siguiente imagen se muestran las propiedades esperadas del mensaje de salida inspeccionadas en EventHub mediante Service Bus Explorer.

Event custom properties

Propiedades del sistema

Puede adjuntar columnas de consulta como propiedades del sistema a los mensajes salientes de cola y tema de Service Bus.

Estas columnas no entran en la carga; en su lugar, la propiedad del sistema ServiceBusMessage correspondiente se rellena con los valores de la columna de consulta. Se admiten estas propiedades del sistema: MessageId, ContentType, Label, PartitionKey, ReplyTo, SessionId, CorrelationId, To, ForcePersistence, TimeToLive, ScheduledEnqueueTimeUtc.

Los valores de cadena de estas columnas se analizan como el tipo de valor de propiedad del sistema correspondiente y los errores de análisis se tratan como errores de datos. Este campo se proporciona como un formato de objeto JSON. Los detalles sobre este formato son los siguientes:

  • Rodeado de llaves {}.
  • Escrito en pares de clave-valor.
  • Las claves y los valores deben ser cadenas.
  • La clave es el nombre de la propiedad del sistema y el valor es el nombre de la columna de consulta.
  • Las claves y los valores se separan por el signo de dos puntos.
  • Los pares de clave-valor están separados entre ellos por una coma.

A continuación se muestra cómo utilizar esta propiedad:

  • Consulta: select *, column1, column2 INTO queueOutput FROM iotHubInput
  • Columnas de propiedades del sistema: { "MessageId": "column1", "PartitionKey": "column2"}

Esto establece MessageId en los mensajes de cola de Service Bus con los valores de column1 y PartitionKey se establece con los valores de column2.

Pasos siguientes