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 con fan-out migliorati con un throughput dedicato
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 un throughput fino a 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 utenti per stream per utilizzare il fan-out avanzato. Con gli stream On-demand Standard e Provisioned, puoi registrare fino a 20 consumatori per streaming per utilizzare un 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.
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 avanzato fornisce fino al 2% MB/sec di dati per shard, indipendentemente da qualsiasi altra pipe o dal numero totale di consumatori.
Argomenti
Differenze tra consumer con throughput condiviso e consumatore con fan-out avanzato
La tabella seguente confronta i consumatori predefiniti con throughput condiviso con i consumatori con fan-out avanzato. Il ritardo di propagazione dei messaggi è definito come il tempo impiegato, in millisecondi, da un payload inviato utilizzando il payload-dispatching (like and) per raggiungere l'applicazione consumer tramite il APIs payload-consuma (like and). PutRecord PutRecords APIs GetRecords SubscribeToShard
| Caratteristiche | Consumatori con throughput condiviso senza fan-out avanzato | Consumatori con fan-out migliorato |
|---|---|---|
| Throughput di lettura |
Risolto il problema con un totale di 2 MB/sec per shard. Se più consumatori leggono dallo stesso shard, condividono tutti questo rendimento. La somma dei rendimenti ricevuti dallo shard non supera 2 MiB/sec. |
Adatta man mano che consumatori si registrano per utilizzare il rendimento avanzato. Ogni consumer registrato per l'utilizzo di un fan-out avanzato riceve il proprio throughput di lettura per shard, fino a 2 MiB/sec, indipendentemente dagli altri consumer. |
| 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 |
Recupera il modello tramite HTTP utilizzando GetRecords. |
Kinesis Data Streams invia i record all'utente tramite HTTP/2 utilizzando. SubscribeToShard |
Regioni supportate per un massimo di 50 utenti con fan-out avanzato (solo On-Demand Advantage)
Il supporto per un massimo di 50 consumatori con fan-out avanzato 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) |
|
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-south-2 |
Asia Pacifico (Hyderabad) |
|
us-east-1 |
Stati Uniti orientali (Virginia settentrionale) |
|
ap-northeast-2 |
Asia Pacifico (Seoul) |
|
ap-northeast-3 |
Asia Pacifico (Osaka) |
|
eu-west-2 |
Europa (Londra) |
|
ap-southeast-4 |
Asia Pacifico (Melbourne) |
|
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) |
|
cn-northwest-1 |
Cina (Ningxia) |
|
eu-central-2 |
Europa (Zurigo) |
| us-gov-east-1 | AWS GovCloud (Stati Uniti orientali) |
| us-gov-west-1 | AWS GovCloud (Stati Uniti occidentali) |
