Azure流处理通过数组向上插入到DocumentDB

Question

我使用Azure Stream Analytics将Json复制到DocumentDB，并使用upsert用最新数据覆盖文档。这对于我的基础数据来说很好，但我希望能够附加列表数据，因为不幸的是，我一次只能发送一个列表项。

在下面的示例中，文档在id上匹配，并且所有项目都更新了，但我希望“myList”数组随着来自每个文档的“myList”数据（具有相同的id）不断增长。这可能吗？是否有其他方法使用Stream Analytics在文档中更新此列表？

如果可能的话，我宁愿避免使用滚动窗口，但这是一个可行的选择吗？

示例文档：

{
    "id": "1234",
    "otherData": "example",
    "myList": [{"listitem": 1}]
}

{
    "id": "1234",
    "otherData": "example 2",
    "myList": [{"listitem": 2}]
}

期望输出:

{
    "id": "1234",
    "otherData": "example 2",
    "myList": [{"listitem": 1}, {"listitem": 2}]
}

我当前的查询：

SELECT id, otherData, myList INTO [myoutput] FROM [myinput] 

Answer 1

目前数组尚未合并，这是 ASA 的 DocumentDB 输出的现有行为，本文中也提到了这一点。我怀疑使用翻滚的窗户会在这里有所帮助。

请注意，JSON文档中数组属性值的更改会导致整个数组被覆盖，即数组未合并。

您可以使用 获取数组函数 将作为数组 （myList） 传入的输入转换为字典。

您的查询可能类似于-

选择i.id，i.otherData，listItemFromArray进入我的输出从我的输入i交叉应用GetArrayElements（i.myList）作为listItemFromArray

干杯！