DynamoDB Streams et Apache Flink - Amazon DynamoDB

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.

DynamoDB Streams et Apache Flink

Vous pouvez utiliser des enregistrements Amazon DynamoDB Streams avec Apache Flink. Avec Amazon Managed Service pour Apache Flink, vous pouvez transformer et analyser les données de streaming en temps réel à l'aide d'Apache Flink. Apache Flink est un framework de traitement de flux open source pour le traitement de données en temps réel. Le connecteur Amazon DynamoDB Streams pour Apache Flink simplifie la création et la gestion des charges de travail Apache Flink et vous permet d'intégrer des applications à d'autres. Services AWS

Amazon Managed Service pour Apache Flink vous aide à créer rapidement des applications de traitement de end-to-end flux pour l'analyse des journaux, l'analyse des flux de clics, l'Internet des objets (IoT), les technologies publicitaires, les jeux vidéo, etc. Les quatre cas d'utilisation les plus courants sont le streaming extract-transform-load (ETL), les applications pilotées par les événements, les analyses réactives en temps réel et les requêtes interactives des flux de données. Pour plus d'informations sur l'écriture vers Apache Flink depuis Amazon DynamoDB Streams, consultez Amazon DynamoDB Streams Connector.

Amazon DynamoDB Streams prend en charge ShardFilter le paramètre dans DescribeStream l'API pour rechercher un sous-ensemble de partitions. En spécifiant une partition parent dans la demande, DynamoDB Streams renvoie ses partitions enfants immédiates. Vous pouvez utiliser ShardFilter ce paramètre pour découvrir rapidement les partitions enfants après la fermeture d'une partition parent, afin de rendre vos applications de traitement de flux plus réactives et plus économiques.

Amazon Managed Service pour Apache Flink prend en charge le ShardFilter paramètre lors de la lecture depuis DynamoDB Streams. Pour utiliser cette fonctionnalité, vous devez demander l'accès à une version spéciale du connecteur Flink qui inclut le ShardFilter support. Pour commencer, ouvrez un dossier d'assistance dans le Centre de AWS support et demandez l'accès à ces fichiers binaires. Pour plus d'informations sur l'utilisation de DynamoDB Streams avec Apache Flink, consultez le Guide Lecture et traitement de flux du développeur DynamoDB.