Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
Lire des données à partir d'Amazon Kinesis Data Streams
Un consommateur est une application qui traite toutes les données d'un flux de données Kinesis. Lorsqu'une application consommateur utilise la diffusion améliorée, elle obtient sa propre allocation de 2 Mo/sec de débit de lecture, ce qui permet à plusieurs applications consommateur de lire les données à partir du même flux en parallèle, sans devoir partager le débit de lecture avec d'autres applications consommateur. Pour utiliser la capacité de diffusion améliorée des partitions, consultez Développement d'applications consommateur personnalisées avec un débit dédié (diffusion améliorée).
Par défaut, les partitions présentes dans un flux fournissent un débit de lecture de 2 Mo/sec par partition. Ce débit est réparti entre toutes les applications consommateur qui lisent une partition donnée. En d'autres termes, la valeur par défaut de 2 Mo/sec de débit par partition est fixe, même si plusieurs applications consommateur lisent la partition. Pour utiliser ce débit par défaut des partitions, consultez Développement d'applications consommateur personnalisées avec un débit partagé.
Le tableau suivant compare le débit par défaut à la diffusion améliorée. Le délai de propagation des messages est défini comme le temps nécessaire en millisecondes pour qu'une charge utile envoyée à l'aide des API de distribution de charge utile (comme PutRecord et PutRecords) atteigne l'application client via les API consommatrices de charge utile (comme et). GetRecords SubscribeToShard
Caractéristiques | Consommateurs non enregistrés sans la diffusion améliorée | Consommateurs enregistrés avec la diffusion améliorée |
---|---|---|
Débit de lecture des partitions | Fixé à un total de 2 Mo/sec par partition. S'il y a plusieurs applications consommateur qui lisent la même partition, elles partagent toutes ce débit. La somme des débits qu'elles reçoivent de la partition ne dépasse pas 2 Mo/sec. | S'adapte au fur et à mesure de l'enregistrement des applications consommateur pour utiliser la diffusion améliorée. Chaque application consommateur enregistrée pour utiliser la diffusion améliorée reçoit son propre débit de lecture par partition, jusqu'à 2 Mo/sec, indépendamment des autres applications consommateur. |
Retard de propagation des messages | En moyenne, environ 200 ms si un consommateur lit depuis le flux. Cette moyenne monte à environ 1000 ms si vous avez cinq consommateurs. | En général, une moyenne de 70 ms que vous ayez un consommateur ou cinq consommateurs. |
Coût | N/A | Il y a un coût d'extraction des données et un coût horaire application consommateur-partition. Pour en savoir plus, consultez la Tarification Amazon Kinesis Data Streams |
Modèle de livraison de l'enregistrement | Extraire le modèle via HTTP en utilisant GetRecords. | Kinesis Data Streams vous envoie les enregistrements via HTTP/2 à l'aide de. SubscribeToShard |
Rubriques
- Utilisation du visualiseur de données dans la console Kinesis
- Interrogation de vos flux de données dans la console Kinesis
- Développer les consommateurs en utilisant AWS Lambda
- Développement de la clientèle à l'aide du service géré Amazon pour Apache Flink
- Développer les consommateurs grâce à Amazon Data Firehose
- Utilisation de Kinesis Client Library
- Développement d'applications consommateur personnalisées avec un débit partagé
- Développement d'applications consommateur personnalisées avec un débit dédié (diffusion améliorée)
- Migration des applications consommateur depuis KCL 1.x vers KCL 2.x
- Utilisation d'autres services AWS pour lire des données à partir de Kinesis Data Streams
- Utilisation d'intégrations tierces
- Dépannage des applications consommateur Kinesis Data Streams
- Sujets avancés pour les consommateurs d'Amazon Kinesis Data Streams