##// END OF EJS Templates
schain
RSS
Modificación a kmamisr para ejecutarse en la versión 3, creación de scripts con terminación v3 para difereciarlos, se comentó la linea #720 de JroIO_param.py debido a que reiniciaba la lista de archivos, ocasionando la reescritura del archivo hdf5. Alguna otra modificación aparente es producto de algunas variaciones en espacios al usar la función print()
Modificación a kmamisr para ejecutarse en la versión 3, creación de scripts con terminación v3 para difereciarlos, se comentó la linea #720 de JroIO_param.py debido a que reiniciaba la lista de archivos, ocasionando la reescritura del archivo hdf5. Alguna otra modificación aparente es producto de algunas variaciones en espacios al usar la función print()
George Yong - - Load All Authors

File last commit:

r1167:1f521b07c958
r1279:c53fe2a4a291
Show More
serializer.py
107 lines | 2.5 KiB | text/x-python | PythonLexer
/ schainpy / model / serializer / serializer.py
History | Annotation | Raw |Copy content |Copy permalink
'''
Created on Jul 17, 2014
@author: roj-idl71
'''
DEFAULT_SERIALIZER = None
try:
import pickle
DEFAULT_SERIALIZER = 'cPickle'
except:
pass
try:
import msgpack_numpy
DEFAULT_SERIALIZER = 'msgpack'
except:
pass
# import jsonpickle
# import yaml
class Serializer(object):
def __init__(self):
self.serializer = None
def dumps(self, obj, **kwargs):
return self.serializer.dumps(obj, **kwargs)
def loads(self, obj, **kwargs):
return self.serializer.loads(obj, **kwargs)
class cPickleSerializer(Serializer):
def __init__(self):
self.serializer = cPickle
def dumps(self, obj, **kwargs):
return self.serializer.dumps(obj, 2)
def loads(self, obj, **kwargs):
return self.serializer.loads(obj)
class msgpackSerializer(Serializer):
def __init__(self):
self.serializer = msgpack_numpy
def dumps(self, obj, **kwargs):
return self.serializer.packb(obj)
def loads(self, obj, **kwargs):
return self.serializer.unpackb(obj)
# class jsonpickleSerializer(Serializer):
#
# def __init__(self):
#
# self.serializer = jsonpickle
#
# def dumps(self, obj, **kwargs):
# return self.serializer.encode(obj, **kwargs)
#
# def loads(self, obj, **kwargs):
# return self.serializer.decode(obj, **kwargs)
#
# class yamlSerializer(Serializer):
#
# def __init__(self):
#
# self.serializer = yaml
#
# def dumps(self, obj, **kwargs):
# return self.serializer.dump(obj, **kwargs)
#
# def loads(self, obj, **kwargs):
# return self.serializer.load(obj, **kwargs)
class DynamicSerializer(Serializer):
def __init__(self, module = None):
if not DEFAULT_SERIALIZER:
raise ImportError("Install a python serializer like cPickle or msgpack")
if not module:
module == DEFAULT_SERIALIZER
if module == 'cPickle':
self.serializer = cPickleSerializer()
#
# if module == 'jsonpickle':
# self.serializer = jsonpickleSerializer()
#
# if module == 'yaml':
# self.serializer = yamlSerializer()
if module == 'msgpack':
self.serializer = msgpackSerializer()
if __name__ == '__main__':
pass