diff --git a/influxdb_api.py b/influxdb_api.py index 37845c1..3096413 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -2724,8 +2724,8 @@ if __name__ == "__main__": # client.close() # step2: 先查询pg数据库中scada_info的信息,然后存储SCADA数据到SCADA_data这个bucket里 - # query_pg_scada_info_realtime('bb') - # query_pg_scada_info_non_realtime('bb') + query_pg_scada_info_realtime('bb') + query_pg_scada_info_non_realtime('bb') # 手动执行存储测试 # 示例1:store_realtime_SCADA_data_to_influxdb