向 aws kinesis 发送和接收日志

Question

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

Answer 1

您可以使用kinesis-agent 库将日志推送到运动流，并使用KCL python 库从流中读取记录。 KCL 处理大量内容，例如从多个分片并行读取、重新分片等。