mymongodaemon.py 文件源码

def data_munging(self):
        """Reads data from replpication queue and writes to mongo

        See Also:
            :meth:`.replicator`

        """
        self.write_pid(str(os.getpid()))
        if self.setproctitle:
            import setproctitle
            setproctitle.setproctitle('mymongo_datamunging')

        module_instance = ParseData()

        mongo = MyMongoDB(config['mongodb'])
        munging = DataMunging(mongo, self.queues['replicator_out'])
        munging.run(module_instance)