Я использую лямбда-функцию для отправки данных в kinesis-firehose, а затем вasticsearch.В моем журнале ElasticsearchDelivery я получаю следующую ошибку:
{"type": "mapper_parsing_exception", "reason": "не удалось проанализировать", "reason_by": {"type": "not_x_content_exception"," причина ":" Обнаружение компрессора может быть вызвано только для некоторых байтов xcontent или сжатых байтов xcontent "}}
Я изо всех сил пытаюсь найти решения для этого в сети.Я подозреваю, что что-то не так с тем, как я возвращаю данные в своей лямбда-функции, но не уверен, как это исправить.
Это моя лямбда-функция:
exports.handler = async (event) => {
var output = [];
var records = event.records;
records.map(function (record) {
output.push({
'recordId': record['recordId'],
'result': 'Ok',
'data':new Buffer(record.data).toString('base64')
})
});
console.log("OUTPUT!!!!:", output)
return {'records': output};
};