Functions
def	getLogger ()

def	getFileLogger ()

def	executeCommand (cmd, inputStream=None, log=None)

def	generateBatch (id=0)

def	generateInputStream (id=0)

def	test (id=0, log=None)

def	threadRun (id=0, log=None)

Variables
def	logger = getLogger()

int	testCount = 5

list	threadsList = []

Function Documentation

◆ executeCommand()

def ftests.ftest_PostprocessorTask.executeCommand	(	cmd,
		inputStream = `None`,
		log = `None`
	)

Definition at line 76 of file ftest_PostprocessorTask.py.

 def executeCommand(cmd, inputStream=None, log=None):
   if log is not None:
     log.debug("Popen: %s", str(cmd))
   process = Popen(cmd, stdout=PIPE, stdin=PIPE, stderr=PIPE, shell=True, close_fds=True)
   if isinstance(inputStream, basestring) and log is not None:
     log.debug("process.communicate(), len(inputStream)=" + str(len(inputStream)))
   (output, err) = process.communicate(input=inputStream)
   if log is not None:
     log.debug("Process std_error: %s", str(err))
     log.debug("Process output len =" + str(len(output)))
   exitCode = process.wait()
   if log is not None:
     log.debug("Process response exitCode: %s", str(exitCode))
 
   return output, exitCode
 
 

Here is the caller graph for this function:

◆ generateBatch()

def ftests.ftest_PostprocessorTask.generateBatch ( id = 0 )

Definition at line 93 of file ftest_PostprocessorTask.py.

 def generateBatch(id=0):
   siteId = id
   url = 'https://retrip.jp/external-link/?article_content_id=482406'
   urlObj = URL(siteId, url)
 
   processedContent = {'link':url}
   processedContents = [base64.b64encode(json.dumps(processedContent))]
   urlContentResponse = URLContentResponse(url=url, processedContents=processedContents)
 
   batchItem = BatchItem(siteId=siteId, urlId=urlObj.urlMd5, urlObj=urlObj, urlContentResponse=urlContentResponse)
   batchItem.properties = {"LINK_RESOLVE":{"method":{"retrip.jp/external-link":"GET"}}}
   # batchItem.properties = {}
   return Batch(id, batchItems=[batchItem])
 
 

Here is the caller graph for this function:

◆ generateInputStream()

def ftests.ftest_PostprocessorTask.generateInputStream ( id = 0 )

Definition at line 108 of file ftest_PostprocessorTask.py.

 def generateInputStream(id=0):
   return pickle.dumps(generateBatch(id=0))

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getFileLogger()

def ftests.ftest_PostprocessorTask.getFileLogger ( )

Definition at line 54 of file ftest_PostprocessorTask.py.

 def getFileLogger():
 
   configName = '../ini/postprocessor_task_log-rt.ini'
 
   retval = os.getcwd()
   os.chdir('..')
   # read config
   logging.config.fileConfig(configName)
 
   # create logger
   log = Utils.MPLogger().getLogger()
   # log = logging.getLogger(APP_CONSTS.LOGGER_NAME)
   os.chdir(retval)
 
   return log
 
 
 # # execute command line command
 #
 # @param cmd - command line string
 # @param inputStream - input stream to popen
 # @return result object of execution and exit code

Here is the call graph for this function:

◆ getLogger()

def ftests.ftest_PostprocessorTask.getLogger ( )

Definition at line 32 of file ftest_PostprocessorTask.py.

 def getLogger():
 
   # create logger
   logger = logging.getLogger('console')
   logger.setLevel(logging.DEBUG)
 
   # create console handler and set level to debug
   ch = logging.StreamHandler()
   ch.setLevel(logging.DEBUG)
 
   # create formatter
   formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
 
   # add formatter to ch
   ch.setFormatter(formatter)
 
   # add ch to logger
   logger.addHandler(ch)
 
   return logger
 
 

Here is the caller graph for this function:

◆ test()

def ftests.ftest_PostprocessorTask.test	(	id = `0`,
		log = `None`
	)

Definition at line 112 of file ftest_PostprocessorTask.py.

 def test(id=0, log=None):
 
   inputFile = '/tmp/input.tmp'
   outputFile = '/tmp/output.tmp'
 
   cmd = "cd ..; ../bin/postprocessor_task.py --config=../ini/postprocessor_task-rt.ini --inputFile=%s > %s" % (str(inputFile), str(outputFile))
 
   f = open(inputFile, 'w')
   f.write(generateInputStream())
   f.close()
 
   output, exitCode = executeCommand(cmd, log=log)
 
   if log is not None:
     log.debug("len(output) = %s", str(len(output)))
     log.debug("exitCode: %s", str(exitCode))
     log.debug("===Finish===")
 
 

Here is the call graph for this function:

Here is the caller graph for this function:

◆ threadRun()

def ftests.ftest_PostprocessorTask.threadRun	(	id = `0`,
		log = `None`
	)

Definition at line 131 of file ftest_PostprocessorTask.py.

 def threadRun(id=0, log=None):
 
   sys.stdout.write("Thread ID = %s started.\n" % str(id))
 
   test(id=id, log=log)
 
   sys.stdout.write("Thread ID = %s stopped.\n" % str(id))