我试图将来自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转换为碎片中可用的特定数据
任何帮助都将不胜感激
目前没有回答
相关问题 更多 >
编程相关推荐