如何将数据写入Kinesis中的特定分片

如何将数据写入Kinesis中的特定分片？如何将数据写入Kinesis中的特定分片

在boto文档说

分区键是Unicode字符串，具有256个字符用于每个键的最大长度的限制。 MD5散列函数用于将分区键映射到128位整数值，并使用分片的散列键范围将关联的数据记录映射到碎片。您可以通过使用ExplicitHashKey参数明确指定散列值来覆盖散列分区键以确定分片。

但是我该怎么做呢？

来源

2017-10-08 Jonathan

执行此操作的方法是将ExplicitHashKey设置为特定分片的EndingHashKey和StartingHashKey之间的值，或者将其设置为其中之一。

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

来源

2017-10-08 20:42:36 Jonathan

如何将数据写入Kinesis中的特定分片

回答

相关问题