Supabase RPC调用刷新物化视图函数超时问题求助

核心原因 #

Supabase托管版的API网关存在2分钟硬超时限制，即使你在Python客户端设置了更长的超时，网关会先中断请求，导致你看到的2分钟超时现象。此外，PostgreSQL的默认语句超时也可能影响，但网关限制是主要因素。

可行解决方法 #

1. 在函数内部设置语句超时（确保操作能完成） #

先给刷新操作设置足够长的语句超时，避免PostgreSQL层面提前终止：

CREATE OR REPLACE FUNCTION refresh_core_transactions()
RETURNS void
LANGUAGE plpgsql
AS $$
BEGIN
  -- 设置当前会话的语句超时为10分钟（根据实际耗时调整）
  SET LOCAL statement_timeout = '600s';
  REFRESH MATERIALIZED VIEW CONCURRENTLY core_transactions;
END;
$$;

2. 改用异步执行绕开网关超时 #

因为网关的2分钟限制无法在托管版修改，最可靠的方式是让刷新操作在PostgreSQL后台异步执行，RPC调用立即返回：

方法A：使用pg_cron一次性执行

首先在Supabase Dashboard的「Database -> Extensions」中启用pg_cron扩展，然后修改函数为：

CREATE OR REPLACE FUNCTION refresh_core_transactions()
RETURNS void
LANGUAGE plpgsql
AS $$
BEGIN
  -- 一次性调度刷新任务（执行后立即返回，任务在后台运行）
  PERFORM pg_cron.schedule(
    'one-time-refresh-core-transactions', -- 唯一任务名称
    NOW(), -- 立即执行
    $$SET statement_timeout = '600s'; REFRESH MATERIALIZED VIEW CONCURRENTLY core_transactions;$$
  );
  -- 执行后自动取消该一次性任务（可选）
  PERFORM pg_cron.unschedule('one-time-refresh-core-transactions');
END;
$$;

方法B：使用dblink异步执行

如果不想用定时任务，也可以用dblink扩展实现异步调用：

1. 先在Supabase Dashboard的「Database -> Extensions」中启用dblink扩展
2. 修改函数：

CREATE OR REPLACE FUNCTION refresh_core_transactions()
RETURNS void
LANGUAGE plpgsql
AS $$
DECLARE
  v_conn text := 'dbname=' || current_database();
BEGIN
  -- 建立连接并异步发送刷新命令
  PERFORM dblink_connect(v_conn);
  PERFORM dblink_send_query(v_conn, 'SET statement_timeout = ''600s''; REFRESH MATERIALIZED VIEW CONCURRENTLY core_transactions;');
END;
$$;

3. 验证物化视图要求 #

确保core_transactions物化视图有唯一索引，这是CONCURRENTLY选项的强制要求：

CREATE UNIQUE INDEX idx_core_transactions_id ON core_transactions(id); -- 替换为你的实际唯一键字段

注意事项 #

• 托管版Supabase无法修改API网关超时，异步执行是绕开这个限制的唯一可行方案
• 异步执行后，RPC调用会立即返回，但刷新操作仍在后台运行，你可以通过以下SQL查看任务状态：

SELECT * FROM pg_stat_activity WHERE query LIKE '%REFRESH MATERIALIZED VIEW%';

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