Я отправляю данные в кинезис и обрабатываю данные с помощью кинезис аналитики. Мои входные данные в потоки кинезиса выглядят следующим образом:
records=[
Data:{"symbol": "YESBANK", "series": "EQ", "openPrice": "46.60", "highPrice": "51.80", "lowPrice": "46.00", "ltp": "50.75", "previousPrice": "47.40", "netPrice": "7.07", "tradedQuantity": "27,71,75,113", "turnoverInLakhs": "1,38,698.43", "lastCorpAnnouncementDate": "03-Jun-2019", "lastCorpAnnouncement": "Annual General Meeting/ Dividend - Rs 2 Per Share"},
partitionKey:'pk1111'
]
Я получаю эти данные в аналитике потоков в следующем формате (после загрузки в виде файла CSV) 
как я могу отправлять данные в потоки кинесиса и обрабатывать их, если я получаю данные в вышеуказанном формате. Заранее спасибо.