有没有什么方法可以在雪花中使用 UDF 而不是扁平化？答案

【问题标题】：Is there any way to build below using UDF in snowflake instead of flattening?有没有什么方法可以在雪花中使用 UDF 而不是扁平化？
【发布时间】：2020-05-22 09:56:17
【问题描述】：

我有下表表格1：有效载荷（列）

{
"list": "212=1.00,214"
}

表 2 如下所示

我想要使用 UDF 而不是 flatten 的结果如下所示

{
  "test13": {
    "code": "212",
    "desc": "success",
    "value": "1.00"
  },
  "test15": {
    "code": "214",
    "desc": "Impression",
    "value": ""
  }
}

【问题讨论】：

标签： snowflake-cloud-data-platform snowflake-schema

【解决方案1】：

您应该能够执行 JavaScript UDTF（用户定义的表函数）https://docs.snowflake.com/en/sql-reference/udf-js-table-functions.html，它可以获取单行有效负载并返回多行。

【讨论】：

【解决方案2】：

所以执行此操作的 SQL，我知道你不想要：

with table1 AS (               
  select parse_json('{"list": "212=1.00,214"}') as payload
), table2 AS (
  select parse_json(column1) as payload
    ,column2 as key
    ,column3 as value
  from values ('{"id":"212"}', 'test13', 'success' ),
              ('{"id":"214"}', 'test15', 'impression' )
), table1_demunged AS (
  select split(f.value,'=')[0] as id
    ,split(f.value,'=')[1] as val
  from table1 t, lateral flatten(input=>split(t.payload:list,',')) f
), tables_joined as (
  select t2.key as obj_key
    ,t1.id as code
    ,t2.value as desc
    ,t1.val as value
  from table2 t2
  join table1_demunged t1 on t2.payload:id = t1.id
), as_objects AS (
    select obj_key, object_construct('code', code, 'desc', desc, 'value', coalesce(value,'')) as res
    from tables_joined t
)
select object_agg(obj_key, res) object
from as_objects
group by true;

给出你想要的结果：

OBJECT
{    "test13": {      "code": "212",      "desc": "success",      "value": "1.00"    },    "test15": {      "code": "214",      "desc": "impression",      "value": ""    }  }

但是我不明白你是否真的想要一个 UDF 来完成所有这些，因为它是一个 FLATTEN 然后是一个 JOIN 然后是一些 OBJECT_ 函数，或者如果你只是想避免 FALTTEN 因为它“棘手的 SQL 和你想在 UDF 后面找到它”，或者您使用的系统无法解析 =>，因此您需要将 flatten 隐藏在 UDF 后面，但在这种情况下，UDF 无法为您完成所有连接..

感觉这个问题比被问到的要多。

【讨论】：