在Tornado web服务器中正确使用协程

Question

我试图将一个简单的同步服务器转换为异步版本，服务器收到post requestes并从外部web服务（亚马逊sqs）获取响应。这里的syncronous代码

def post(self): 

    zoom_level = self.get_argument('zoom_level') 
    neLat = self.get_argument('neLat') 
    neLon = self.get_argument('neLon') 
    swLat = self.get_argument('swLat') 
    swLon = self.get_argument('swLon') 
    data = self._create_request_message(zoom_level, neLat, neLon, swLat, swLon) 

    self._send_parking_spots_request(data) 

    #....other stuff 

def _send_parking_spots_request(self, data): 

    msg = Message() 
    msg.set_body(json.dumps(data)) 
    self._sqs_send_queue.write(msg) 

阅读旋风文档和这里的一些线程我使用协同程序使用此代码结束：

def post(self): 

    zoom_level = self.get_argument('zoom_level') 
    neLat = self.get_argument('neLat') 
    neLon = self.get_argument('neLon') 
    swLat = self.get_argument('swLat') 
    swLon = self.get_argument('swLon') 
    data = self._create_request_message(zoom_level, neLat, neLon, swLat, swLon) 
    self._send_parking_spots_request(data) 
    self.finish() 

@gen.coroutine 
def _send_parking_spots_request(self, data): 

    msg = Message() 
    msg.set_body(json.dumps(data)) 
    yield gen.Task(write_msg, self._sqs_send_queue, msg) 

def write_msg(queue, msg, callback=None): 
    queue.write(msg) 

使用攻城相比演出我得到的第二个版本是比原来更差一个，所以可能有一些关于协程和Torndado异步编程的东西，我根本不懂。 你能帮我解决这个问题吗？

编辑：self._sqs_send_queue它是从伯特接口和queue.write(msg)检索队列对象返回已写入队列

Answer 1

tornado依赖于你将所有的I/O是非阻塞的消息。只需在gen.Task之前使用与之前使用的代码相同的代码，根本不会提高性能，因为I/O本身仍然会阻止事件循环。此外，您需要将post方法作为协程，并使用yield调用_send_parking_spots_requests，以使代码正常运行。所以，一个“正确”的解决方案将是这个样子：

@gen.coroutine 
def post(self): 
    ... 
    yield self._send_parking_spots_request(data) # wait (without blocking the event loop) until the method is done 
    self.finish() 

@gen.coroutine 
def _send_parking_spots_request(self, data): 

    msg = Message() 
    msg.set_body(json.dumps(data)) 
    yield gen.Task(write_msg, self._sqs_send_queue, msg) 

def write_msg(queue, msg, callback=None): 
    yield queue.write(msg, callback=callback) # This has to do non-blocking I/O. 

在这个例子中，queue.write将需要一些API发送使用您的要求非阻塞I/O，当一个反应是执行callback接收。如果不知道原始示例中的queue究竟是什么，我无法详细说明如何在您的案例中实施。

编辑：假设你正在使用boto，你可能想看看bototornado，它实现the exact same API I described above：

def write(self, message, callback=None): 
    """ 
    Add a single message to the queue. 
    :type message: Message 
    :param message: The message to be written to the queue 
    :rtype: :class:`boto.sqs.message.Message` 
    :return: The :class:`boto.sqs.message.Message` object that was written.