serialtest.py
187 lines
| 6.1 KiB
| text/x-python
|
PythonLexer
Miguel Valdez
|
r568 | |||
| # | ||||
| # when Serializer is imported alone, fault indicates this package is | ||||
| # dependent on lookup, but don't import Lookup, instead: | ||||
| # | ||||
| import DynamicObject # dependent on pysvn | ||||
| import Serializer # dependent on Dynamic Object | ||||
| import msgpack | ||||
| import redis | ||||
| import numpy as np | ||||
| class NamedObject(): | ||||
| #--------------------------------------------- | ||||
| @staticmethod | ||||
| def indexListMatch(list_of_lists, name, value, name2=None, value2=None, unique_f=False): | ||||
| # | ||||
| # for each list's <element> attribute compare with value | ||||
| # if match, return True plus list | ||||
| # else return False plus empty list | ||||
| # | ||||
| # search needs to be named part of class for object else .<value> is unrecognized | ||||
| # | ||||
| # unique_f finds non-uniqueness | ||||
| index = [] # return empty indices | ||||
| list_data = [] # return empty list | ||||
| ii = 0 | ||||
| for theList in list_of_lists: | ||||
| cmd0 = "theList.%s == value" % (name) | ||||
| cmd1 = "isInlist(theList.%s,value)" % name | ||||
| # if name is valid then | ||||
| # match name against value | ||||
| # match name (as list) against value | ||||
| if (eval(cmd0) or eval(cmd1)): | ||||
| if (name2 != None): | ||||
| cmd2 = "theList.%s == value2" % name2 | ||||
| cmd3 = "isInlist(theList.%s,value2)" % name2 | ||||
| if (eval(cmd2) or eval(cmd3)): | ||||
| if (unique_f): | ||||
| index = index + [ii] | ||||
| list_data = list_data + [theList] # save list of lists if non-unique | ||||
| # don't exit on match, may be non-unique | ||||
| else: | ||||
| list_data = theList # save the list | ||||
| index = [ii] | ||||
| break | ||||
| else: | ||||
| if (unique_f): | ||||
| index = index + [ii] | ||||
| list_data = list_data + [theList] # list of lists if non-unique | ||||
| else: | ||||
| list_data = theList | ||||
| index = [ii] | ||||
| break # exit on match | ||||
| #endif | ||||
| ii = ii + 1 | ||||
| #end for | ||||
| return index, list_data # return indices of matches and list (or list of lists) | ||||
| #end indexListMatch | ||||
| #--------------------------------------------- | ||||
| @staticmethod | ||||
| def namedListMatch(list_of_lists, name, value, name2=None, value2=None, unique_f=None): | ||||
| # | ||||
| # for each list's <element> attribute compare with value | ||||
| # if match, return True plus list | ||||
| # else return False plus empty list | ||||
| # | ||||
| # search needs to be named part of class for object else .<value> is unrecognized | ||||
| # | ||||
| # unique_f finds non-uniqueness ('None' is same as False) | ||||
| match_f = False | ||||
| list_data = [] # initialize | ||||
| for theList in list_of_lists: | ||||
| cmd0 = "theList.%s == value" % (name) | ||||
| cmd1 = "isInlist(theList.%s,value)" % name | ||||
| # if name is valid then | ||||
| # match name against value | ||||
| # match name (as list) against value | ||||
| if (eval(cmd0) or eval(cmd1)): | ||||
| if (name2 != None): | ||||
| cmd2 = "theList.%s == value2" % name2 | ||||
| cmd3 = "isInlist(theList.%s,value2)" % name2 | ||||
| if (eval(cmd2) or eval(cmd3)): | ||||
| match_f = True | ||||
| if (unique_f): | ||||
| list_data = list_data + [theList] # save list of lists if non-unique | ||||
| # don't exit on match, may be non-unique | ||||
| else: | ||||
| list_data = theList # save the list | ||||
| break | ||||
| else: | ||||
| match_f = True | ||||
| if (unique_f): | ||||
| list_data = list_data + [theList] # list of lists if non-unique | ||||
| else: | ||||
| list_data = theList | ||||
| break # exit on match | ||||
| #endif | ||||
| #end for | ||||
| return match_f, list_data # return match, and list (or list of lists) | ||||
| #end namedListMatch | ||||
| #--------------------------------------------- | ||||
| @staticmethod | ||||
| def combineLists(object): | ||||
| # | ||||
| # used for dumping elements in list of lists for debugging | ||||
| # | ||||
| ret_list =[] | ||||
| ii = 0 | ||||
| while ii < len(object): | ||||
| ret_list = ret_list + [object[ii].list] # not a real list, so can't use built-in list iterator | ||||
| ii = ii + 1 | ||||
| return ret_list | ||||
| # end combineLists | ||||
| class StateListObject(NamedObject): | ||||
| def __init__(self, concurrent=None, hierarchical=None, history=None, state=None): | ||||
| self.concurrent = concurrent | ||||
| self.hierarchical = hierarchical | ||||
| self.history = history | ||||
| self.state = state | ||||
| self.list = [self.concurrent, self.hierarchical, self.history, self.state ] | ||||
| #end class StateListObject | ||||
| source_object = "my test string" | ||||
| serializer = "yaml" | ||||
| # | ||||
| # python versioning issue (ver 2.7 -> else path) | ||||
| # | ||||
| if isinstance(serializer,Serializer.Serializer): | ||||
| serial_type = Serializer.serial_types[serializer] | ||||
| else: | ||||
| serial_type = serializer | ||||
| serializer = Serializer.serializers[serializer]() | ||||
| datastr = serializer.toSerial(source_object) | ||||
| dest_object = serializer.fromSerial(datastr) | ||||
| print "dest_object=",dest_object | ||||
| myObject = StateListObject(hierarchical="yes",state=np.array([1,2,3.0])) | ||||
| datastr = serializer.toSerial(myObject) | ||||
| packed = msgpack.packb(datastr) | ||||
| try: | ||||
| r= redis.StrictRedis(host='localhost',port=6379,db=0) | ||||
| except Exception as eobj: | ||||
| print "is the redis server running?",eobj | ||||
| else: | ||||
| r.set('baz',packed) # converts to string | ||||
| x = r.get('baz') | ||||
| unpacked = msgpack.unpackb(x) | ||||
| dest_object = serializer.fromSerial(unpacked) | ||||
| print "val1=",dest_object.hierarchical | ||||
| val2 = dest_object.state | ||||
| print "val2=",val2 | ||||
| # can numpy array be used as array? | ||||
| print val2.shape | ||||