idning

import threading
import os
import time
import commands
import redis

class RedisServer(threading.Thread):
    def __init__(self, binary = 'redis-server', port = 7777):
        threading.Thread.__init__(self)
        self.binary = binary

idning

import threading
import os
import time
import commands
import redis

class RedisServer(threading.Thread):
    def __init__(self, binary = 'redis-server', port = 7777):
        threading.Thread.__init__(self)
        self.binary = binary

idning

        #3. Pre-Splitting
        # export_size > 64K(records) and no data in dest collection
        chunksize = self.args.chunksize # default 64K items (for 64MBytes chunksize)
        maxshardkey = self.args.maxshardkey 

        if not(self.pre_src_count > chunksize and self.pre_to_count == 0):
            logging.info('we will not pre-split !')
            return 

        logging.info('we will pre-split by chunksize: %d, maxshardkey is: %d' % (chunksize, maxshardkey))

idning

import os
import logging

import pybcs

#设置日志级别
pybcs.init_logging(logging.INFO)


AK = os.environ['AK']           #请改为你的AK