76 lines
2.2 KiB
Python
76 lines
2.2 KiB
Python
|
#!/usr/bin/env python
|
|||
|
|
# -*- coding: utf-8 -*-
|
|||
|
|
"""诊断指定时间区间的InfluxDB数据"""
|
|||
|
|
|
|||
|
|
import json
|
|||
|
|
import sys
|
|||
|
|
from datetime import datetime, timezone, timedelta
|
|||
|
|
|
|||
|
|
def main():
|
|||
|
|
# 写死配置
|
|||
|
|
influx_config = {
|
|||
|
|
"url": "http://10.0.5.232:8086",
|
|||
|
|
"org": "MEASCON",
|
|||
|
|
"token": "JPZMq2UP5ORhLq8CfsPbawl6k0MSDlJmEwMJ2uvR_TXqW5bUOWIYBQOSXkGNzDqOU3rnuGpIxGxrB_mlAF-EEw=="
|
|||
|
|
}
|
|||
|
|
bucket = "PCM"
|
|||
|
|
measurement = "PCM_Measurement"
|
|||
|
|
|
|||
|
|
# 时间区间（UTC+8转UTC）
|
|||
|
|
start_local = "2026-03-12T17:39:10"
|
|||
|
|
end_local = "2026-03-12T21:09:17"
|
|||
|
|
|
|||
|
|
# 本地时间转UTC（本地时间-8小时=UTC）
|
|||
|
|
start_time = datetime.strptime(start_local, "%Y-%m-%dT%H:%M:%S")
|
|||
|
|
start_time = start_time - timedelta(hours=8)
|
|||
|
|
start_time = start_time.replace(tzinfo=timezone.utc)
|
|||
|
|
|
|||
|
|
end_time = datetime.strptime(end_local, "%Y-%m-%dT%H:%M:%S")
|
|||
|
|
end_time = end_time - timedelta(hours=8)
|
|||
|
|
end_time = end_time.replace(tzinfo=timezone.utc)
|
|||
|
|
|
|||
|
|
print(f"查询时间: {start_time} → {end_time}")
|
|||
|
|
|
|||
|
|
try:
|
|||
|
|
from influxdb_client import InfluxDBClient
|
|||
|
|
|
|||
|
|
client = InfluxDBClient(
|
|||
|
|
url=influx_config['url'],
|
|||
|
|
org=influx_config['org'],
|
|||
|
|
token=influx_config['token']
|
|||
|
|
)
|
|||
|
|
query_api = client.query_api()
|
|||
|
|
|
|||
|
|
# 查询主轴承#1数据
|
|||
|
|
flux = f'''
|
|||
|
|
from(bucket: "{bucket}")
|
|||
|
|
|> range(start: {start_time.strftime('%Y-%m-%dT%H:%M:%SZ')}, stop: {end_time.strftime('%Y-%m-%dT%H:%M:%SZ')})
|
|||
|
|
|> filter(fn: (r) => r["_measurement"] == "{measurement}")
|
|||
|
|
|> filter(fn: (r) => r["data_type"] == "LSDAQ")
|
|||
|
|
|> filter(fn: (r) => r["_field"] == "主轴承#1")
|
|||
|
|
|> limit(n: 10)
|
|||
|
|
'''
|
|||
|
|
|
|||
|
|
print(f"\nFlux查询:\n{flux}\n")
|
|||
|
|
|
|||
|
|
tables = query_api.query(flux)
|
|||
|
|
|
|||
|
|
count = 0
|
|||
|
|
for table in tables:
|
|||
|
|
for record in table.records:
|
|||
|
|
count += 1
|
|||
|
|
print(f"时间: {record.get_time()}, 值: {record.get_value()}")
|
|||
|
|
|
|||
|
|
print(f"\n共找到 {count} 条数据")
|
|||
|
|
|
|||
|
|
client.close()
|
|||
|
|
|
|||
|
|
except Exception as e:
|
|||
|
|
print(f"错误: {e}", file=sys.stderr)
|
|||
|
|
return 1
|
|||
|
|
|
|||
|
|
return 0
|
|||
|
|
|
|||
|
|
if __name__ == "__main__":
|
|||
|
|
sys.exit(main())
|