无法通过 sdk 在 BigQuery 上创建包含多个 SQL 语句的计划查询

Question

我有 2 个 SQL 语句，它们是 DELETE 和 INSERT。 INSERT 必须在 DELETE 之后运行。我计划通过 sdk bg mk 使用 DELETE ...; INSERT ...; 语句创建预定查询

但是，我可以通过来自 sdk 的 1 条语句（DELETE 或 INSERT）成功创建预定查询

bq mk \
    --transfer_config \
    --project_id='my-proj-id' \
    --schedule='every day 00:01' \
    --target_dataset='my_dataset' \
    --display_name='query_name' \
    --params='{"query": "DELETE ..."}' \
    --data_source=scheduled_query

当我尝试时

bq mk \
    --transfer_config \
    --project_id='my-proj-id' \
    --schedule='every day 00:01' \
    --target_dataset='my_dataset' \
    --display_name='query_name' \
    --params='{"query": "DELETE ...; INSERT ...;"}' \
    --data_source=scheduled_query

调度查询创建成功，但运行失败，报错

Error code 9 : Dataset specified in the query ('') is not consistent with Destination dataset 'my_dataset'.

注意：

• 我可以通过云控制台 (UI) 使用多个 SQL 语句创建计划查询。

---

更新

完整的命令

bq mk \
    --transfer_config \
    --project_id='my-proj-id' \
    --schedule='every day 00:01' \
    --target_dataset="my_dataset" \
    --display_name='del-insert-test' \
    --params='{"query": "DELETE FROM my-proj-id.my_dataset.my_table WHERE DATE(timestamp) = DATE_ADD(CURRENT_DATE(), INTERVAL -1 DAY); INSERT INTO my-proj-id.my_dataset.my_table SELECT res.col_a, res.col_b, res.col_c, timestamp FROM my-proj-id.my_dataset.my_raw_table, UNNEST (result) as res WHERE DATE(timestamp) = DATE_ADD(CURRENT_DATE(), INTERVAL -1 DAY);"}' \
    --data_source=scheduled_query

请注意，SQL语句不是实际的，而是类似的，我可以在云控制台上成功运行SQL语句

Answer 1

它对我来说就像一个魅力

  bq mk \
        --transfer_config \
        --project_id='gdglyon-cloudrun' \
        --schedule='every day 00:01' \
        --target_dataset='dlp_test' \
        --display_name='query_name' \
        --params='{"query": "DELETE from `gdglyon-cloudrun.dlp_test.name` where id=11;INSERT INTO `gdglyon-cloudrun.dlp_test.name` VALUES (11,111,\"@me.com\");"}' \
        --data_source=scheduled_query

你能分享更多关于你的请求吗？