¿Hay alguna manera de configurar manualmente una identificación de documento de ElasticSearch al insertar a través de AWS Kinesis Firehose?

1 minuto de lectura

Avatar de usuario de Alex Coleman
alex coleman

Tengo un AWS Kinesis Firehose Stream configurado para enviar datos a un clúster de AWS ElasticSearch y puedo insertar documentos correctamente enviándolos a Firehose Stream, que los carga en ElasticSearch.

Pero me gustaría poder especificar/establecer manualmente un documento id valor al enviarlo a Firehose Stream. Estoy utilizando con éxito el SDK de PHP de AWS para enviar datos a Firehose, simplemente no puedo averiguar si hay una manera de configurar manualmente un documento id.

$firehoseParams = [
    'DeliveryStreamName' => 'myStreamName', // REQUIRED
    'Record' => [ // REQUIRED
        'Data' => '{"json_encoded": "data", ...}', // REQUIRED
    ],
];
$firehoseResult = $this->_firehoseClient->putRecord($firehoseParams);

He intentado configurar id, _idy esDocumentId valores en los datos JSON, todo fue en vano.

¿Alguien tiene alguna idea?

  • Intenté cambiar la identificación una vez hace unos años, y eso dio como resultado que algunas consultas no devolvieran los valores correctos, como cuando usaba avg. Por lo tanto, es posible que desee verificar que funciona cuando lo descubra.

    – WoodyDRN

    16 de julio de 2021 a las 12:17

¿Ha sido útil esta solución?