Azure Stream Analytics修改SQL后无法触发HTTP型Azure Function

可能的核心原因及排查步骤 #

1. LAG函数引用了不存在的字段ec #

修改后的SQL中使用了LAG(ec,5,-1)，但原输入数据源（IoT Hub遥测数据）和之前的查询逻辑里均未提及ec字段。Stream Analytics中，引用不存在的字段会导致LAG返回NULL，而NULL = -1的判断结果为false，最终没有符合条件的记录输出，自然无法触发下游Function。

验证与修复：
将LAG(ec,5,-1)替换为实际存在的温度字段temp，修改后的SQL如下：

SELECT
   temp as value,
   time_of_reading as time,
   device as device
INTO
   warningFunction
FROM 
   input
WHERE
   LAG(temp,5,-1) OVER (PARTITION BY device LIMIT DURATION(minute,10)) = -1
AND
   temp < 20

重新测试查询，确认是否能持续输出符合条件的记录。

2. Stream Analytics输出批处理配置限制 #

Stream Analytics的HTTP输出默认会根据批量大小和最大延迟触发请求，如果满足条件的记录数未达到批量阈值，或者未到最大延迟时间，会暂存数据不发送。

排查与调整：

• 进入Stream Analytics作业的warningFunction对应的HTTP输出配置：
  • 检查“批量大小”（默认可能为100条），若场景中符合条件的记录数较少，可将其调低至1。
  • 检查“最大延迟”（默认可能为1分钟），若需要实时触发，可设为0秒。
• 调整后重启作业，观察Function是否被触发。

3. LAG函数的窗口逻辑未满足触发条件 #

LAG(temp,5,-1) OVER (PARTITION BY device LIMIT DURATION(minute,10)) = -1的逻辑是：当前设备的最近10分钟窗口内，往前数第5条记录不存在时返回-1。只有当该设备在10分钟内连续出现第5条及以后的temp<20记录时，才会触发输出。

验证逻辑：

• 确认测试数据是否真的满足“10分钟内该设备有至少5条temp<20的记录”，且当前记录是第5条及以后的符合条件的记录。
• 可尝试延长窗口时间（比如LIMIT DURATION(minute,30)），验证是否因窗口时间过短导致未满足条件。

4. 序列化兼容性（次要排查点） #

修改后的SQL新增了device字段，但Function中的Notification类未包含该属性。虽然Newtonsoft.Json默认会忽略未知属性，但极少数情况下可能出现隐性序列化问题。

修复：
在Notification类中添加device属性：

public class Notification
{
    public string time { get; set; }
    public string value { get; set; }
    public string device { get; set; } // 新增字段
}

重新发布Function后测试。

内容的提问来源于stack exchange，提问作者puradrogasincortar