dc_db.ProxyFindTask.ProxyFindTask Class Reference

Inheritance diagram for dc_db.ProxyFindTask.ProxyFindTask:

Collaboration diagram for dc_db.ProxyFindTask.ProxyFindTask:

Public Member Functions
def	__init__ (self)
def	process (self, proxyFinds, queryCallback)
def	fetchProxy (self, proxyFind, queryCallback, localSiteId)
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 ProxyFindTask.py.

Constructor & Destructor Documentation

__init__()

def dc_db.ProxyFindTask.ProxyFindTask.__init__

(

self

)

Definition at line 26 of file ProxyFindTask.py.

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

Member Function Documentation

fetchProxy()

def dc_db.ProxyFindTask.ProxyFindTask.fetchProxy	(		self,
			proxyFind,
			queryCallback,
			localSiteId
	)

Definition at line 57 of file ProxyFindTask.py.

  def fetchProxy(self, proxyFind, queryCallback, localSiteId):
    ret = []
    if localSiteId is None:
      additionWhere = None
    else:
      additionWhere = "`Site_Id` = '%s'" % localSiteId
    result = ProxyStatusTask.execCriterion(proxyFind, queryCallback, localSiteId, additionWhere)
    if hasattr(result, '__iter__'):
      for elem in result:
        localProxy = dc.EventObjects.Proxy(elem["Site_Id"], elem["Host"])
        localProxy.id = elem["Id"]
        localProxy.domains = elem["Domains"]
        localProxy.priority = elem["Priority"]
        localProxy.state = elem["State"]
        localProxy.countryCode = elem["CountryCode"]
        localProxy.countryName = elem["CountryName"]
        localProxy.regionCode = elem["RegionCode"]
        localProxy.regionName = elem["RegionName"]
        localProxy.cityName = elem["CityName"]
        localProxy.zipCode = elem["ZipCode"]
        localProxy.timeZone = elem["TimeZone"]
        localProxy.latitude = elem["Latitude"]
        localProxy.longitude = elem["Longitude"]
        localProxy.metroCode = elem["MetroCode"]
        localProxy.faults = elem["Faults"]
        localProxy.faultsMax = elem["FaultsMax"]
        localProxy.categoryId = elem["Category_Id"]
        localProxy.limits = elem["Limits"]
        localProxy.description = elem["Description"]
        localProxy.cDate = elem["CDate"]
        localProxy.uDate = elem["UDate"]
        ret.append(localProxy)
    return ret

process()

def dc_db.ProxyFindTask.ProxyFindTask.process	(		self,
			proxyFinds,
			queryCallback
	)

Definition at line 35 of file ProxyFindTask.py.

  def process(self, proxyFinds, queryCallback):
    ret = []
    for proxyFind in proxyFinds:
      localSiteIds = []
      if proxyFind.siteId is None:
        if proxyFind.siteCriterions is not None and len(proxyFind.siteCriterions) > 0:
          localSiteIds = SiteTask.execSiteCriterions(proxyFind.siteCriterions, queryCallback)
        else:
          localSiteIds.append(None)
      else:
        localSiteIds.append(proxyFind.siteId)
      for localSiteId in localSiteIds:
        ret += self.fetchProxy(proxyFind, queryCallback, localSiteId)
    return ret

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/ProxyFindTask.py