View a markdown version of this page

Sviluppa consumatori fan-out migliorati con una produttività dedicata - 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 fan-out migliorati con una produttività dedicata

In Flusso di dati Amazon Kinesis, è possibile creare applicazioni consumer che utilizzano la funzione di fan-out avanzato. Questa funzionalità consente ai consumatori di ricevere record da uno stream con una velocità massima di 2 MB di dati al secondo per 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

Con la modalità On-demand Advantage, puoi registrare fino a 50 consumatori per stream per utilizzare il fan-out avanzato. Con gli stream On-demand Standard e Provisioned, puoi registrare fino a 20 consumatori per stream per utilizzare il fan-out avanzato.

Il diagramma seguente illustra l'architettura del fan-out avanzato. Se si utilizza la versione 2.0 o una successiva di Amazon Kinesis Client Library (KCL) per creare un'applicazione consumer, la KCL imposterà l'applicazione per utilizzare il fan-out avanzato e ricevere i dati provenienti da tutte le partizioni del flusso. Se si utilizza l'API per creare un'applicazione consumer che utilizza il fan-out avanzato, è possibile abbonarsi 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 si utilizza la versione 2.0 o una successiva della KCL per creare un'applicazione consumer, la KCL sottoscriverà automaticamente l'applicazione a tutte le partizioni del flusso. D'altra parte, se si utilizza l'API per creare un'applicazione consumer è possibile abbonarsi 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 fan-out pipe migliorato fornisce fino al 2% MB/sec di dati per shard, indipendentemente da qualsiasi altro pipe o dal numero totale di consumatori.

Differenze tra un consumatore a produttività condivisa e un consumatore con tecnologia fan-out migliorata

La tabella seguente confronta i consumatori predefiniti con throughput condiviso con i consumatori fan-out avanzati. Il ritardo di propagazione dei messaggi è definito come il tempo impiegato in millisecondi da un payload inviato utilizzando le API di invio del payload (like and) per raggiungere l'applicazione consumer tramite le API che consumano payload (like e). PutRecord PutRecords GetRecords SubscribeToShard

Questa tabella confronta i consumatori con throughput condiviso con i consumatori più appassionati
Caratteristiche Consumatori con throughput condiviso senza fan-out migliorato Consumatori con fan-out migliorato
Throughput di lettura

Risolto il problema con un totale di 2 MB/sec per frammento. Se più consumatori leggono dallo stesso shard, condividono tutti questo rendimento. La somma dei rendimenti che ricevono dallo shard non supera 2. MB/sec

Adatta man mano che consumatori si registrano per utilizzare il rendimento avanzato. Ogni consumatore registrato per utilizzare il fan-out avanzato riceve il proprio throughput di lettura per shard, fino a 2 MB/sec, indipendentemente dagli altri consumatori.

Ritardo di propagazione dei messaggi

Una media di circa 200 ms in presenza di un consumer che legge dal flusso. Tale media sale fino a circa 1000 ms in presenza di cinque consumer.

In genere, la media è pari a 70 ms, in presenza di uno o di 5 consumer.

Costo Non applicabile

Non esistono costi di recupero dati né costi orari per shard-consumer. Per ulteriori informazioni, consulta Prezzi dei flussi di dati per Amazon Kinesis.

Modello di distribuzione record

Pull del modello su HTTP utilizzando. GetRecords

Kinesis Data Streams ti invia i record tramite. HTTP/2 SubscribeToShard

Regioni supportate per un massimo di 50 consumatori con tecnologia Enhanced Fan-Out (solo Advantage) On-demand

Il supporto per un massimo di 50 consumatori con tecnologia Enhanced fan-out in modalità On-demand Advantage è disponibile solo nelle seguenti regioni: AWS

AWS Regione Nome della regione

eu-north-1

Europa (Stoccolma)

me-south-1

Medio Oriente (Bahrein)

mx-central-1

Messico (centrale)

ap-south-1

Asia Pacifico (Mumbai)

eu-west-3

Europa (Parigi)

ap-southeast-3

Asia Pacifico (Giacarta)

us-east-2

Stati Uniti orientali (Ohio)

af-south-1

Africa (Città del Capo)

eu-west-1

Europa (Irlanda)

me-central-1

Medio Oriente (Emirati Arabi Uniti)

eu-central-1

Europa (Francoforte)

sa-east-1

Sud America (San Paolo)

ap-east-1

Asia Pacifico (Hong Kong)

ap-east-2

Asia Pacifico (Taipei)

ap-south-2

Asia Pacifico (Hyderabad)

us-east-1

Stati Uniti orientali (Virginia settentrionale)

ap-northeast-2

Asia Pacifico (Seul)

ap-northeast-3

Asia Pacifico (Osaka)

eu-west-2

Europa (Londra)

ap-southeast-4

Asia Pacifico (Melbourne)

ap-southeast-5

Asia Pacifico (Malesia)

ap-southeast-6

Asia Pacifico (Nuova Zelanda)

ap-southeast-7

Asia Pacifico (Thailandia)

ap-northeast-1

Asia Pacifico (Tokyo)

us-west-2

Stati Uniti occidentali (Oregon)

us-west-1

Stati Uniti occidentali (California settentrionale)

ap-southeast-1

Asia Pacifico (Singapore)

ap-southeast-2

Asia Pacifico (Sydney)

il-central-1

Israele (Tel Aviv)

ca-central-1

Canada (Centrale)

ca-west-1

Canada occidentale (Calgary)

eu-south-2

Europa (Spagna)

eu-south-1

Europa (Milano)

cn-northwest-1

Cina (Ningxia)

eu-central-2

Europa (Zurigo)

us-gov-east-1

AWS GovCloud (US-East)

us-gov-west-1

AWS GovCloud (US-West)