This commit is contained in:
DingZQ
2025-03-15 14:26:38 +08:00
parent e67f487737
commit 176d6f00cd
2 changed files with 6 additions and 4 deletions

2
.gitignore vendored
View File

@@ -27,3 +27,5 @@ build
*.c *.c
*.pyd *.pyd
temp/ temp/
source_db_structure.dump
source_db.dump

View File

@@ -16,14 +16,14 @@ import csv
import pandas as pd import pandas as pd
import openpyxl import openpyxl
import pytz import pytz
import influxdb_info
# influxdb数据库连接信息 # influxdb数据库连接信息
url = "http://localhost:8086" # 替换为你的InfluxDB实例地址 url = influxdb_info.url
token = "MhJDl7odKW-y6wNXXUhUMRJ9oPzOvEe52E4NYD5GXtAAMV7BoHMFdet6HqUOt4DjZ-syKjwGao_k0ZIcgrGAPA==" # 替换为你的InfluxDB Token token = influxdb_info.token
org_name = "beibei" # 替换为你的Organization名称 org_name = influxdb_info.org
client = InfluxDBClient(url=url, token=token, org=org_name) client = InfluxDBClient(url=url, token=token, org=org_name)
def query_pg_scada_info_realtime(name: str) -> None: def query_pg_scada_info_realtime(name: str) -> None:
""" """
查询pg数据库中scada_info中属于realtime的数据 查询pg数据库中scada_info中属于realtime的数据