發送和接收日誌到aws kinesis

Question

如何使用python boto3將日誌發送（接收）到不同的kinesis流分片？當只有一個碎片時，我可以發送和接收，但是如果我爲我的kinesis流指定了多個碎片，不知道它將如何工作。

Answer 1

您可以使用kinesis-agent庫將日誌推送到kinesis流，並使用KCL python庫從流中讀取記錄。 KCL處理諸如從多個碎片並行讀取，重新劃分等的負載。