executor.py 文件源码

def __init__(self, collection=None, **kwargs):
        self.logger = logging.getLogger('executor')
        self.logger.setLevel(logging.INFO)
        self.sche = sched.scheduler(time.time, time.sleep)
        self.sessions_queue = {} # {ID: {delay: cmd, delay2: cmd2, ....}}
        self.setCollection(collection)
        self.reset_prof = kwargs.get('reset_profiling', False)
        self.profile_size = int(kwargs.get('profile_size', 1)) # 1 MB by default
        self.drop_coll = kwargs.get('drop_collection', False)
        self.creat_coll = kwargs.get('create_collection', True)
        self.bins = int(kwargs.get('bins', 20))
        self.time_scale_factor = float(kwargs.get('time_scale_factor', 1.0))
        self.histtype = kwargs.get('histtype', 'step')
        self.exec_time_cache = {} # for display execution result
        self.type_cache = { # caching for display
            'find' : [], # [ID(str), ...]
            'insert' : [],
            'update' : [],
            'delete' : []
        }