我已设置了一个AWS Kinesis Firehose流以将数据提供给AWS ElasticSearch集群,并且我可以通过将它们发送到Firehose流来成功插入文档,由此将其加载到ElasticSearch中。
但是,当发送文档到Firehose流时,我希望能够手动指定/设置文档的id
值。 我正在成功使用AWS PHP SDK将数据发送到Firehose,只是无法弄清楚是否有办法手动设置文档的id
。
$firehoseParams = [
'DeliveryStreamName' => 'myStreamName', // REQUIRED
'Record' => [ // REQUIRED
'Data' => '{"json_encoded": "data", ...}', // REQUIRED
],
];
$firehoseResult = $this->_firehoseClient->putRecord($firehoseParams);
我已经尝试在JSON数据中设置id
、_id
和esDocumentId
的值,但都没有成功。
有人有任何想法吗?