Kinesis Firehose 与 Elastic Search

Question

我有一个用例，我想将数据插入弹性搜索域。我正在使用 kinesis firehose。我没有得到 kinesis firehose 如何将数据插入弹性搜索域？是使用批量插入还是一一插入？

Answer 1

Kinesis Firehose 对您的数据进行批处理。

来自documentation：

向 Amazon ES 传输数据的频率由 Elasticsearch 缓冲区大小和缓冲区间隔值 为您的交付流配置。 Kinesis Data Firehose 缓冲区 在将传入数据传送到 Amazon ES 之前。您可以配置 Elasticsearch 缓冲区大小 (1–100 MB) 或缓冲区间隔的值 （60-900秒），条件满足首先触发数据 配送至亚马逊 ES。