如何使用 azure 流分析将 cosmos db 中的值更新为输出？

Posted 2023-05-08

【中文标题】如何使用 azure 流分析将 cosmos db 中的值更新为输出？

【英文标题】：How to update values in cosmosdb as output using azure stream analutics?

【发布时间】：2019-08-28 19:36:53

【问题描述】：

在第一次事件中，我得到如下数据

'product_name':'hamam',
'quantity':'100'

第二次我得到如下数据

'product_name':'hamam',
'quantity':'70'

这里我想更新 cosmos db 中的值，我该怎么做？

【问题讨论】：

你能分享你尝试了什么吗？你想从虚拟机做吗？什么样的应用程序会传递信息？你知道 Cosmos DB Partitioning吗？

您好，我的回答对您有帮助吗？我不知道你为什么要开一个新案子。

【参考方案1】：

如果您的数据包含唯一的文档 ID，则 ASA 支持 cosmos db 的 upserts 功能。（您的示例数据似乎没有它）请参阅此paragraph，了解 ASA 中用于 cosmos db 的 upserts。

摘录如下：

流分析与 Azure Cosmos DB 的集成允许您根据给定的文档 ID 列在容器中插入或更新记录。

如果传入的 JSON 文档具有现有的 ID 字段，则该字段将自动用作 Cosmos DB 中的文档 ID 列，并且任何后续写入都将按此处理，从而导致以下情况之一：

唯一 ID 导致插入 重复 ID 和“文档 ID”设置为“ID”会导致更新插入 重复 ID 和未设置“文档 ID”会导致错误，在 第一份文件