dc_db.StatisticLogManager.StatisticLogManager Class Reference

Inheritance diagram for dc_db.StatisticLogManager.StatisticLogManager:

Collaboration diagram for dc_db.StatisticLogManager.StatisticLogManager:

Static Public Member Functions
def	isStatisticEnabled (queryCallback, siteId, defValue, propName)
def	addNewRecord (queryCallback, siteId, URLMd5)
def	statisticUpdate (queryCallback, freqName, addValue, siteId, URLMd5)
def	logUpdate (queryCallback, opName, logObject, siteId, URLMd5, opDate="NOW()")

Static Public Attributes
string	SITE_PROP_NAME_FREQ = "STATS_FREQ_ENABLED"
string	SITE_PROP_NAME_LOG = "STATS_LOG_ENABLED"
bool	GLOBAL_FREQ_ENABLED = False
bool	GLOBAL_LOG_ENABLED = False

Detailed Description

Definition at line 17 of file StatisticLogManager.py.

Member Function Documentation

addNewRecord()

def dc_db.StatisticLogManager.StatisticLogManager.addNewRecord (   queryCallback,   siteId,   URLMd5  )

static

Definition at line 45 of file StatisticLogManager.py.

  def addNewRecord(queryCallback, siteId, URLMd5):
    if queryCallback is not None:
      SQL_INSERT_TEMPLAE = "INSERT IGNORE INTO `%s` SET `URLMd5`= '%s'"
      if StatisticLogManager.isStatisticEnabled(queryCallback, siteId, StatisticLogManager.GLOBAL_FREQ_ENABLED,
                                                StatisticLogManager.SITE_PROP_NAME_FREQ):
        tbName = Constants.DC_FREQ_TABLE_NAME_TEMPLATE % siteId
        query = SQL_INSERT_TEMPLAE % (tbName, URLMd5)
        queryCallback(query, Constants.STAT_DB_ID)
      else:
        logger.debug(">>> Statistic Freq Disabled, SiteId=" + siteId)
    else:
      logger.error(">>> addNewRecord error, queryCallback is None")

isStatisticEnabled()

def dc_db.StatisticLogManager.StatisticLogManager.isStatisticEnabled (   queryCallback,   siteId,   defValue,   propName  )

static

Definition at line 30 of file StatisticLogManager.py.

  def isStatisticEnabled(queryCallback, siteId, defValue, propName):
    from dc_db.BaseTask import BaseTask
    ret = defValue
    tempValue = BaseTask.readValueFromSiteProp(siteId, propName, queryCallback)
    if tempValue is not None:
      ret = bool(int(tempValue))
    return ret

logUpdate()

def dc_db.StatisticLogManager.StatisticLogManager.logUpdate (   queryCallback,   opName,   logObject,   siteId,   URLMd5,   opDate = "NOW()"  )

static

Definition at line 93 of file StatisticLogManager.py.

  def logUpdate(queryCallback, opName, logObject, siteId, URLMd5, opDate="NOW()"):    if StatisticLogManager.isStatisticEnabled(queryCallback, siteId, StatisticLogManager.GLOBAL_LOG_ENABLED,
                                              StatisticLogManager.SITE_PROP_NAME_LOG):
      if queryCallback is not None:
        if opName in Constants.logOperationsDict:
          LOG_INSERT_SQL_TEMPLATE = "INSERT INTO `%s` SET `URLMd5`='%s', `OpCode`=%s, `Object`='%s', `ODate`=%s"
          tbName = Constants.DC_LOG_TABLE_NAME_TEMPLATE % siteId
          objectStr = ""
          if logObject is not None:
            try:
              objectStr = logObject.toJSON()
#               objectStr = MySQLdb.escape_string(objectStr)
              objectStr = Utils.escape(objectStr)
            except Exception as ex:
              logger.debug(">>> logUpdate Object to JSON error = " + str(ex))
          if opDate != "NOW()":
            opDate = ("'" + opDate + "'")
          query = LOG_INSERT_SQL_TEMPLATE % (tbName, URLMd5, str(Constants.logOperationsDict[opName]), objectStr,
                                             opDate)
          queryCallback(query, Constants.LOG_DB_ID)
        else:
          logger.error(">>> logUpdate error = " + str(opName) + " Log field not support !")
      else:
        logger.error(">>> logUpdate error, queryCallback is None")
    else:
      logger.debug(">>> Statistic Log Disabled, SiteId=" + siteId)

statisticUpdate()

def dc_db.StatisticLogManager.StatisticLogManager.statisticUpdate (   queryCallback,   freqName,   addValue,   siteId,   URLMd5  )

static

Definition at line 67 of file StatisticLogManager.py.

  def statisticUpdate(queryCallback, freqName, addValue, siteId, URLMd5):
    if StatisticLogManager.isStatisticEnabled(queryCallback, siteId, StatisticLogManager.GLOBAL_FREQ_ENABLED,
                                              StatisticLogManager.SITE_PROP_NAME_FREQ):
      if queryCallback is not None:
        if freqName in Constants.StatFreqConstants.__dict__.values():
          FREQ_UPDATE_SQL_TEMPLATE = "UPDATE `%s` SET `%s`=`%s`+%s, `MDate`=NOW() WHERE `URLMd5`='%s'"
          tbName = Constants.DC_FREQ_TABLE_NAME_TEMPLATE % siteId
          query = FREQ_UPDATE_SQL_TEMPLATE % (tbName, freqName, freqName, str(addValue), URLMd5)
          queryCallback(query, Constants.STAT_DB_ID)
        else:
          logger.error(">>> statisticUpdate error = " + str(freqName) + " Statistic Freq field not support !")
      else:
        logger.error(">>> statisticUpdate error, queryCallback is None")
    else:
      logger.debug(">>> Statistic Freq Disabled, SiteId=" + siteId)

Here is the caller graph for this function:

Member Data Documentation

GLOBAL_FREQ_ENABLED

bool dc_db.StatisticLogManager.StatisticLogManager.GLOBAL_FREQ_ENABLED = False

static

Definition at line 21 of file StatisticLogManager.py.

GLOBAL_LOG_ENABLED

bool dc_db.StatisticLogManager.StatisticLogManager.GLOBAL_LOG_ENABLED = False

static

Definition at line 22 of file StatisticLogManager.py.

SITE_PROP_NAME_FREQ

string dc_db.StatisticLogManager.StatisticLogManager.SITE_PROP_NAME_FREQ = "STATS_FREQ_ENABLED"

static

Definition at line 19 of file StatisticLogManager.py.

SITE_PROP_NAME_LOG

string dc_db.StatisticLogManager.StatisticLogManager.SITE_PROP_NAME_LOG = "STATS_LOG_ENABLED"

static

Definition at line 20 of file StatisticLogManager.py.

---

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

• sources/hce/dc_db/StatisticLogManager.py