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.
Développez des clients fans améliorés grâce à un débit dédié
Dans Amazon Kinesis Data Streams, vous pouvez créer des applications consommateur qui utilisent une fonctionnalité appelée diffusion améliorée. Cette fonctionnalité permet aux consommateurs de recevoir des enregistrements à partir d'un flux avec un débit allant jusqu'à 2 Mo de données par seconde et par partition. Ce débit est dédié. En d'autres termes, les consommateurs qui utilisent la diffusion améliorée n'ont pas besoin de se heurter à d'autres consommateurs qui reçoivent des données à partir du flux. Kinesis Data Streams envoie les enregistrements de données depuis le flux vers les applications consommateur qui utilisent la diffusion améliorée. Par conséquent, ces applications consommateur n'ont pas besoin de sonder des données.
Important
Vous pouvez enregistrer jusqu'à vingt applications consommateur par flux pour utiliser la diffusion améliorée.
Le schéma suivant illustre l'architecture de diffusion améliorée proposée. Si vous utilisez la version 2.0 ou ultérieure de la bibliothèque client Amazon Kinesis (KCL) pour créer un consommateur, le consommateur est KCL configuré pour qu'il utilise un ventilateur amélioré pour recevoir les données de toutes les partitions du flux. Si vous utilisez le API pour créer un consommateur utilisant un ventilateur amélioré, vous pouvez vous abonner à des partitions individuelles.
Le diagramme décrit les éléments suivants :
-
Un flux comportant deux partitions.
-
Deux applications consommateur qui utilisent la diffusion améliorée pour recevoir des données à partir du flux : Consommateur X et Consommateur Y. Chacune des deux applications consommateur est abonnée à toutes les partitions et tous les enregistrements du flux. Si vous utilisez la version 2.0 ou ultérieure de KCL pour créer un consommateur, celui-ci abonne KCL automatiquement ce consommateur à toutes les partitions du stream. D'autre part, si vous utilisez le API pour créer un consommateur, vous pouvez vous abonner à des partitions individuelles.
-
Les flèches représentant les canaux de diffusion améliorée des tuyaux que les applications consommateur utilisent pour recevoir des données à partir du flux. Un canal de diffusion améliorée fournit jusqu'à 2 Mo/sec de données par partition, indépendamment des autres canaux ou du nombre total d'applications consommateur.
Rubriques
Différences entre un consommateur partagé et un consommateur ventilé amélioré
Le tableau suivant compare les consommateurs à débit partagé par défaut aux consommateurs à débit partagé amélioré. 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 de la méthode d'expédition de charge utile APIs (comme PutRecord etPutRecords) atteigne l'application client via l'application consommatrice de charge utile (comme et). APIs GetRecords SubscribeToShard
| Caractéristiques | Consommateurs à débit partagé sans ventilateur amélioré | Consommateurs plus nombreux |
|---|---|---|
| Read throughput |
Fixé à un total de 2MB/sec per shard. If there are multiple consumers reading from the same shard, they all share this throughput. The sum of the throughputs they receive from the shard doesn't exceed 2 MB/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 | Ne s’applique pas |
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 |
Tirez le modèle sur le dessus HTTP en utilisant GetRecords. |
Kinesis Data Streams vous envoie les enregistrements HTTP sur /2 en utilisant. SubscribeToShard |
