0

Je peuplant des enregistrements dans DynamoDB dans la séquence suivante:ordre de flux DynamoDB des dossiers

A11, A12, A13, A14, A15, A21, A22, A23, A24, A25, A31, A32, A33, A34, A35 

enregistrements avec le même préfixe (Ai) ont les mêmes clés de tri clé de partition, mais différentes. Supposons que tous les enregistrements listés ci-dessus appartiennent à la même partition, de sorte que tous ces enregistrements iront dans le même stream-shard.

Maintenant, si je traite cette partition en utilisant KCL, suis-je sûr d'obtenir les enregistrements ci-dessus dans le même ordre? Je sais que les modifications apportées aux mêmes enregistrements apparaissent dans l'ordre dans le flux, mais l'ordre est-il également valable pour les enregistrements?

Répondre

0

Si vous utilisez DynamoDBStreamsKinesisAdapter, l'ordre des enregistrements par fragment Kinesis est conservé.

Si vous utilisez KPL pour transférer des données vers un flux kinesis, cela dépend de la partition que vous choisissez pour le fragment Kinesis. Si vous avez choisi le même partitionKey que celui utilisé dans dynamoDB, tous les enregistrements par partition seront dans la bonne séquence.

Je serai en mesure d'expliquer plus en détail si vous pouvez élaborer sur la façon dont les données sont écrites dans Kinesis partition.