rmq_sub.py 文件源码

def get_stats(self):
        process = psutil.Process()
        self.run_data['stats']['net']['end'] = psutil.net_io_counters()
        self.run_data['stats']['cpu']['end'] = process.cpu_times()
        self.run_data['stats']['mem']['end'] = process.memory_info()
        duration = self.run_data['last_msg_time'] - self.run_data['first_msg_time']
        if duration == 0:
            self.run_data['rate'] = 0
        else:
            self.run_data['rate'] = self.run_data['msg_cnt'] / duration

        return ('ok', self.run_data)