Как преобразовать строковый файл из потока Kinesis в файл JSON

Может ли кто-нибудь помочь мне в этом. Я пытаюсь преобразовать мой файл строки в файл JSON.

Строковый файл я получаю из потока Kinesis.