Kinesis FireHose支持更新操作是否在OpenSearch上
我正在使用FireHose(使用内置转换lambda)设计数据索引管道,例如:数据源-----(putrecordbatch)----------> Firehose ---(Lambda Transformation) - > OpenSearch
将在近乎实际的时间内通过此流量索引到数据存储中的新数据。既需要创建新文档,又需要对现有文档进行部分更新(即,更新指定文档ID的精选属性)。
FireHose与OpenSearch支持UPSERT是否集成(如果在OpenSearch中看到文档,否则插入)?
谢谢
I'm designing a data indexing pipeline to OpenSearch using Firehose(using the built-in transformation lambda), like : data source ----(putRecordBatch)----> firehose ---(Lambda transformation)--> OpenSearch
New data added to data store will be indexed via this flow in near-real time. There is requirement of both creating new documents, and doing partial update on existing documents(ie, updating select attributes of a specified document id).
Does Firehose integration with OpenSearch support Upsert(Update if document is seen in OpenSearch, else insert)?
Thanks
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
据我所知这是不可能的。
我发现了这个问题:AWS Kinesis Firehose lambda 如何向 ElasticSearch 发送更新和删除请求? 这证实了我的想法。
As far as I can tell that is not possible.
I've found this question: How can AWS Kinesis Firehose lambda send update and delete requests to ElasticSearch? which confirms my thought.