2017-10-08 117 views
0

如何將數據寫入Kinesis中的特定分片?如何將數據寫入Kinesis中的特定分片

在boto文檔說

分區鍵是Unicode字符串,具有256個字符用於每個鍵的最大長度的限制。 MD5散列函數用於將分區鍵映射到128位整數值,並使用分片的散列鍵範圍將關聯的數據記錄映射到碎片。您可以通過使用ExplicitHashKey參數明確指定散列值來覆蓋散列分區鍵以確定分片。

但是我該怎麼做呢?

回答

0

執行此操作的方法是將ExplicitHashKey設置爲特定分片的EndingHashKey和StartingHashKey之間的值,或者將其設置爲其中之一。

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