HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator Class Reference

DTMCObjectsSerializator Class contents serialize/deserialize methods for incoming "DTMC" commands. More...

Inheritance diagram for dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator:
Collaboration diagram for dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator:

Public Member Functions

def __init__ (self)
 
def newDeserialize (self, jsonData)
 newDeserialize method, deserializes incoming jsonData to the NewTask object jsonData - incoming json string More...
 
def checkDeserialize (self, jsonData)
 
def terminateDeserialize (self, jsonData)
 
def getDeserialize (self, jsonData)
 
def statusDeserialize (self, jsonData)
 
def cleanupDeserialize (self, jsonData)
 
def getTasksDeserialize (self, jsonData)
 

Detailed Description

DTMCObjectsSerializator Class contents serialize/deserialize methods for incoming "DTMC" commands.

Definition at line 24 of file DTMCObjectsSerializator.py.

Constructor & Destructor Documentation

◆ __init__()

def dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator.__init__ (   self)

Definition at line 26 of file DTMCObjectsSerializator.py.

26  def __init__(self):
27  pass
28 
29 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ checkDeserialize()

def dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator.checkDeserialize (   self,
  jsonData 
)

Definition at line 89 of file DTMCObjectsSerializator.py.

89  def checkDeserialize(self, jsonData):
90  checkObject = None
91  if "id" in jsonData:
92 # checkObject.id = int(jsonData["id"])
93  checkObject = dtm.EventObjects.CheckTaskState(int(jsonData["id"]))
94  else:
95  raise Exceptions.DeserilizeException("CHECK.id json-field not found")
96  if "type" in jsonData:
97  checkObject.type = int(jsonData["type"])
98  else:
99  raise Exceptions.DeserilizeException("CHECK.type json-field not found")
100  return checkObject
101 
102 
CheckTaskState event object, for check task status inside EE.

◆ cleanupDeserialize()

def dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator.cleanupDeserialize (   self,
  jsonData 
)

Definition at line 186 of file DTMCObjectsSerializator.py.

186  def cleanupDeserialize(self, jsonData):
187  cleanupObject = None
188  if "id" in jsonData:
189  cleanupObject = dtm.EventObjects.DeleteTaskResults(int(jsonData["id"]))
190  else:
191  raise Exceptions.DeserilizeException("CLEANUP.id json-field not found")
192  return cleanupObject
193 
194 
DeleteTaskResults event object, for delete task results from DTM application operation.

◆ getDeserialize()

def dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator.getDeserialize (   self,
  jsonData 
)

Definition at line 149 of file DTMCObjectsSerializator.py.

149  def getDeserialize(self, jsonData):
150  fetchObject = None
151  if "id" in jsonData:
152 # fetchObject.id = int(jsonData["id"])
153  fetchObject = dtm.EventObjects.FetchTasksResults(int(jsonData["id"]))
154  else:
155  raise Exceptions.DeserilizeException("GET.id json-field not found")
156  if "type" in jsonData:
157  fetchObject.type = int(jsonData["type"])
158  else:
159  raise Exceptions.DeserilizeException("GET.type json-field not found")
160  return fetchObject
161 
162 
FetchTasksResults event object, for fetch task's results data from EE.

◆ getTasksDeserialize()

def dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator.getTasksDeserialize (   self,
  jsonData 
)

Definition at line 195 of file DTMCObjectsSerializator.py.

195  def getTasksDeserialize(self, jsonData):
196  getTasksObject = None
197  if "fetchNum" in jsonData:
198  getTasksObject = dtm.EventObjects.FetchAvailabelTaskIds(int(jsonData["fetchNum"]))
199  else:
200  raise Exceptions.DeserilizeException("GET_TASKS.fetchNum json-field not found")
201  if "fetchAdditionalFields" in jsonData:
202  getTasksObject.fetchAdditionalFields = bool(jsonData["fetchAdditionalFields"])
203  if "tableName" in jsonData:
204  getTasksObject.tableName = str(jsonData["tableName"])
205  if "criterions" in jsonData and jsonData["criterions"] is not None:
206  if type(jsonData["criterions"]) is not types.DictType:
207  raise Exceptions.DeserilizeException("GET_TASKS.criterions has wrong type")
208  if hasattr(getTasksObject.criterions, '__iter__'):
209  getTasksObject.criterions.update(jsonData["criterions"])
210  else:
211  getTasksObject.criterions = jsonData["criterions"]
212  return getTasksObject
213 
FetchAvailabelTaskIds event object, for fetch available task id.

◆ newDeserialize()

def dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator.newDeserialize (   self,
  jsonData 
)

newDeserialize method, deserializes incoming jsonData to the NewTask object jsonData - incoming json string

Definition at line 32 of file DTMCObjectsSerializator.py.

