KQL 更新策略的数据摄取问题；查询架构与表架构不匹配

如何解决KQL 更新策略的数据摄取问题；查询架构与表架构不匹配

我正在编写一个函数，它接收原始数据表（包含 multijson 遥测数据）并将其重新格式化为多个列。我使用 .set MyTable <| myfunction|limit 0 根据函数创建目标表，并使用更新策略提醒目标表。

代码如下：

.set-or-append MyTargetTable <| 
   myfunction
   | limit 0

.alter table MyTargetTable policy update 
@'[{ "IsEnabled": true,"Source": "raw","Query": "myfunction()","IsTransactional": false,"PropagateIngestionProperties": false}]'

但我遇到了摄取失败：这是摄取失败消息：

未能调用更新策略。目标表 = 'MyTargetTable'，查询 = '

let raw = __table("raw",'All','AllButRowStore') 
| where extent_id() in (guid(659e3b3c-6859-426d-9c37-003623834455));
myfunction()': Query schema does not match table schema 

我仔细检查了查询模式和目标表；他们是一样的 。我不确定这个错误是什么意思。 此外，我对 raw 和 mytarget 表进行了计算；差异比较大（我的目标有 400 行，原始表有 2000 行）。

任何建议将不胜感激。

解决方法

一般来说 - 要找到模式之间不匹配的根源，您可以按照以下方式运行，并过滤差异：

myfunction
| getschema 
| join kind=leftouter (
    table('MyTargetTable')
    | getschema 
) on ColumnOrdinal,ColumnType

此外 - 您应该确保您在更新策略中使用的函数的输出架构是“稳定的”，即不受输入数据的影响

• 某些查询插件（例如 pivot() 和 bag_unpack()）的输出架构取决于输入数据，因此不建议在更新策略中使用它们。