normalizer.py 文件源码

def __init__(self, database, ignore_rfc1918=True):
        self.normalizers = {}
        #injected instance of database.Database
        self.database = database
        self.enabled = True
        self.ignore_rfc1918 = ignore_rfc1918

        #max number of concurrent mongodb inserters
        self.worker_pool = Pool(5)

        #map normalizers
        for n in basenormalizer.BaseNormalizer.__subclasses__():
            normalizer = n()
            for channel in normalizer.channels:
                if channel in self.normalizers:
                    raise Exception('Only one normalizer for each channel allowed (%s).'.format(channel))
                else:
                    self.normalizers[channel] = normalizer