问Azure流分析mapWithState的替代方案

EN

在Analytics中是否有一种方法可以像Sparks mapWithState那样使用自定义状态创建一些聚合？

下面是我的场景：

我有来自IoT设备的数据，其中包含以下字段：

• DeviceId
• 位置
• 价值

数据可能会出现故障。

每当给定DeviceId的新数据包到达时，我都希望输出该设备的最后n个位置和值。喜欢

输入：{ "DeviceId": "A", "Position": 10, "Value": 100}

输出：{ "DeviceId": "A", "Positions": [10], "Value": [100]}

下一个输入：{ "DeviceId": "A", "Position": 11, "Value": 101}

输出：{ "DeviceId": "A", "Positions": [10, 11], "Value": [100, 101]}

下一个输入：{ "DeviceId": "A", "Position": 9, "Value": 99}

输出：{ "DeviceId": "A", "Positions": [9, 10, 11], "Value": [9, 100, 101]}

在Spark结构化流中，我将使用groupBy和mapWithState实现这一点。有没有办法在ASA中实现这一点？