移动订阅碎片

2024-09-27 19:26:41 发布

您现在位置:Python中文网/ 问答频道 /正文

我试图将来自Kinesis的数据流作为增强的扇出消费者。下面是我正在使用的代码

kinesis=Session()。创建_客户端(“kinesis”,region_name=“us-east-1”)

response=kinesis.subscribe_到_shard(ConsumerARN='Regiserd consumer ARN',ShardId=self.shard_id,StartingPosition={'Type':'LATEST'})

当我打印响应时,它被打印为“'EventStream':”。如何将此eventStream转换为碎片中可用的特定数据

任何帮助都将不胜感激


Tags: 代码name客户端responsesession消费者subscriberegion

热门问题