本地Kinesis：kinesalite + boto3

Question

我想設置boto3 kinesis客戶端，使其使用kinesalite。這樣我可以完全在本地工作。

有什麼見解？

Answer 1

初始化客戶端時，您可以將endpoint_url關鍵字參數傳遞給boto3。

import boto3 

client = boto3.client('kinesis', endpoint_url='http://localhost:4567') 
client.list_streams() 

：

假設kinesalite在端口4567上運行