Данные не вставляются из пожарного шланга AWS Kinesis Data Stream в Elasticsearch
Я пытаюсь собрать журналы сервера из EC2 с агентом AWS Kinesis в Kinesis Data Stream и Firehose, и хранение необработанных данных в S3 идет хорошо, но это не помогает отправке в Elasticsearch Service для индексации данных после небольшой обработки с помощью Lambda.
Возникла ошибка: "Неверная структура вывода: пожалуйста, проверьте свою функцию и убедитесь, что обработанные записи содержат действительный статус результата Dropped, Ok или ProcessingFailed.".
Данные ответа от Lambda:
{'records': [{'recordId': 'recordID', 'result': 'Ok', 'data': 'Base64_Encoded_Json_Array'}]}
Но я больше не знаю, что мне для этого делать