32  def newDeserialize(self, jsonData):
33  newObject = dtm.EventObjects.NewTask("")
34  if "command" in jsonData:
35  newObject.command = jsonData["command"]
36  else:
37  raise Exceptions.DeserilizeException("NEW.command json-field not found")
38  if "id" in jsonData:
39  newObject.id = int(jsonData["id"])
40  else:
41  raise Exceptions.DeserilizeException("NEW.id json-field not found")
42  if "input" in jsonData:
43  newObject.input = jsonData["input"]
44  else:
45  raise Exceptions.DeserilizeException("NEW.input json-field not found")
46  if "files" in jsonData:
47  if type(jsonData["files"]) != type([]):
48  raise Exceptions.DeserilizeException("NEW.files not list type")
49  newObject.files = jsonData["files"]
50  else:
51  raise Exceptions.DeserilizeException("NEW.files json-field not found")
52  if "session" in jsonData:
53  if type(jsonData["session"]) != type({}):
54  raise Exceptions.DeserilizeException("NEW.session not dict type")
55  if newObject.session == None:
56  newObject.session = jsonData["session"]
57  else:
58  for key in jsonData["session"].keys():
59  newObject.session[key] = jsonData["session"][key]
60  else:
61  raise Exceptions.DeserilizeException("NEW.session json-field not found")
62  if "strategy" in jsonData:
63  if type(jsonData["strategy"]) != type({}):
64  raise Exceptions.DeserilizeException("NEW.strategy not dict type")
65  if newObject.strategy == None:
66  newObject.strategy = jsonData["strategy"]
67  else:
68  for key in jsonData["strategy"].keys():
69  newObject.strategy[key] = jsonData["strategy"][key]
70  else:
71  raise Exceptions.DeserilizeException("NEW.strategy json-field not found")
72  if "limits" in jsonData:
73  if type(jsonData["limits"]) != type({}):
74  raise Exceptions.DeserilizeException("NEW.limits not dict type")
75  if newObject.limits == None:
76  newObject.limits = jsonData["limits"]
77  else:
78  for key in jsonData["limits"].keys():
79  newObject.limits[key] = jsonData["limits"][key]
80  else:
81  raise Exceptions.DeserilizeException("NEW.limits json-field not found")
82  if "autoCleanupFields" in jsonData:
83  if type(jsonData["autoCleanupFields"]) != type({}):
84  raise Exceptions.DeserilizeException("NEW.autoCleanupFields not dict type")
85  newObject.autoCleanupFields = jsonData["autoCleanupFields"]
86  return newObject
87 
88 
NewTask event object, defines the Task object fields.

◆ statusDeserialize()

def dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator.statusDeserialize (   self,
  jsonData 
)

Definition at line 163 of file DTMCObjectsSerializator.py.

163  def statusDeserialize(self, jsonData):
164  statusObject = None
165  if "ids" in jsonData:
166  if type(jsonData["ids"]) != type([]):
167  raise Exceptions.DeserilizeException("STATUS.ids not list type")
168  statusObject = dtm.EventObjects.GetTasksStatus(list(jsonData["ids"]))
169  else:
170  raise Exceptions.DeserilizeException("STATUS.ids json-field not found")
171  if "filters" in jsonData:
172  if type(jsonData["filters"]) != type({}):
173  raise Exceptions.DeserilizeException("STATUS.filters not dict type")
174  statusObject.filters = jsonData["filters"]
175  else:
176  raise Exceptions.DeserilizeException("STATUS.filters json-field not found")
177  if "strategy" in jsonData:
178  if type(jsonData["strategy"]) != type({}):
179  raise Exceptions.DeserilizeException("STATUS.strategy not dict type")
180  statusObject.strategy = jsonData["strategy"]
181  else:
182  raise Exceptions.DeserilizeException("STATUS.strategy json-field not found")
183  return statusObject
184 
185 
GetTasksStatus event object, for check task status operation.

◆ terminateDeserialize()

def dtmc.DTMCObjectsSerializator.DTMCObjectsSerializator.terminateDeserialize (   self,
  jsonData 
)

Definition at line 103 of file DTMCObjectsSerializator.py.

103  def terminateDeserialize(self, jsonData):
104  deleteObject = None
105  if "id" in jsonData:
106 # deleteObject.id = int(jsonData["id"])
107  deleteObject = dtm.EventObjects.DeleteTask(int(jsonData["id"]))
108  else:
109  raise Exceptions.DeserilizeException("TERMINATE.id json-field not found")
110  if "alg" in jsonData:
111  deleteObject.alg = int(jsonData["alg"])
112  else:
113  raise Exceptions.DeserilizeException("TERMINATE.alg json-field not found")
114  if "delay" in jsonData:
115  deleteObject.delay = int(jsonData["delay"])
116  else:
117  raise Exceptions.DeserilizeException("TERMINATE.delay json-field not found")
118  if "repeat" in jsonData:
119  deleteObject.repeat = int(jsonData["repeat"])
120  else:
121  raise Exceptions.DeserilizeException("TERMINATE.repeat json-field not found")
122  if "signal" in jsonData:
123  deleteObject.signal = int(jsonData["signal"])
124  else:
125  raise Exceptions.DeserilizeException("TERMINATE.signal json-field not found")
126  if "host" in jsonData:
127  deleteObject.host = str(jsonData["host"])
128  else:
129  raise Exceptions.DeserilizeException("TERMINATE.host json-field not found")
130  if "port" in jsonData:
131  deleteObject.port = int(jsonData["port"])
132  else:
133  raise Exceptions.DeserilizeException("TERMINATE.port json-field not found")
134  if "action" in jsonData:
135  deleteObject.action = int(jsonData["action"])
136  else:
137  raise Exceptions.DeserilizeException("TERMINATE.action json-field not found")
138  if "strategy" in jsonData:
139  if type(jsonData["strategy"]) != type({}):
140  raise Exceptions.DeserilizeException("TERMINATE.strategy not dict type")
141  if deleteObject.strategy == None:
142  deleteObject.strategy = jsonData["strategy"]
143  else:
144  for key in jsonData["strategy"].keys():
145  deleteObject.strategy[key] = jsonData["strategy"][key]
146  return deleteObject
147 
148 
DeleteTask event object, to delete task from DTM application and from EE.

The documentation for this class was generated from the following file: