我在 TimescaleDB（时间序列数据的 PostgreSQL 扩展）中创建了一个物化视图，当我使用 PGAdmin 中的以下代码刷新它时，会添加最新数据，一切正常：
REFRESH MATERIALIZED VIEW CONCURRENTLY
public.time_series_mv
WITH DATA;
当我在Python中使用相同的用户（postgres）运行完全相同的代码时，它表明成功（即没有发生错误），但最新数据没有actually已添加到物化视图中...
因此，我尝试创建一个函数来做同样的事情：
CREATE OR REPLACE FUNCTION refresh_time_series_mv()
RETURNS void
SECURITY DEFINER
AS $$
BEGIN
REFRESH MATERIALIZED VIEW CONCURRENTLY time_series_mv with data;
RETURN;
END;
$$ LANGUAGE plpgsql;
然后我按如下方式运行该函数，它再次在浏览器中的 PGAdmin 中运行，但当我在调度应用程序中从 Python 运行相同的 SQL 时则不起作用。
select refresh_time_series_mv();
这是我的 Python 代码：
import psycopg2
SQL1 = """
REFRESH MATERIALIZED VIEW CONCURRENTLY
public.time_series_mv
WITH DATA
"""
SQL2 = "select refresh_time_series_mv();"
host = os.getenv("HOST")
port = int(os.getenv("PORT"))
dbname = os.getenv('DB')
user = os.getenv("USER")
password = os.getenv("PASS")
conn = psycopg2.connect(
host=host,
port=port,
dbname=dbname,
user=user,
password=password,
connect_timeout=5
)
cursor = conn.cursor()
cursor.execute(SQL1)
# cursor.execute(SQL2)
cursor.close()
conn.close()
无论我使用“SQL1”还是“SQL2”，Python 代码都会成功运行（显然，对于 Python），但同样，数据不会在物化视图中刷新...
我使用相同的用户名和密码连接到数据库，无论是在 PGAdmin 中还是在 Python 中。
有任何想法吗？谢谢！
-Sean
