发送和接收日志到aws kinesis

Question

如何使用python boto3将日志发送（接收）到不同的kinesis流分片？当只有一个碎片时，我可以发送和接收，但是如果我为我的kinesis流指定了多个碎片，不知道它将如何工作。

Answer 1

您可以使用kinesis-agent库将日志推送到kinesis流，并使用KCL python库从流中读取记录。 KCL处理诸如从多个碎片并行读取，重新划分等的负载。