更新字段中的流分析问题

Question

我在更新流分析查询中的字段时遇到问题。查询如下：

SELECT * INTO CosmosDBTelemetry FROM IOTHub WHERE type like 't%' or type is null
SELECT * INTO CosmosDBEvents FROM IOTHub WHERE type = 'event'

在CosmosDBTelemetry中，我必须将deviceId值更改为另一个字段的值。

谁能帮我。

提前感谢。

Simone

Answer 1

[首先，如评论中的@silent所述，Stream Analytics与Azure Cosmos DB的集成允许您基于给定的Document ID列在容器中插入或更新记录。这也称为Upsert。更多详细信息，请参考此link。

其次，恐怕不适合使用ASA来实现您的需求。 ASA更倾向于从源收集数据，而不是清除或修改目标中的数据。您可能会想到Azure Function Cosmos DB Trigger。只要有数据流进入数据库，它就可以监视cosmos db并根据其他值修改列。