Comment écrire des données sur un fragment spécifique dans Kinesis

Question

Comment écrire des données sur un fragment spécifique dans Kinesis?

Boto docs disent

clés de partition sont des chaînes Unicode, avec une limite de longueur maximale de 256 caractères pour chaque touche. Une fonction de hachage MD5 est utilisée pour mapper des clés de partition sur des valeurs entières de 128 bits et pour mapper des enregistrements de données associés à des fragments en utilisant les plages de clés de hachage des fragments. Vous pouvez remplacer le hachage de la clé de partition pour déterminer le fragment en spécifiant explicitement une valeur de hachage à l'aide du paramètre ExplicitHashKey.

Cependant, comment puis-je réellement faire cela?

Answer 1

Pour ce faire, vous devez définir la valeur ExplicitHashKey entre EndingHashKey et StartingHashKey du fragment spécifique ou simplement le définir sur l'un d'entre eux.

put_response = kinesis_client.put_record(
        StreamName=my_stream_name, 
        Data=json.dumps(payload), 
        ExplicitHashKey='340282366920938463463374607431768211455', 
        PartitionKey=thing_id)