mongo_base.py 文件源码

def stream_events(self, inputs, ew):
        for input_name, input_item in inputs.inputs.iteritems():
            host = input_item["server"]
            port = input_item["port"]
            if not port is None:
                port = int(port)
            client = pymongo.MongoClient(host, port)
            self.stream_events_mongo(input_name, input_item, client, ew)