Déplacer des données à l’aide de Stream Analytics
Azure Stream Analytics est un moteur de traitement d’événements en temps réel, conçu pour traiter des données de streaming rapides à partir de plusieurs sources simultanément. Il peut agréger, analyser, transformer et même déplacer des données vers d’autres magasins de données pour une analyse plus profonde et plus poussée.
Programme d’installation
Azure Stream Analytics prend en charge plusieurs récepteurs de sortie, notamment Azure Cosmos DB for NoSQL.
Notes
Seule l’API NoSQL est prise en charge actuellement.
Paramétrage
La configuration de la sortie d’Azure Cosmos DB for NoSQL consiste à sélectionner le compte dans votre abonnement ou à fournir vos informations d’identification, qui incluent généralement :
| Propriété | Description |
|---|---|
Output alias |
Alias pour faire référence à cette sortie dans la requête |
Account ID |
URI du point de terminaison de compte |
Account Key |
Clé de compte |
Database |
Nom de la ressource de base de données |
Container name |
Nom du conteneur |
La base de données et le conteneur doivent déjà exister dans le compte d’Azure Cosmos DB for NoSQL avant d’utiliser le récepteur de sortie.
Écrire dans Azure Cosmos DB
Les résultats de requête d’Azure Stream Analytics sont traités en tant que sortie JSON quand ils sont écrits dans Azure Cosmos DB for NoSQL.
En outre, les éléments font l’objet d’un upsert dans Azure Cosmos DB for NoSQL en fonction de la valeur du champ id. Les éléments sont généralement insérés dans Azure Cosmos DB for NoSQL. Si un élément avec le même ID unique existe déjà, l’opération est considérée comme une opération de mise à jour au lieu d’une opération d’insertion.