dc_db.ProxyDeleteTask.ProxyDeleteTask Class Reference

Inheritance diagram for dc_db.ProxyDeleteTask.ProxyDeleteTask:

Collaboration diagram for dc_db.ProxyDeleteTask.ProxyDeleteTask:

Public Member Functions
def	__init__ (self)
def	process (self, proxyDeletes, queryCallback)
def	deleteProxy (self, localProxy, 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)

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 22 of file ProxyDeleteTask.py.

Constructor & Destructor Documentation

__init__()

def dc_db.ProxyDeleteTask.ProxyDeleteTask.__init__

(

self

)

Definition at line 27 of file ProxyDeleteTask.py.

  def __init__(self):
    super(ProxyDeleteTask, self).__init__()

Member Function Documentation

deleteProxy()

def dc_db.ProxyDeleteTask.ProxyDeleteTask.deleteProxy	(		self,
			localProxy,
			queryCallback
	)

Definition at line 65 of file ProxyDeleteTask.py.

  def deleteProxy(self, localProxy, queryCallback):
    DELETE_PROXY_TEMPLATE = "DELETE FROM `sites_proxy` WHERE `Site_Id` = '%s' AND `Host` = '%s'"
    query = DELETE_PROXY_TEMPLATE % (localProxy.siteId, localProxy.host)
    queryCallback(query, Constants.PRIMARY_DB_ID)
    return True

process()

def dc_db.ProxyDeleteTask.ProxyDeleteTask.process	(		self,
			proxyDeletes,
			queryCallback
	)

Definition at line 36 of file ProxyDeleteTask.py.

  def process(self, proxyDeletes, queryCallback):
    generalResponse = GeneralResponse()
    for proxyDelete in proxyDeletes:
      localProxyDeletes = []
      if proxyDelete.siteId is None or proxyDelete.host is None and proxyDelete.criterions is not None:
        result = ProxyStatusTask.execCriterion(proxyDelete, queryCallback, proxyDelete.siteId)
        for elem in result:
          localProxy = copy.deepcopy(proxyDelete)
          if localProxy.siteId is None:
            localProxy.siteId = elem["Site_Id"]
          if localProxy.host is None:
            localProxy.host = elem["Host"]
          localProxyDeletes.append(localProxy)
      else:
        localProxyDeletes.append(proxyDelete)
      logger.debug(">>> len(localProxyStatuses) = " + str(len(localProxyDeletes)))
      for localProxy in localProxyDeletes:
        if self.deleteProxy(localProxy, queryCallback):
          generalResponse.statuses.append(True)
        else:
          generalResponse.statuses.append(False)
    return generalResponse

Here is the call graph for this function:

Here is the caller graph for this function:

---

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

• sources/hce/dc_db/ProxyDeleteTask.py