Publié le: Aug 18, 2020
Amazon Kinesis Data Streams annonce deux nouvelles fonctionnalités API qui simplifient les applications consommant des données de Kinesis Data Streams. La première fonctionnalité est un champ de filtrage en option dans l'API ListShards qui vous permet de définir des critères de filtrage pour les partitions que vous souhaitez répertorier à partir d'un flux de données. Par exemple, vous pouvez désormais utiliser un filtre d'horodatage afin de répertorier les partitions contenant des données à un moment donné. La deuxième fonctionnalité est un nouveau champ, appelé ChildShards, dans les API GetRecords et SubscribeToShards qui vous permet de découvrir les partitions enfants d'une partition fermée (sans devoir utiliser l'API ListShards pour répertorier l'ensemble des partitions ouvertes et fermées). Les applications consommant des données de Kinesis Data Streams peuvent utiliser ce nouveau champ afin de passer efficacement de la lecture d'une partition fermée à la lecture de sa partition enfant. Il s'agit d'un cas d'utilisation courant pour les applications consommatrices, notamment lorsqu'une partition est fermée en raison d'opérations de scaling du flux.
La bibliothèque client Kinesis (KCL) vous aide à rapidement créer des applications de consommateurs personnalisées en gérant des problèmes complexes, tels que l'adaptation aux variations de volume du flux, l'équilibrage de charge des données du flux, la coordination des travailleurs distribués et le traitement des données en garantissant la tolérance aux pannes. KCL vous permet ainsi de vous concentrer sur la logique métier lors de la conception des applications de consommateurs. Les clients utilisant les dernières versions de KCL, KCL 1.14 pour les consommateurs standard et KCL 2.3 pour les consommateurs avec diffusion améliorée, bénéficieront automatiquement de ces deux nouvelles fonctionnalités.
Amazon Kinesis Data Streams est un service de diffusion de données en temps réel, extrêmement scalable et durable. Il peut capturer en continu des gigaoctets de données par seconde à partir de centaines de milliers de sources telles que les clics de sites Web, les données IoT, les flux d'événements de bases de données, les transactions financières, les flux de médias sociaux, les journaux informatiques et les événements de localisation. Les données collectées sont disponibles en millisecondes pour des cas d'utilisation d'analytique en temps réel comme les tableaux de bord, la détection des anomalies en temps réel, la tarification dynamique, etc.
Pour plus d'informations, reportez-vous à la section Lecture de données de Kinesis Data Streams dans le guide du développeur Amazon Kinesis Data Streams ainsi qu'à la section Référence d'API pour ListShards, GetRecords et SubscribeToShard. Ces améliorations d'API et les dernières versions de KCL sont disponibles dans toutes les régions AWS où Amazon Kinesis Data Streams est disponible.