如何在处理程序中对龙卷风处理程序进行基准测试？

Question

我编写了一个非常简单的tornado处理程序，用于测试远程部署的一些设备的上传速度。主要测试将在所说的远程设备上运行（多亏了cURL），我可以得到上传时间的详细报告。

Tornado处理程序真正要做的唯一一件事就是接受一个包含大量字节的实体（差不多就是这样）

class TestUploadHandler(tornado.web.RequestHandler):
   def post(self):
        logging.debug("Testing upload")
        self.write("")

所以，上面的代码是有效的，但它有点。。。几乎是可耻的：-D让它更。。。可展示的，我想展示一些更有用的日志，比如请求上传所花的时间或者类似的东西。我不知道。。。稍微多汁一点的。

有没有办法测量龙卷风处理器本身的上传速度？我已经谷歌了如何测试龙卷风处理器，但是我似乎只能找到不同网络服务器之间的性能比较。

先谢谢你。

Answer 1

嗯，上传本身需要多长时间很简单：

import time

class TestUploadHandler(tornado.web.RequestHandler):
   def post(self):
        logging.debug("Testing upload")
        start = time.time()
        self.write({})
        end = time.time()
        print "Time to write was {} seconds.".format(end-start)

如果要在多个处理程序中使用定时代码，还可以将其移动到装饰器：

from functools import wrap
import time

def timer(func):
    @wraps(func)
    def wrapper(*args, **kwargs):
        start  = time.time()
        ret = func(*args, **kwargs)
        end = time.time()
        print 'Function took {} seconds'.format(end-start)
        return ret 
    return wrapper

class TestUploadHandler(tornado.web.RequestHandler):
   @timer
   def post(self):
        logging.debug("Testing upload")
        self.write({})

编辑：

考虑到您试图从服务器的角度衡量上传到服务器需要多长时间，上述方法是行不通的。看来你能用tornado最接近的方法就是使用@tornado。网状物stream_request_bodydecorator，以便将请求正文作为流接收：

@tornado.web.stream_request_body
class ValueHandler(tornado.web.RequestHandler):
    def initialize(self):
        self.start = None

    def post(self):
        end = time.time()
        print self.request
        if self.start:
            print("Upload time %s" % end-self.start)
        self.write({})

    def data_received(self, data):
        if not self.start:
            self.start = time.time()

当收到请求主体的第一块时，我们将时间保存（作为self.start）。post方法将在收到完整的正文后被调用，因此我们得到end。

不过，我在大文件上传时遇到了问题。不过，它似乎对小文件（100MB以下）工作正常。