This commit is contained in:
DingZQ
2025-04-04 11:15:41 +08:00
parent 6f06eb43e7
commit cefba29195

View File

@@ -19,7 +19,6 @@ from online_Analysis import *
from fastapi.middleware.cors import CORSMiddleware from fastapi.middleware.cors import CORSMiddleware
from influxdb_client import InfluxDBClient, BucketsApi, WriteApi, OrganizationsApi, Point, QueryApi from influxdb_client import InfluxDBClient, BucketsApi, WriteApi, OrganizationsApi, Point, QueryApi
from typing import List, Dict from typing import List, Dict
import datetime
from datetime import datetime, timedelta, timezone from datetime import datetime, timedelta, timezone
from dateutil import parser from dateutil import parser
import influxdb_info import influxdb_info
@@ -52,7 +51,7 @@ app = FastAPI()
# 序列化处理器 # 序列化处理器
def encode_datetime(obj): def encode_datetime(obj):
"""将datetime转换为可序列化的字典结构""" """将datetime转换为可序列化的字典结构"""
if isinstance(obj, datetime.datetime): if isinstance(obj, datetime):
return { return {
'__datetime__': True, '__datetime__': True,
'as_str': obj.strftime("%Y%m%dT%H:%M:%S.%f") 'as_str': obj.strftime("%Y%m%dT%H:%M:%S.%f")
@@ -63,7 +62,7 @@ def encode_datetime(obj):
def decode_datetime(obj): def decode_datetime(obj):
"""将字典还原为datetime对象""" """将字典还原为datetime对象"""
if '__datetime__' in obj: if '__datetime__' in obj:
return datetime.datetime.strptime( return datetime.strptime(
obj['as_str'], "%Y%m%dT%H:%M:%S.%f" obj['as_str'], "%Y%m%dT%H:%M:%S.%f"
) )
return obj return obj