dc_db.ProxyUpdateTask.ProxyUpdateTask Class Reference

Inheritance diagram for dc_db.ProxyUpdateTask.ProxyUpdateTask:

Collaboration diagram for dc_db.ProxyUpdateTask.ProxyUpdateTask:

Public Member Functions
def	__init__ (self)
def	process (self, proxyUpdates, queryCallback)
def	updateProxy (self, proxyUpdate, 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 21 of file ProxyUpdateTask.py.

Constructor & Destructor Documentation

__init__()

def dc_db.ProxyUpdateTask.ProxyUpdateTask.__init__

(

self

)

Definition at line 26 of file ProxyUpdateTask.py.

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

Member Function Documentation

process()

def dc_db.ProxyUpdateTask.ProxyUpdateTask.process	(		self,
			proxyUpdates,
			queryCallback
	)

Definition at line 35 of file ProxyUpdateTask.py.

  def process(self, proxyUpdates, queryCallback):
    generalResponse = GeneralResponse()
    for proxyUpdate in proxyUpdates:
      status = False
#       if ProxyNewTask.lookProxyInDB(proxyUpdate, queryCallback):
      if self.updateProxy(proxyUpdate, queryCallback):
        status = True
      generalResponse.statuses.append(status)
    return generalResponse

Here is the call graph for this function:

Here is the caller graph for this function:

updateProxy()

def dc_db.ProxyUpdateTask.ProxyUpdateTask.updateProxy	(		self,
			proxyUpdate,
			queryCallback
	)

Definition at line 51 of file ProxyUpdateTask.py.

  def updateProxy(self, proxyUpdate, queryCallback):
    ret = False

    fields, values = Constants.getFieldsValuesTuple(proxyUpdate, Constants.ProxyTableDict)
    fieldValueString = Constants.createFieldsValuesString(fields, values, Constants.proxyExcludeList)
    if fieldValueString is not None and fieldValueString != "":
      PROXY_UPDATE_TEMPLATE = "UPDATE `sites_proxy` SET %s WHERE `Site_Id` = '%s' AND `Host` = '%s'"
      query = PROXY_UPDATE_TEMPLATE % (fieldValueString, proxyUpdate.siteId, proxyUpdate.host)

      print query
      queryCallback(query, Constants.PRIMARY_DB_ID)
      ret = True
    return ret

---

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

• sources/hce/dc_db/ProxyUpdateTask.py