analyse.py 文件源码

def reducer(self, key, values):
        if key == 'latencies':
            values = list(values)
            yield 'average_latency', numpy.average(values)
            yield 'median_latency', numpy.median(values)
            yield '95th_percentile_latency', numpy.percentile(values, 95)
        elif key == 'sent':
            first, last, count = minmax(values)
            yield 'count', count
            yield 'sending_first', first
            yield 'sending_last', last
            yield 'sending_overhead', (last - first) / (count - 1)
            yield 'sending_throughput', (count - 1) / (last - first)
        elif key == 'received':
            first, last, count = minmax(values)
            yield 'receiving_first', first
            yield 'receiving_last', last
            yield 'receiving_overhead', (last - first) / (count - 1)
            yield 'receiving_throughput', (count - 1) / (last - first)