OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refine

Browse Source
This commit is contained in:
DingZQ
2025-04-19 17:47:15 +08:00
parent 9180b9c5cf
commit 7dca6685d1
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
influxdb_api.py
View File

@@ -3355,11 +3355,11 @@ if __name__ == "__main__":
client = InfluxDBClient(url=url, token=token) client = InfluxDBClient(url=url, token=token)
# step1: 检查连接状态，初始化influxdb的buckets # step1: 检查连接状态，初始化influxdb的buckets
try: # try:
# delete_buckets(org_name) # # delete_buckets(org_name)
create_and_initialize_buckets(org_name) # create_and_initialize_buckets(org_name)
except Exception as e: # except Exception as e:
print(f"连接失败: {e}") # print(f"连接失败: {e}")
# step2: 先查询pg数据库中scada_info的信息，然后存储SCADA数据到SCADA_data这个bucket里 # step2: 先查询pg数据库中scada_info的信息，然后存储SCADA数据到SCADA_data这个bucket里