Azure流分析集成ML函数的查询无法写入表存储求助

我碰到过好几个类似的情况，你这个问题大概率是字段命名或者ML输出结构的问题，咱们一步步来排查：

1. 先搞定字段命名的坑 #

你查询里的'probabalities of rain'有两个明显问题：一是拼写错误（正确拼写是probabilities），二是表存储不支持带空格的属性名！这绝对是触发写入失败的常见原因，先把这个字段改成probabilities_of_rain试试，用下划线替代空格，别再用带空格的命名了。

2. 验证ML函数的输出结构是否符合要求 #

流分析写入表存储需要扁平的字段结构，嵌套的复杂类型很容易导致写入失败。你可以临时把查询结果输出到Blob存储，看看ML返回的result到底是什么样的：

WITH machinelearning AS (
    SELECT 
        [IoTHub].[ConnectionDeviceId] AS [DeviceId],
        [ventEnqueuedUtcTime],
        [temperature],
        [humidity],
        [machinelearning]([temperature], [humidity]) AS [result]
    FROM [MachineLearningInput]
)
SELECT [System].Timestamp AS time, [DeviceId], [EventEnqueuedUtcTime], [result]
INTO [TempBlobOutput] -- 临时创建一个Blob输出用来排查
FROM [machinelearning];

打开Blob里的JSON文件，确认result里确实存在temperature、humidity、Scored Probabilities这些字段，而且数据类型能被正常转成FLOAT。如果ML返回的字段名有大小写偏差或者拼写错误，也会导致CAST操作失败。

3. 查日志找具体错误 #

别瞎猜，直接去流分析作业的监控>诊断日志里看详情，日志会明确告诉你写入失败的具体原因：是字段类型不匹配？权限不足？还是字段名非法？这是最快定位问题的方式。

另外还要确认流分析作业的托管标识（或者服务主体）对目标存储账户有表数据参与者的权限，有时候集成ML后权限配置可能被意外改动，导致无法写入表存储。

修正后的参考查询 #

把字段名改好后的查询示例：

WITH machinelearning AS (
    SELECT 
        [IoTHub].[ConnectionDeviceId] AS [DeviceId],
        [ventEnqueuedUtcTime],
        [temperature],
        [humidity],
        [machinelearning]([temperature], [humidity]) AS [result]
    FROM [MachineLearningInput]
)
SELECT 
    [System].Timestamp AS [time],
    [DeviceId],
    [EventEnqueuedUtcTime],
    CAST([result].[temperature] AS FLOAT) AS [temperature],
    CAST([result].[humidity] AS FLOAT) AS [humidity],
    CAST([result].[Scored Probabilities] AS FLOAT) AS [probabilities_of_rain]
INTO [MachineLearningOutput]
FROM [machinelearning];

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