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