我已经设置了一个AWS Kinesis Firehose流,将数据馈送到AWS ElasticSearch集群,并且我可以通过将文档发送到Firehose流成功插入文档,该流将文档加载到ElasticSearch中
但我希望能够在将文档发送到Firehose流时手动指定/设置文档的id值。我正在成功地使用AWS PHP SDK向Firehose发送数据,我只是不知道是否有办法手动设置文档的id
$firehoseParams=[
'DeliveryStreamName'=>;'myStreamName',//必需
“记录”=>;[//必需
'Data'=>;'{“json_编码”:“Data”,…}',//必需
],
];
$firehoseResult=$this->_firehoseClient->;putRecord($firehoseParams);
我尝试在JSON数据中设置id、\u id和esDocumentId值,但均无效
有人有什么想法吗
为此,您可以使用Kinesis数据流,您可以将文档发送到流,并通过lambda函数,使用官方的Elasticsearch API提供_id属性