Порядок записей потока Dynamodb

Я заполняю записи в dynamodb в следующей последовательности:

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

Записи с одинаковым префиксом (Ai) имеют один и тот же ключ раздела, но разные ключи сортировки. Предположим, что все перечисленные выше записи принадлежат одному и тому же разделу, поэтому все эти записи будут находиться в одном потоке-шарде.

Теперь, если я обработаю этот фрагмент с помощью KCL, гарантированно ли я получу вышеуказанные записи в том же порядке? Я знаю, что изменения в одних и тех же записях отображаются в потоке по порядку, но сохраняется ли порядок и в записях?


person ishan3243    schedule 09.09.2017    source источник


Ответы (1)


Если вы используете DynamoDBStreamsKinesisAdapter, порядок записей для каждого сегмента Kinesis.

Если вы используете KPL для отправки данных kinesis, это зависит от того, какой partitionKey вы выбираете для Kinesis shard. Если вы выбрали тот же ключ partitionKey, который использовался в DynamoDB, все записи в сегменте будут в правильной последовательности.

Я смогу объяснить это более подробно, если вы объясните, как данные записываются в осколок Kinesis.

person SIDDHARTH J MEHTA    schedule 17.09.2017