如何在BigQuery中将存储过程结果存入临时表或视图？

BigQuery中可以通过两种常见方式实现将存储过程的执行结果存入临时表，以下是具体操作：

1. 调用存储过程时捕获结果并插入临时表 #

如果你的存储过程通过SELECT语句直接返回结果集，可以在调用时用SELECT * FROM CALL(...)语法捕获结果，再写入临时表。

示例步骤： #

• 假设已有如下存储过程：

CREATE OR REPLACE PROCEDURE my_dataset.get_recent_sales()
BEGIN
  SELECT sale_id, sale_date, amount 
  FROM my_dataset.sales 
  WHERE sale_date >= DATE_SUB(CURRENT_DATE(), INTERVAL 30 DAY);
END;

• 调用存储过程并将结果写入会话临时表（仅当前会话有效，会话结束自动删除）：

CREATE TEMP TABLE #temp_recent_sales AS
SELECT * FROM CALL(my_dataset.get_recent_sales());

• 若需要追加数据到已存在的临时表，可改用INSERT INTO：

INSERT INTO #temp_recent_sales
SELECT * FROM CALL(my_dataset.get_recent_sales());

2. 在存储过程内部直接生成临时表 #

你也可以在存储过程逻辑中直接创建并写入临时表，调用存储过程后即可直接使用该临时表。

示例步骤： #

• 创建包含临时表写入逻辑的存储过程：

CREATE OR REPLACE PROCEDURE my_dataset.generate_temp_sales()
BEGIN
  -- 创建或覆盖会话临时表
  CREATE OR REPLACE TEMP TABLE #temp_recent_sales AS
  SELECT sale_id, sale_date, amount 
  FROM my_dataset.sales 
  WHERE sale_date >= DATE_SUB(CURRENT_DATE(), INTERVAL 30 DAY);
END;

• 调用存储过程后，直接访问临时表：

CALL my_dataset.generate_temp_sales();
-- 后续分析可直接使用临时表
SELECT COUNT(*), SUM(amount) FROM #temp_recent_sales;

临时表类型说明 #

• 会话临时表：以#为前缀，仅当前会话可见，会话结束后自动删除，适合单个会话内的临时数据处理。
• 全局临时表：以##为前缀，存储在session数据集下，所有会话均可访问，会话结束后自动清理，适合跨会话共享临时数据（需注意并发冲突）。

内容的提问来源于stack exchange，提问作者Consuela