У меня есть AWS Kinesis Firehose Stream, настроенный для подачи данных в кластер AWS ElasticSearch, и я могу успешно вставлять документы, отправляя их в Firehose Stream, который загружает их в ElasticSearch.
Но я хотел бы иметь возможность вручную указать / установить документ id
значение при отправке его в поток Firehose. Я успешно использую AWS PHP SDK для отправки данных в Firehose, я просто не могу понять, есть ли способ установить документ вручную id
,
$firehoseParams = [
'DeliveryStreamName' => 'myStreamName', // REQUIRED
'Record' => [ // REQUIRED
'Data' => '{"json_encoded": "data", ...}', // REQUIRED
],
];
$firehoseResult = $this->_firehoseClient->putRecord($firehoseParams);
Я пытался установить id
, _id
, а также esDocumentId
значения в данных JSON, все безрезультатно.
У кого-нибудь есть идеи?
У нас точно такая же проблема, и мне жаль говорить, что на данный момент нет хорошего решения. Служба поддержки Amazon подтвердила, что они получили несколько запросов на это и в настоящее время работают над решением.
Других решений пока нет …