azure - 逻辑应用程序将数据从 Cosmosdb 推送到 CRM 并执行更新

Question

我创建了一个逻辑应用程序，其目标是从 cosmosdb 中的容器中提取数据(使用查询)，循环结果，然后将这些数据推送到 CRM(或 Common Data Service)中。当数据推送到CRM时，会生成一个ID。我希望用这个新 ID 更新 cosmosdb。这是我到目前为止所拥有的:

下一步是在 cosmosdb 数据库中查询数据并选择长度大于 15 的所有 IDS。(这告诉我们该 ID 尚未在 CRM 数据库中)

然后我们循环结果并将其推送到 CRM(Dynamics365 或 Common Data Service)

困境:这个过程的第一部分似乎是正确的，但是，我想确保我走在正确的轨道上。此外，一旦数据成功推送到CRM，CRM就会自动为每条记录生成一个ID。然后我如何使用新生成的 ID 更新 cosmosDB？

如有任何建议，我们将不胜感激谢谢

Answer 1

对于 length(c.id) > 15 的查询，我在您的方法中看到了一个危险信号。这不是我会做的事情。我不知道您的数据库有多大，但通常在执行大量跨分区查询时性能不太好，特别是在数据库持续增长的情况下。

Cosmos DB 已经提供了出色的流处理功能，因此我不会批量执行此操作，而是使用 Change Feed 并使用它来完成您在逻辑应用程序中执行的任何操作。这可能会让您更好地控制流程，并可能允许您从 CRM 应用中取回 ID 以插入回 Cosmos DB。

由于您将写回 Cosmos DB，因此在更新项目时，您将需要一个标志来忽略更改源中的更新。