azure - 如何使用 Azure 流分析查询创建复杂类型

Question

我尝试将平面 JSON 数据从事件中心转换为 DocumentDB。目标结构应如下所示:

{
   "id" : 1
   "field_1" : "value_1",
   "details" : {
      "detail_field_1":"abc",
      "detail_field_2":"def"
   }
}

从源创建:

{
   "id":1,
   "field_1" : "value_1",
   "detail_field_1":"abc",
   "detail_field_2":"def"
}

我检查了Azure流分析的文档，但没有明确描述如何创建正确的查询。

谁可以帮助我？

Answer 1

您可以利用the new JavaScript UDF feature将嵌套的 JSON 对象写入输出。

注册一个用户定义函数“UDF.getDetails()”如下:

function main(obj) {
  //get details object from input payload
  var details_obj = {};

  details_obj.detail_field_1 = obj.detail_field_1;
  details_obj.detail_field_2 = obj.detail_field_2;

  return JSON.stringify(details_obj);
}

然后在查询中调用 UDF 以获取嵌套 JSON 对象的字符串。

SELECT
  id,
  field_1,
  UDF.getDetails(input) As details
INTO output
FROM input