Есть ли способ установить идентификатор документа ElasticSearch вручную при вставке через AWS Kinesis Firehose?

У меня есть 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, все безрезультатно.

У кого-нибудь есть идеи?

8

Решение

У нас точно такая же проблема, и мне жаль говорить, что на данный момент нет хорошего решения. Служба поддержки Amazon подтвердила, что они получили несколько запросов на это и в настоящее время работают над решением.

4

Другие решения

Других решений пока нет …

По вопросам рекламы [email protected]