Kinesis FireHose支持更新操作是否在OpenSearch上

发布于 2025-01-17 18:28:18 字数 305 浏览 5 评论 0原文

我正在使用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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

天煞孤星 2025-01-24 18:28:18

据我所知这是不可能的。

我发现了这个问题: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.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文