De-batch e filtrare l'elaborazione di eventi serverless con Hub eventi

Hub eventi di Azure
Funzioni di Azure
Azure Cosmos DB

Idee per le soluzioni

Questo articolo è un'idea di soluzione. Per espandere il contenuto con altre informazioni, ad esempio casi d'uso potenziali, servizi alternativi, considerazioni sull'implementazione o indicazioni sui prezzi, inviare commenti e suggerimenti su GitHub.

Questo articolo descrive un'architettura basata su eventi serverless che usa Hub eventi di Azure e Funzioni di Azure per inserire e filtrare un flusso di dati per l'archiviazione del database.

Architettura

Diagramma che illustra il flusso di dati e i punti di elaborazione chiave nell'architettura descritta in questo articolo

Flusso di dati

  1. Gli eventi arrivano all'hub eventi di input.
  2. La funzione di de-batch e filtro di Azure viene attivata per gestire l'evento. Questo passaggio filtra gli eventi indesiderati e de-batch gli eventi ricevuti prima di inviarli all'hub eventi di output.
  3. Se la funzione di de-batch e filtro di Azure non riesce a archiviare correttamente l'evento, l'evento viene inviato all'hub eventi Deadletter 1.
  4. Gli eventi in arrivo nell'hub eventi di output attivano la funzione di Trasformazione di Azure. Questa funzione di Azure trasforma l'evento in un messaggio per l'istanza di Azure Cosmos DB.
  5. L'evento viene archiviato in un database di Azure Cosmos DB.
  6. Se la funzione di trasformazione di Azure non riesce a archiviare correttamente l'evento, l'evento viene salvato nell'hub eventi Deadletter 2.

Componenti

  • Hub eventi inserisce il flusso di dati. Hub eventi è progettato per scenari di flusso di dati con velocità effettiva elevata.
  • Funzioni di Azure è un'opzione di calcolo senza server. Usa un modello basato su eventi, in cui un frammento di codice (una funzione) viene richiamato da un trigger.
  • Azure Cosmos DB è un servizio di database multimodelle disponibile in modalità serverless basata sul consumo. Per questo scenario, la funzione di elaborazione eventi archivia i record JSON usando Azure Cosmos DB per NoSQL.

Dettagli dello scenario

Questa idea di soluzione descrive una variante di un'architettura basata su eventi serverless che usa Hub eventi e Funzioni di Azure per inserire ed elaborare un flusso di dati. I risultati vengono scritti in un database per l'archiviazione e la revisione futura dopo che vengono de-batch e filtrati.

Per altre informazioni sui concetti di base, considerazioni e approcci per l'elaborazione di eventi serverless, vedere l'architettura di riferimento per l'elaborazione di eventi serverless .

Potenziali casi d'uso

Un caso d'uso comune per l'implementazione di un modello di elaborazione del flusso di eventi end-to-end include il servizio di inserimento di streaming di Hub eventi per ricevere ed elaborare eventi al secondo usando una logica di de-batch e trasformazione implementata con funzioni altamente scalabili e attivate dall'hub eventi.

Autori di contributi

Questo articolo viene gestito da Microsoft. Originariamente è stato scritto dai collaboratori seguenti.

Autore principale:

Per visualizzare i profili LinkedIn non pubblici, accedere a LinkedIn.

Passaggi successivi