0

我正在使用 python 开发一个 GAE 应用程序,我希望它同时服务请求。为此,我将threadsafe设置为true。我在请求处理程序中定义了两种方法:

POST - 将拉取任务排入队列以异步执行,稍后将自己将拉取任务排入队列作为响应:

def post(self):
    message = self.request.body
    taskqueue.add(url='/process', params={'message': message}) #this task will enqueue a pull task as a response

GET - 轮询拉取任务队列以获取响应,直到有可用的响应(我知道我应该找到一种方法来改进该循环,但我只是在尝试):

def get(self):
    (...)
    tasks = queue.lease_tasks_by_tag(1, 100, tag)
    while tasks.__len__() == 0:
        time.sleep(1)
        tasks = queue.lease_tasks_by_tag(1, 100, tag) 

客户端应用程序调用 POST,然后调用 GET。我在 POST 方法排队的任务上放置了一个断点,但是当请求处理程序卡在循环中时,它永远不会被调用。我认为应用程序应该有多个线程为请求提供服务,那么它为什么不同时执行推送请求处理程序呢?我很感激这方面的任何帮助。

4

1 回答 1

1

我怀疑您从开发服务器看到了问题中描述的行为,该服务器一次不能提供多个请求。因此,当您将断点放在 POST 方法中时,开发服务器实际上会暂停。要按预期查看此行为,请上传到 App Engine。

此外,不要使用 GET HTTP 请求进行轮询,而是尝试使用 App Engines Channel API。使用它,您可以直接从任务队列处理程序将响应推送回客户端,以通知该过程已完成(或其他)。

于 2012-11-25T16:22:34.920 回答