sflowtool.py 文件源码

def probe(self):
        self.log.debug("stdout queue %d" % self.stdout_queue.qsize())
        if not self.stdout_queue.qsize():
            return {}

        data = []
        try:
        # OPT skip_fields
            while True:
                line = self.stdout_queue.get_nowait()
                data.append(line)

        except gevent.queue.Empty as e:
            pass

        msg = {}
        msg['data'] = data
        msg['ts'] = (datetime.datetime.utcnow() - datetime.datetime(1970, 1, 1)).total_seconds()
        return msg