ElasticsearchDelivery无法解析

Question

我正在使用lambda函数将数据发送到kinesis-firehose然后发送到elasticsearch。在我的ElasticsearchDelivery日志中，我收到以下错误：

{“type”：“mapper_parsing_exception”，“reason”：“无法解析”，“caused_by”：{“type”：“not_x_content_exception”，“reason”：“压缩器检测只能在某些xcontent字节或压缩的xcontent上调用字节“}}

我正在努力在网上找到这个解决方案。我怀疑我如何在lambda函数中返回数据但是不确定如何修复它有什么问题。

这是我的lambda函数：

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};
    };

Answer 1

我不得不将数据更改为：'data'：record.data.toString（'base64'）