Spostare i dati usando Analisi di flusso
Analisi di flusso di Azure è un motore di elaborazione eventi in tempo reale progettato per elaborare dati di streaming da più origini contemporaneamente. È in grado di aggregare, analizzare, trasformare e persino spostare i dati in altri archivi dati per ulteriori analisi più approfondite.
Attrezzaggio
Analisi di flusso di Azure supporta più sink di output, incluso Azure Cosmos DB for NoSQL.
Nota
Al momento è supportata solo l'API NoSQL.
Impostazione
La configurazione dell'output di Azure Cosmos DB for NoSQL consiste nel selezionare l'account all'interno della sottoscrizione o specificare le credenziali, che in genere includono:
| Proprietà | Descrizione |
|---|---|
Output alias |
Alias per fare riferimento a questo output nella query |
Account ID |
URI dell'endpoint dell'account |
Account Key |
Chiave dell'account |
Database |
Nome della risorsa di database |
Container name |
Nome del contenitore |
Il database e il contenitore devono essere già presenti nell'account di Azure Cosmos DB for NoSQL prima di usare il sink di output.
Scrivere in Azure Cosmos DB
I risultati delle query da Analisi di flusso di Azure verranno elaborati come output JSON quando vengono scritti in Azure Cosmos DB for NoSQL.
Inoltre, viene eseguito l'upsert degli elementi in Azure Cosmos DB for NoSQL in base al valore del campo ID. Gli elementi vengono generalmente inseriti in Azure Cosmos DB for NoSQL. Se esiste già un elemento con lo stesso ID univoco, si presuppone che venga eseguita un'operazione di aggiornamento anziché un'operazione di inserimento.