我想serialize a python object
,将它保存到mysql
(基于Django ORM)后我想得到它并将此对象传递给需要这种对象作为参数的函数。
以下两部分是我的主要逻辑代码:
1保存参数:
class Param(object):
def __init__(self, name=None, targeting=None, start_time=None, end_time=None):
self.name = name
self.targeting = targeting
self.start_time = start_time
self.end_time = end_time
#...
param = Param()
param.name = "name1"
param.targeting= "targeting1"
task_param = {
"task_id":task_id, # string
"user_name":user_name, # string
"param":param, # Param object
"save_param":save_param_dict, # dictionary
"access_token":access_token, # string
"account_id": account_id, # string
"page_id": page_id, # string
"task_name":"sync_create_ad" # string
}
class SyncTaskList(models.Model):
task_id = models.CharField(max_length=128, blank=True, null=True)
ad_name = models.CharField(max_length=128, blank=True, null=True)
user_name = models.CharField(max_length=128, blank=True, null=True)
task_status = models.SmallIntegerField(blank=True, null=True)
task_fail_reason = models.CharField(max_length=255, blank=True, null=True)
task_name = models.CharField(max_length=128, blank=True, null=True)
start_time = models.DateTimeField()
end_time = models.DateTimeField(blank=True, null=True)
task_param = models.TextField(blank=True, null=True)
class Meta:
managed = False
db_table = 'sync_task_list'
SyncTaskList(
task_id=task_id,
ad_name=param.name,
user_name=user_name,
task_status=0,
task_param = task_param,
).save()
2使用参数部分
def add_param(param, access_token):
pass
task_list = SyncTaskList.objects.filter(task_status=0)
for task in task_list:
task_param = json.loads(task.task_param)
add_param(task_param["param"], task_param["access_token"]) # pass param object to function add_param
如果我直接使用Django ORM
将task_param保存到mysql中,我会收到错误,
json.decoder.JSONDecodeError: Expecting property name enclosed in double quotes: line 1 column 2 (char 1)
对于ORM操作之后,我得到字符串谁的属性名称用单引号括起来,如:
# in mysql it saved as
task_param: " task_param: {'task_id': 'e4b8b240cefaf58fa9fa5a591221c90a',
'user_name': 'jimmy',
'param': Param(name='name1',
targeting='geo_locations',
),
'save_param': {}}"
我现在对序列化python对象感到困惑,然后如何加载这个原始对象并将其传递给函数?
任何评论都非常受欢迎。十分感谢。
到目前为止更新我的解
task_param = {
# ...
"param":vars(param), # turn Param object to dictionary
# ...
}
SyncTaskList(
#...
task_param = json.dumps(task_param),
#...
).save()
#task_list = SyncTaskList.objects.filter(task_status=0)
#for task in task_list:
task_param = json.loads(task.task_param)
add_param(Param(**task_param["param"]), task_param["access_token"])
根据@ AJS的答案进行更新
直接pickle dumps
并保存为binary field
,然后pickle loads
it也工作
对此更好的解决方案?
您可以使用pickle
,基本上你是序列化你的python对象,并使用BinaryField
作为Django中的模型字段类型将其保存为MySQL数据库中的字节,因为我不认为JSON序列化可以在你的情况下工作,因为你有一个python对象作为你的dict中的一个值,当你从db中取出你的数据时,它的语法类似于json库,见下文。
import pickle
#to pickle
data = pickle.dumps({'name':'testname'})
# to unpickle just do
pickle.loads(data)
因此,在您取消对象的情况下,您应该以与泡菜之前相同的形式获取数据。
希望这可以帮助。
试着看看msgpack https://msgpack.org/index.html
与pickle(特定于python)不同,msgpack受到许多语言的支持(因此用于写入mysql的语言可能与用于读取的语言不同)。
还有一些项目将这些序列化程序库集成到Django模型字段中: