dc_db.ProxyStatusTask.ProxyStatusTask Class Reference

Inheritance diagram for dc_db.ProxyStatusTask.ProxyStatusTask:

Collaboration diagram for dc_db.ProxyStatusTask.ProxyStatusTask:

Public Member Functions
def	__init__ (self)
def	process (self, proxyStatuses, queryCallback)
def	fetchProxy (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)

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

Detailed Description

Definition at line 24 of file ProxyStatusTask.py.

Constructor & Destructor Documentation

__init__()

def dc_db.ProxyStatusTask.ProxyStatusTask.__init__

(

self

)

Definition at line 28 of file ProxyStatusTask.py.

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

Member Function Documentation

execCriterion()

def dc_db.ProxyStatusTask.ProxyStatusTask.execCriterion (   proxyStatus,   queryCallback,   siteId,   additionWhere = None  )

static

Definition at line 67 of file ProxyStatusTask.py.

  def execCriterion(proxyStatus, queryCallback, siteId, additionWhere=None):
    ret = []
    PROXY_SELECT_TEMPLATE = "SELECT * FROM `sites_proxy`"
    criterionString = app.SQLCriterions.generateCriterionSQL(proxyStatus.criterions, additionWhere, siteId)
    if criterionString is not None and criterionString != "":
      query = PROXY_SELECT_TEMPLATE + criterionString
      res = queryCallback(query, Constants.PRIMARY_DB_ID, Constants.EXEC_NAME)
      if isinstance(res, collections.Iterable):
        ret = res

    return ret

Here is the call graph for this function:

fetchProxy()

def dc_db.ProxyStatusTask.ProxyStatusTask.fetchProxy	(		self,
			localProxy,
			queryCallback
	)

Definition at line 84 of file ProxyStatusTask.py.

  def fetchProxy(self, localProxy, queryCallback):
    ret = None
    if localProxy.siteId is not None and localProxy.host is not None:
      try:
        PROXY_FETCH_TEMPLATE = "SELECT * FROM `sites_proxy` WHERE `Site_Id` = '%s' AND `Host` = '%s'"
        query = PROXY_FETCH_TEMPLATE % (localProxy.siteId, localProxy.host)
        res = queryCallback(query, Constants.PRIMARY_DB_ID, Constants.EXEC_NAME)

        if isinstance(res, collections.Iterable) and len(res) > 0:
          ret = dc.EventObjects.Proxy(res[0]["Site_Id"], res[0]["Host"])
          ret.id = res[0]["Id"]
          ret.domains = res[0]["Domains"]
          ret.priority = res[0]["Priority"]
          ret.state = res[0]["State"]
          ret.countryCode = res[0]["CountryCode"]
          ret.countryName = res[0]["CountryName"]
          ret.regionCode = res[0]["RegionCode"]
          ret.regionName = res[0]["RegionName"]
          ret.cityName = res[0]["CityName"]
          ret.zipCode = res[0]["ZipCode"]
          ret.timeZone = res[0]["TimeZone"]
          ret.latitude = res[0]["Latitude"]
          ret.longitude = res[0]["Longitude"]
          ret.metroCode = res[0]["MetroCode"]
          ret.faults = res[0]["Faults"]
          ret.faultsMax = res[0]["FaultsMax"]
          ret.categoryId = res[0]["Category_Id"]
          ret.limits = res[0]["Limits"]
          ret.description = res[0]["Description"]
          ret.cDate = res[0]["CDate"]
          ret.uDate = res[0]["UDate"]
      except Exception as excp:
        logger.debug(">>> ProxyStatusTask.fetchProxy some exception = " + str(excp))
    return ret

process()

def dc_db.ProxyStatusTask.ProxyStatusTask.process	(		self,
			proxyStatuses,
			queryCallback
	)

Definition at line 37 of file ProxyStatusTask.py.

  def process(self, proxyStatuses, queryCallback):
    proxies = []
    for proxyStatus in proxyStatuses:
      localProxyStatuses = []
      if proxyStatus.siteId is None or proxyStatus.host is None and proxyStatus.criterions is not None:
        result = ProxyStatusTask.execCriterion(proxyStatus, queryCallback, proxyStatus.siteId)
        for elem in result:
          localProxy = copy.deepcopy(proxyStatus)
          # if localProxy.siteId is None:
          localProxy.siteId = elem["Site_Id"]
          # if localProxy.host is None:
          localProxy.host = elem["Host"]
          localProxyStatuses.append(localProxy)
      else:
        localProxyStatuses.append(proxyStatus)
      logger.debug(">>> len(localProxyStatuses) = " + str(len(localProxyStatuses)))
      for localProxy in localProxyStatuses:
        proxy = self.fetchProxy(localProxy, queryCallback)
        if proxy is not None:
          proxies.append(proxy)
    return proxies

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