mrt_table_dump.py 文件源码

def __init__(self, cfg, log_queue):
        """ Constructor

            :param cfg:               Configuration dictionary
            :param log_queue:         Logging queue - sync logging
        """
        multiprocessing.Process.__init__(self)
        self._stop = multiprocessing.Event()

        self._thr_list = {}
        self._db_conn = None
        self._cfg = cfg
        self._log_queue = log_queue
        self.LOG = None

        self._interval = int(cfg['table_dump']['interval']['minutes'])
        if self._interval < 15:
            self._interval = 900    # to seconds
        else:
            self._interval *= 60    # to seconds