Verschieben von Daten mit Stream Analytics
Azure Stream Analytics ist ein Echtzeit-Ereignisverarbeitungsmodul, das für die gleichzeitige Verarbeitung schneller Streamingdaten aus mehreren Quellen entwickelt wurde. Sie kann Daten aggregieren, analysieren, transformieren und sogar in andere Datenspeicher verschieben, um eine genauere und umfassendere Analyse zu ermöglichen.
Einrichtung
Azure Stream Analytics unterstützt mehrere Ausgabesenken, einschließlich Azure Cosmos DB for NoSQL.
Hinweis
Derzeit wird nur die NoSQL-API unterstützt.
Konfiguration
Zum Konfigurieren der Ausgabe von Azure Cosmos DB for NoSQL wählen Sie entweder das Konto in Ihrem Abonnement aus oder geben Ihre Anmeldeinformationen an, die in der Regel Folgendes umfassen:
| Eigentum | Beschreibung |
|---|---|
Output alias |
Alias, um in der Abfrage auf diese Ausgabe zu verweisen |
Account ID |
Kontoendpunkt-URI |
Account Key |
Kontoschlüssel |
Database |
Name der Datenbankressource |
Container name |
Name des Containers |
Die Datenbank und der Container müssen bereits im Azure Cosmos DB for NoSQL-Konto vorhanden sein, bevor die Ausgabesenke verwendet wird.
Schreiben in Azure Cosmos DB
Abfrageergebnisse aus Azure Stream Analytics werden beim Schreiben in Azure Cosmos DB for NoSQL als JSON-Ausgabe verarbeitet.
Darüber hinaus erfolgt für Elemente ein Upsertvorgang in Azure Cosmos DB for NoSQL basierend auf dem Wert des Felds ID. Elemente werden in der Regel in Azure Cosmos DB for NoSQL eingefügt. Wenn bereits ein Element mit derselben eindeutigen ID vorhanden ist, wird davon ausgegangen, dass es sich bei dem Vorgang um einen Aktualisierungsvorgang anstelle eines Einfügevorgangs handelt.