Movimiento de datos mediante Stream Analytics
Azure Stream Analytics es un motor de procesamiento de eventos en tiempo real diseñado para procesar datos de transmisión rápido de varios orígenes simultáneamente. Puede agregar, analizar, transformar e incluso mover datos a otros almacenes de datos para un análisis más profundo y posterior.
Configurar
Azure Stream Analytics admite varios receptores de salida, incluido Azure Cosmos DB for NoSQL.
Nota
En este momento, solo se admite la API NoSQL.
Configuración
La configuración de la salida de Azure Cosmos DB for NoSQL consiste en seleccionar la cuenta dentro de la suscripción o proporcionar sus credenciales, que normalmente incluyen:
| Propiedad | Descripción |
|---|---|
Output alias |
Alias para hacer referencia a esta salida en la consulta |
Account ID |
URI del punto de conexión de la cuenta |
Account Key |
Clave de cuenta |
Database |
Nombre del recurso de la base de datos |
Container name |
Nombre del contenedor |
La base de datos y el contenedor ya deben existir en la cuenta de Azure Cosmos DB for NoSQL antes de usar el receptor de salida.
Escritura a Azure Cosmos DB
Los resultados de la consulta de Azure Stream Analytics se procesarán como una salida JSON cuando se escriban en Azure Cosmos DB for NoSQL.
Además, los elementos se actualizan/insertan (upsert) en Azure Cosmos DB for NoSQL en función del valor del campo id. Normalmente, los elementos se insertan en Azure Cosmos DB for NoSQL. Si ya existe un elemento con el mismo identificador único, se supone que la operación es una operación de actualización en lugar de una operación de inserción.