Я пытаюсь передавать данные из Kinesis как расширенный потребитель. Ниже приведен код, который я использую
kinesis = Session (). Create_client ("kinesis", region_name = "us-east-1")
response = kinesis.subscribe_to_shard (ConsumerARN = 'Regiserd) потребитель ARN ', ShardId = self.shard_id, StartingPosition = {' Type ':' LATEST '})
Когда я печатаю ответ, он печатается как "EventStream": ". Как я могу преобразовать этот eventStream в специфицированные c данные, доступные в шардах
Любая помощь будет оценена.