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

Public Member Functions

def __init__ (self)
 
def process (self, attrDeletes, 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)
 

Static Public Member Functions

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

Static Public Attributes

string ATTR_DELETE_TEMPLATE = "DELETE FROM `%s` "
 

Detailed Description

Definition at line 23 of file AttrDeleteTask.py.

Constructor & Destructor Documentation

◆ __init__()

def dc_db.AttrDeleteTask.AttrDeleteTask.__init__ (   self)

Definition at line 31 of file AttrDeleteTask.py.

31  def __init__(self):
32  super(AttrDeleteTask, self).__init__()
33 
34 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ deleteUrlsAttributes()

def dc_db.AttrDeleteTask.AttrDeleteTask.deleteUrlsAttributes (   siteId,
  urlMd5,
  queryCallback 
)
static

Definition at line 71 of file AttrDeleteTask.py.

71  def deleteUrlsAttributes(siteId, urlMd5, queryCallback):
72  attrDeleteTask = AttrDeleteTask()
73  attrDeletes = [dc.EventObjects.AttributeDelete(siteId, None, {"WHERE": ("`URLMd5` = '%s'" % urlMd5)})]
74  res = attrDeleteTask.process(attrDeletes, queryCallback)
75  logger.debug(">>> AttrDeleteTask.deleteUrlsAttributes operation result = " + varDump(res))
76 
def varDump(obj, stringify=True, strTypeMaxLen=256, strTypeCutSuffix='...', stringifyType=1, ignoreErrors=False, objectsHash=None, depth=0, indent=2, ensure_ascii=False, maxDepth=10)
Definition: Utils.py:410
Here is the call graph for this function:

◆ process()

def dc_db.AttrDeleteTask.AttrDeleteTask.process (   self,
  attrDeletes,
  queryCallback 
)

Definition at line 40 of file AttrDeleteTask.py.

40  def process(self, attrDeletes, queryCallback):
41  ret = GeneralResponse()
42  for attrDelete in attrDeletes:
43  if self.isSiteExist(attrDelete.siteId, queryCallback):
44  try:
45  additionWhere = None
46  if attrDelete.name is None:
47  additionWhere = self.generateCriterionSQL(attrDelete.criterions)
48  else:
49  additionWhere = ("WHERE `Name` = '%s'" % attrDelete.name)
50  logger.debug(">>> additionWhere = " + str(additionWhere))
51  if additionWhere is not None and len(additionWhere) > 0:
52  query = AttrDeleteTask.ATTR_DELETE_TEMPLATE % ((Constants.DC_ATT_TABLE_NAME_TEMPLATE % attrDelete.siteId))
53  queryCallback(query + additionWhere, Constants.ATT_DB_ID)
54  ret.statuses.append(True)
55  else:
56  ret.statuses.append(False)
57  except Exception as excp:
58  logger.debug(">>> [AttributeDelete] Some Exception = " + str(type(excp)) + " " + str(excp))
59  ret.statuses.append(False)
60  else:
61  ret.statuses.append(False)
62  return ret
63 
64 
Here is the call graph for this function:
Here is the caller graph for this function:

Member Data Documentation

◆ ATTR_DELETE_TEMPLATE

string dc_db.AttrDeleteTask.AttrDeleteTask.ATTR_DELETE_TEMPLATE = "DELETE FROM `%s` "
static

Definition at line 26 of file AttrDeleteTask.py.


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