我有一个逻辑应用程序(标准计划),它从服务总线队列中获取消息,并将内容存储在数据湖中。这些消息来自通过物联网集线器上传遥测数据的现场设备。
这些消息包含设备的名称。有些在设备名称中有前缀X,有些有前缀Y。(例如)
根据设备名称是以X还是Y开头,我正在更改保存数据的数据湖中的路径。
我在流的开始处设置一个变量,然后使用控件来更改该变量->条件评估。这在FOR EACH循环中。根据设备名称是以X还是Y开头,它会将变量更改为我想要保存blob的路径。
然后,我将FOR EACH末尾的变量重置回0。
我发现评估90%的时间都是正确的。然而,有时它会将X的数据放在数据湖中Y的文件夹中。。。尽管先前已经从先前的运行中正确地评估了设备。
在查看跑步细节时,没有任何迹象表明有任何异常。
为什么我的变量和控制条件不一致地评估数据?
对于每个管路,默认情况下平行运行。
设置设置->并发性->平行度为0。