Sviluppa consumatori personalizzati con throughput dedicato (fan-out migliorato) - Flusso di dati Amazon Kinesis

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Sviluppa consumatori personalizzati con throughput dedicato (fan-out migliorato)

In Flusso di dati Amazon Kinesis, è possibile creare applicazioni consumer che utilizzano la funzione di fan-out avanzato. Questa funzione consente alle applicazioni consumer di ricevere record da un flusso con un throughput fino a 2 MiB di dati al secondo per ogni shard. Questa velocità di trasmissione effettiva è dedicata, il che significa che le applicazioni consumer che utilizzano il fan-out avanzato non devono convivere con altre applicazioni consumer che stanno ricevendo dati dal flusso. Il flusso di dati Kinesis inserisce i record di dati dal flusso alle applicazioni consumer che utilizzano il fan-out avanzato. Pertanto, per queste applicazioni consumer non è necessario eseguire il polling per i dati.

Importante

È possibile registrare fino a venti applicazioni consumer per flusso per l'utilizzo del fan-out avanzato.

Il diagramma seguente illustra l'architettura del fan-out avanzato. Se utilizzi la versione 2.0 o successiva di Amazon Kinesis Client Library (KCL) per creare un consumer, lo KCL configura per utilizzare un fan-out avanzato per ricevere dati da tutti gli shard dello stream. Se utilizzi il API per creare un consumatore che utilizzi il fan-out avanzato, puoi abbonarti a singoli shard.

Diagramma di flusso di lavoro che mostra l'architettura del fan-out avanzato con due shard e due applicazioni consumer. Ognuna delle due applicazioni consumer sta utilizzando il fan-out avanzato per ricevere i dati da entrambi gli shard del flusso.

Il diagramma mostra:

  • Un flusso con due shard.

  • Due applicazioni consumer che utilizzano il fan-out avanzato per ricevere i dati dal flusso: Consumer X e Consumer Y. Ognuna delle due applicazioni consumer è abbonata a tutti gli shard e a tutti i record del flusso. Se utilizzi la versione 2.0 o successiva di KCL per creare un consumatore, lo sottoscrive KCL automaticamente a tutti gli shard dello stream. D'altra parte, se utilizzi API to build a consumer, puoi abbonarti a singoli shard.

  • Frecce che rappresentano i canali di diffusione del fan-out che le applicazioni consumer utilizzano per ricevere i dati dal flusso. Un canale di fan-out avanzato fornisce fino a 2 MiB/sec di dati per shard, indipendentemente da qualsiasi altro canale o dal numero totale di applicazioni consumer.