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 中数组的值进行迭代。

google-workflows yaml yaml