Как настроить лямбду для отправки авро данных в AWS кинесис-поток - PullRequest
0 голосов
/ 04 ноября 2019

У меня есть требование отправлять данные в формате avro в поток kinesis. Я попытался выдвинуть запись, используя put_record или put_records, но он ожидает только байты или ByteArray. Если я преобразую данные в строку, это сработает, но потребитель не получит их в формате avro. Как я могу настроить поток для потребителя, чтобы получить данные в формате AVRO по умолчанию? (Примечание: я использую Python 3.7)

...