azure cosmos db（使用 mongo api）和弹性搜索之间的实时数据同步答案

【问题标题】：Real time data sync between azure cosmos db( with mongo api) and elastic searchazure cosmos db（使用 mongo api）和弹性搜索之间的实时数据同步
【发布时间】：2022-08-03 19:37:56
【问题描述】：

在我们的堆栈中，既有 Azure Cosmos DB（使用 Mongo Api），也有具有类似索引的 Elastic search。 cosmos DB 经常更新，后端运行一些 api。此更新还需要反映在其他应用程序正在查询的弹性搜索中，因此弹性搜索和 Cosmos DB 中的数据应该是同步的。

我正在尝试查看是否有任何工具可以满足此要求，以将我的 Azure Cosmos DB 与弹性搜索实时同步。我尝试过使用像 monstache 这样的第三方工具，但不幸的是，由于下面提到的问题，这似乎不起作用 - Error starting change stream。

也许像更改提要这样的东西对你有用：docs.microsoft.com/en-us/azure/cosmos-db/sql/…？

标签： java azure elasticsearch azure-cosmosdb-mongoapi monstache

【解决方案1】：

尝试更改 Azure cosmos DB 中的源以与 Elastic 实时同步

Azure Cosmos DB 更改源可用于 IoT 的实时流处理或操作数据的实时分析处理。例如，您可以使用Spark 接收和存储来自设备、传感器、基础设施和应用程序的事件数据，并实时处理这些事件。下图显示了如何通过更改源使用 Azure Cosmos DB 实现 lambda 体系结构：

按照@Thomas 的建议检查此document 以获取完整信息。

【讨论】：