This commit is contained in:
DingZQ
2025-04-15 07:52:47 +08:00
parent 6235383aca
commit 65ba34ff3a

View File

@@ -6,14 +6,14 @@ import redis
import urllib.request import urllib.request
import influxdb_api import influxdb_api
import msgpack import msgpack
from datetime import datetime import datetime
# 将 Query的信息 序列号到 redis/json 默认不支持datetime需要自定义 # 将 Query的信息 序列号到 redis/json 默认不支持datetime需要自定义
# 自定义序列化函数 # 自定义序列化函数
# 序列化处理器 # 序列化处理器
def encode_datetime(obj): def encode_datetime(obj):
"""将datetime转换为可序列化的字典结构""" """将datetime转换为可序列化的字典结构"""
if isinstance(obj, datetime): if isinstance(obj, datetime.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")
@@ -24,7 +24,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.strptime( return datetime.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