scheduler.py 文件源码

def main():
    redis_connection = StrictRedis(
        host=ENV_DICT.get('REDIS_HOST', 'localhost'),
        port=ENV_DICT.get('REDIS_PORT', 6379),
        db=ENV_DICT.get('REDIS_DB', 0),
        password=ENV_DICT.get('REDIS_PASSWORD')
    )
    interval = ENV_DICT.get('RQ_SCHEDULER_POLLING_INTERVAL', 60)
    verbose = ENV_DICT.get('RQ_SCHEDULER_VERBOSE_OUTPUT', False)
    burst = ENV_DICT.get('RQ_SCHEDULER_BURST_MODE', False)

    if verbose:
        log_level = 'DEBUG'
    else:
        log_level = 'INFO'
    setup_loghandlers(log_level)

    scheduler = Scheduler(connection=redis_connection, interval=interval)
    scheduler.run(burst=burst)