如何解决Google Workflows 上的多行字符串插值
我正在尝试使用 Google 工作流来执行一些自动 BigQuery 调度任务。要求是对多个数据集运行查询,如下所示:
- execute_query_job:
call: execute_query_job
args:
query_text: >-
SELECT
* EXCEPT(row_number)
FROM (
SELECT *,ROW_NUMBER() OVER (PARTITION BY uuid) row_number
FROM
`project.${database_id}.table`)
WHERE
row_number = 1
然而,这不起作用,因为字符串被解释为原样并且没有发生插值。
${}
语法不会跨越多行,并且 {{ var }}
的 ansible 语法也不起作用。
解决方法
尝试以与以下类似的方式将查询更改为一行:
- execute_query_job:
call: execute_query_job
args:
query_text: ${"SELECT * EXCEPT(row_number) FROM (SELECT *,ROW_NUMBER() OVER (PARTITION BY uuid) row_number FROM `project."+database_id+".table`) WHERE row_number = 1"}
请注意,根据 the Workflow's docs:
可以将变量分配给特定值或表达式的结果。
如果这不起作用,请注意向 BigQuery's API jobs.insert 方法发出 POST 请求将允许您指定 JobConfiguration,您可以在其中更改 defaultDataset 字段并更改此值对于每次迭代的每个不同数据集。以下 sample 显示了如何根据 Workflows 中数组的值进行迭代。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。