通过AWS Kinesis Firehose插入时,是否有方法手动设置ElasticSearch文档id?

我已经设置了一个AWS Kinesis Firehose流,将数据馈送到AWS ElasticSearch集群,并且我可以通过将文档发送到Firehose流成功插入文档,该流将文档加载到ElasticSearch中

但我希望能够在将文档发送到Firehose流时手动指定/设置文档的id值。我正在成功地使用AWS PHP SDK向Firehose发送数据,我只是不知道是否有办法手动设置文档的id

$firehoseParams=[
'DeliveryStreamName'=>'myStreamName',//必需
“记录”=>[//必需
'Data'=>'{“json_编码”:“Data”,…}',//必需
],
];
$firehoseResult=$this-&gt_firehoseClient->putRecord($firehoseParams);

我尝试在JSON数据中设置id\u idesDocumentId值,但均无效

有人有什么想法吗

为此,您可以使用Kinesis数据流,您可以将文档发送到流,并通过lambda函数,使用官方的Elasticsearch API提供_id属性

发表评论