如何将Grafana中可正常运行的PostgreSQL SQL查询在Pandas中复现并解决执行报错问题

看起来你遇到的问题主要是Grafana专属语法和PostgreSQL原生SQL的差异导致的，我来一步步帮你修正：

错误原因分析 #

你的代码报错核心有两个关键点：

1. $__timeFilter是Grafana专属变量：PostgreSQL无法识别这个语法，Grafana会在运行时把它替换成对应的时间范围条件（比如"time" BETWEEN 'xxx' AND 'xxx'），但直接在Pandas里执行时数据库无法解析这个$开头的变量。
2. JSON字段语法错误：你把原Grafana查询里的kv_tags->'equip_name' = '["35201"]'改成了kv_tags->equip_name = ["35201"]，去掉了关键的单引号，PostgreSQL会把["35201"]当成语法错误。

修正后的解决方案 #

1. 替换时间过滤条件 #

把Grafana的$__timeFilter("time")替换成PostgreSQL能识别的时间范围条件，比如：

• 取最近7天的数据："time" >= NOW() - INTERVAL '7 days'
• 手动指定起止时间："time" BETWEEN '2024-01-01 00:00:00' AND '2024-01-08 23:59:59'

2. 修正JSON字段匹配 #

根据你的kv_tags字段类型（JSON或JSONB），选择合适的匹配方式：

• 如果kv_tags是JSON类型，保留原语法但补全单引号：kv_tags->'equip_name' = '["35201"]'
• 如果是JSONB类型（更推荐），用@>操作符检查JSON结构包含关系，逻辑更严谨：kv_tags @> '{"equip_name": ["35201"]}'

3. 完整可运行代码示例 #

import pandas as pd
import psycopg2

# 假设你已经通过psycopg2建立了dbconn连接
# 自定义时间范围（这里示例取最近7天）
time_filter = '"time" >= NOW() - INTERVAL \'7 days\''

# 构建兼容PostgreSQL的查询语句
sql_query = f'''
SELECT "time" AS "time", metric AS metric, value 
FROM volttron 
WHERE {time_filter} 
  AND kv_tags->\'equip_name\' = \'["35201"]\' 
  AND \'power\' = ANY(m_tags) 
ORDER BY 1,2
'''

# 执行查询并获取DataFrame
eGauge35201 = pd.read_sql(sql_query, dbconn)

如果你的kv_tags是JSONB类型，把JSON条件改成下面这样会更可靠：

sql_query = f'''
SELECT "time" AS "time", metric AS metric, value 
FROM volttron 
WHERE {time_filter} 
  AND kv_tags @> \'{{"equip_name": ["35201"]}}\' 
  AND \'power\' = ANY(m_tags) 
ORDER BY 1,2
'''

额外调试建议 #

• 先在pgAdmin或者psql命令行工具中测试修正后的SQL语句，确认能正常返回数据后再放到Pandas中执行，这样更容易定位语法问题。
• 如果不确定kv_tags的字段类型，可以先执行SELECT data_type FROM information_schema.columns WHERE table_name = 'volttron' AND column_name = 'kv_tags';来查看。

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