0
如何將數據寫入Kinesis中的特定分片?如何將數據寫入Kinesis中的特定分片
在boto文檔說
分區鍵是Unicode字符串,具有256個字符用於每個鍵的最大長度的限制。 MD5散列函數用於將分區鍵映射到128位整數值,並使用分片的散列鍵範圍將關聯的數據記錄映射到碎片。您可以通過使用ExplicitHashKey參數明確指定散列值來覆蓋散列分區鍵以確定分片。
但是我該怎麼做呢?
如何將數據寫入Kinesis中的特定分片?如何將數據寫入Kinesis中的特定分片
在boto文檔說
分區鍵是Unicode字符串,具有256個字符用於每個鍵的最大長度的限制。 MD5散列函數用於將分區鍵映射到128位整數值,並使用分片的散列鍵範圍將關聯的數據記錄映射到碎片。您可以通過使用ExplicitHashKey參數明確指定散列值來覆蓋散列分區鍵以確定分片。
但是我該怎麼做呢?
執行此操作的方法是將ExplicitHashKey設置爲特定分片的EndingHashKey和StartingHashKey之間的值,或者將其設置爲其中之一。
put_response = kinesis_client.put_record(
StreamName=my_stream_name,
Data=json.dumps(payload),
ExplicitHashKey='340282366920938463463374607431768211455',
PartitionKey=thing_id)