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
dc_db.FieldRecalculatorTask.FieldRecalculatorTask Class Reference
Inheritance diagram for dc_db.FieldRecalculatorTask.FieldRecalculatorTask:
Collaboration diagram for dc_db.FieldRecalculatorTask.FieldRecalculatorTask:

Public Member Functions

def __init__ (self)
 
def process (self, siteRecalculatorObjs, queryCallback)
 
- Public Member Functions inherited from dc_db.BaseTask.BaseTask
def isSiteExist (self, siteId, queryCallback, userId=None)
 
def generateCriterionSQL (self, criterions, additionWhere=None, siteId=None)
 
def fetchByCriterions (self, criterions, queryCallback)
 
def dbLock (self, mutexName, queryCallback, sleepTime=1, mutexLockTTL=Constants.DEFAULT_LOCK_TTL)
 
def dbUnlock (self, mutexName, queryCallback)
 
def createUrlsInsertQuery (self, siteId, localKeys, localValues)
 
def copyUrlsToDcUrls (self, siteId, queryCallback)
 
def statisticLogUpdate (self, localObj, urlMd5, siteId, status, queryCallback, isInsert=False)
 
def calculateMd5FormUrl (self, url, urlType, useNormilize=False)
 

Public Attributes

 recalculator
 

Additional Inherited Members

- Static Public Member Functions inherited from dc_db.BaseTask.BaseTask
def readValueFromSiteProp (siteId, propName, queryCallback, urlMd5=None)
 

Detailed Description

Definition at line 21 of file FieldRecalculatorTask.py.

Constructor & Destructor Documentation

◆ __init__()

def dc_db.FieldRecalculatorTask.FieldRecalculatorTask.__init__ (   self)

Definition at line 25 of file FieldRecalculatorTask.py.

25  def __init__(self):
26  super(FieldRecalculatorTask, self).__init__()
27  self.recalculator = FieldRecalculator()
28 
29 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ process()

def dc_db.FieldRecalculatorTask.FieldRecalculatorTask.process (   self,
  siteRecalculatorObjs,
  queryCallback 
)

Definition at line 35 of file FieldRecalculatorTask.py.

35  def process(self, siteRecalculatorObjs, queryCallback):
36  response = GeneralResponse()
37  for siteRecalculatorObj in siteRecalculatorObjs:
38  if hasattr(siteRecalculatorObj, "criterions") and siteRecalculatorObj.criterions is not None:
39  siteIds = self.fetchByCriterions(siteRecalculatorObj.criterions, queryCallback)
40  if siteIds is not None and hasattr(siteIds, '__iter__'):
41  for siteId in siteIds:
42  localSiteRecalculatorObj = copy.deepcopy(siteRecalculatorObj)
43  localSiteRecalculatorObj.criterions = None
44  localSiteRecalculatorObj.siteId = siteId
45  siteRecalculatorObjs.append(localSiteRecalculatorObj)
46  for siteRecalculatorObj in siteRecalculatorObjs:
47  response.statuses.append(siteRecalculatorObj.siteId)
48  self.recalculator.commonRecalc(siteRecalculatorObj.siteId, queryCallback, siteRecalculatorObj.recalcType)
49  return response
Here is the call graph for this function:
Here is the caller graph for this function:

Member Data Documentation

◆ recalculator

dc_db.FieldRecalculatorTask.FieldRecalculatorTask.recalculator

Definition at line 27 of file FieldRecalculatorTask.py.


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