am_*_*_am 4 sql arrays json google-bigquery legacy-sql
我正在尝试从jsons(使用sql legacy)中提取每个json中的两个密钥,目前我正在使用json提取功能:
json_extract(json_column , '$[1].X') AS X,
json_extract(json_column , '$[1].Y') AS Y,
Run Code Online (Sandbox Code Playgroud)
如何使它在“ json arry列”的每个json上运行,而不仅仅是[1](例如)?
json示例:
[
{"blabla":000,"X":1,"blabla":000,"blabla":000,"blabla":000,,"Y":"2"},
{"blabla":000,"X":3,"blabla":000,"blabla":000,"blabla":000,,"Y":"4"},
]
Run Code Online (Sandbox Code Playgroud)
提前致谢!
让我们从一个类似的问题开始-这不是从json数组提取所有电子邮件的非常方便的方法:
SELECT id
, [ JSON_EXTRACT_SCALAR(JSON_EXTRACT(payload, '$.commits'), '$[0].author.email')
, JSON_EXTRACT_SCALAR(JSON_EXTRACT(payload, '$.commits'), '$[1].author.email')
, JSON_EXTRACT_SCALAR(JSON_EXTRACT(payload, '$.commits'), '$[2].author.email')
, JSON_EXTRACT_SCALAR(JSON_EXTRACT(payload, '$.commits'), '$[3].author.email')
] emails
FROM `githubarchive.day.20180830`
WHERE type='PushEvent'
AND id='8188163772'
Run Code Online (Sandbox Code Playgroud)
我们现在要解决的最好方法是在UDF中使用一些JavaScript将json数组拆分为SQL数组:
CREATE TEMP FUNCTION json2array(json STRING)
RETURNS ARRAY<STRING>
LANGUAGE js AS """
return JSON.parse(json).map(x=>JSON.stringify(x));
""";
SELECT * EXCEPT(array_commits),
ARRAY(SELECT JSON_EXTRACT_SCALAR(x, '$.author.email') FROM UNNEST(array_commits) x) emails
FROM (
SELECT id
, json2array(JSON_EXTRACT(payload, '$.commits')) array_commits
FROM `githubarchive.day.20180830`
WHERE type='PushEvent'
AND id='8188163772'
)
Run Code Online (Sandbox Code Playgroud)
2020 年 5 月 1 日更新
新函数 JSON_EXTRACT_ARRAY 刚刚添加到 JSON 函数列表中。此函数允许您将 JSON 文档的内容提取为字符串数组。
所以在下面你可以用CUSTOM_JSON_EXTRACT内置函数替换UDF 的使用JSON_EXTRACT_ARRAY,如下例所示
#standardSQL
SELECT
JSON_EXTRACT_SCALAR(json , '$.X') AS X,
JSON_EXTRACT_SCALAR(json , '$.Y') AS Y
FROM t, UNNEST(JSON_EXTRACT_ARRAY(json_column , '$')) json
Run Code Online (Sandbox Code Playgroud)
==============
下面是 BigQuery Standard SQL 的示例,它允许您接近使用 JSONPath 的标准方式,并且不需要额外的操作,因此您只需使用CUSTOM_JSON_EXTRACT(json, json_path)函数
#standardSQL
SELECT
JSON_EXTRACT_SCALAR(json , '$.X') AS X,
JSON_EXTRACT_SCALAR(json , '$.Y') AS Y
FROM t, UNNEST(JSON_EXTRACT_ARRAY(json_column , '$')) json
Run Code Online (Sandbox Code Playgroud)
结果将是
#standardSQL
CREATE TEMPORARY FUNCTION CUSTOM_JSON_EXTRACT(json STRING, json_path STRING)
RETURNS ARRAY<STRING>
LANGUAGE js AS """
return jsonPath(JSON.parse(json), json_path);
"""
OPTIONS (
library="gs://your_bucket/jsonpath-0.8.0.js"
);
WITH t AS (
SELECT '''
[
{"blabla1":1,"X":1,"blabla2":3,"blabla3":5,"blabla4":7,"Y":"2"},
{"blabla1":2,"X":3,"blabla2":4,"blabla3":6,"blabla4":8,"Y":"4"}
]
''' AS json_column
)
SELECT
CUSTOM_JSON_EXTRACT(json_column , '$[*].X') AS X,
CUSTOM_JSON_EXTRACT(json_column , '$[*].Y') AS Y
FROM t
Run Code Online (Sandbox Code Playgroud)
注意:为了克服当前 BigQuery 对 JsonPath 的“限制”,上述解决方案使用自定义函数和外部库-jsonpath-0.8.0.js可以从https://code.google.com/archive/p/jsonpath/downloads下载并上传到 Google Cloud Storage - gs://your_bucket/jsonpath-0.8.0.js
只需重新阅读 Felipe 的回答 - 对于他上面的示例,解决方案如下所示(仅供参考)
Row X Y
1 1 2
3 4
Run Code Online (Sandbox Code Playgroud)