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à.
Leggi i dati da Amazon Kinesis Data Streams
Un consumer è un'applicazione che elabora i dati da un flusso di dati Kinesis. Quando un consumer utilizza l'espansione fan-out avanzato, ottiene la propria assegnazione di 2 MiB/sec di rendimento di lettura, consentendo a più utenti di leggere i dati dallo stesso flusso in parallelo, senza contendersi il rendimento di lettura con altri consumatori. Per utilizzare la funzionalità avanzata di smistamento degli shard, consulta Sviluppa consumatori personalizzati con throughput dedicato (fan-out migliorato).
Per impostazione predefinita, gli shard in un flusso forniscono 2 MiB/sec di rendimento di lettura per shard. Questo rendimento viene condiviso tra tutti i consumatori che stanno leggendo da un dato shard. In altre parole, il valore predefinito di 2 MiB/sec di rendimento per shard è fisso, anche se ci sono più utenti che stanno leggendo dallo shard. Per usare questa impostazione predefinita del rendimento di shard, consulta Sviluppa consumatori personalizzati con un throughput condiviso.
La tabella seguente confronta un throughput di default per migliorare il fan-out. 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 payload-dispatching APIs (like PutRecord and PutRecords). APIs GetRecords SubscribeToShard
Caratteristiche | Consumer non registrati senza fan-out avanzato | Consumer registrati con fan-out avanzato |
---|---|---|
Rendimento lettura shard | Fisso su un totale di 2 MiB/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 | N/D | 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 | Riavvia il modello usando. HTTP GetRecords | Kinesis Data Streams invia i record all'utente tramite /2 utilizzando. HTTP SubscribeToShard |
Argomenti
- Usa il Data Viewer nella console Kinesis
- Interroga i tuoi flussi di dati nella console Kinesis
- Sviluppa i consumatori utilizzando AWS Lambda
- Sviluppa i consumatori utilizzando Amazon Managed Service per Apache Flink
- Sviluppa i consumatori utilizzando Amazon Data Firehose
- Usa la libreria Kinesis Client
- Sviluppa consumatori personalizzati con un throughput condiviso
- Sviluppa consumatori personalizzati con throughput dedicato (fan-out migliorato)
- Migrazione dei consumatori da KCL 1.x a 2.x KCL
- Leggi i dati da Kinesis Data AWS Streams utilizzando altri servizi
- Leggi da Kinesis Data Streams utilizzando integrazioni di terze parti
- Risolvi i problemi dei consumatori di Kinesis Data Streams
- Ottimizza i consumatori di Amazon Kinesis Data Streams