[DEFAULT]
#当收到kill信号后,几秒后干掉worker
graceful_timeout        = 3
#应用的环境变量
base_path               = . 
#日志根目录
log_path                = .
#是否支持多实例
single_instance         = false
[jobexecute]
#是否需要扔到后端
daemonize               = true
#进程名字
proc_name               = jobexecute
#Master主进程PID
pidfile                 = %(base_path)s/master.pid
#日志位置
log_file                = %(log_path)s/master.log
#最大的请求数,也可以理解为是调用测试
max_requests            = 10000
#启动的进程数目,每个进程都是一个实例
number_workers          = 2

pip install requirement.txt

# coding=utf-8
import time
import logging
import traceback
from ProcessHandler.lib.log import setup_file_logging
from ProcessHandler.lib.workers.sync import SyncWorker
class JobExecute(SyncWorker):
    LOGGER_NAME = "jobexecute"
    def __init__(self, cfg, file_logger=None, ppid=None, sockets=None):
        SyncWorker.__init__(self, cfg, file_logger, ppid)
        setup_file_logging(self.LOGGER_NAME, self.cfg.log_file)
        self.logger = logging.getLogger(self.LOGGER_NAME)
    def setup(self):
        super(JobExecute, self).setup()
    def init_process(self):
        super(JobExecute, self).init_process()
    def stop(self):
        super(JobExecute, self).stop()
    def handle_request(self):
        while 1:
            print 'go....'
            logger.info('go...')
            time.sleep(1.5)
if __name__ == '__main__':
    pass