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)