get_result() 是 Google App Engine 中 put_async() 所需的调用吗

Question

随着 GAE 1.5.0 的新版本，我们现在有了一种简单的方法来执行异步数据存储调用。调用后是否需要调用get_result() “put_async”？

例如，如果我有一个名为 MyLogData 的模型，我可以

put_async(MyLogData(text="My Text"))

在处理程序返回之前调用：而不调用匹配的 get_result() 吗？ 在将结果发送给客户端之前，GAE 是否会自动阻止任何待处理的调用？

请注意，我并不真正关心处理错误情况。也就是说，我不介意其中一些看跌期权是否失败。

Answer 1

我认为没有任何确定的方法可以知道是否需要 get_result() ，除非 GAE 团队中的某人验证了这一点，但我认为不需要。这是我测试的方法。

我编写了一个简单的处理程序：

class DB_TempTestModel(db.Model):
    data = db.BlobProperty()

class MyHandler(webapp.RequestHandler):
    def get(self):
        starttime = datetime.datetime.now()
        lots_of_data = ' '*500000
        if self.request.get('a') == '1':
            db.put(DB_TempTestModel(data=lots_of_data))
            db.put(DB_TempTestModel(data=lots_of_data))
            db.put(DB_TempTestModel(data=lots_of_data))
            db.put(DB_TempTestModel(data=lots_of_data))
        if self.request.get('a') == '2':
            db.put_async(DB_TempTestModel(data=lots_of_data))
            db.put_async(DB_TempTestModel(data=lots_of_data))
            db.put_async(DB_TempTestModel(data=lots_of_data))
            db.put_async(DB_TempTestModel(data=lots_of_data))
        self.response.out.write(str(datetime.datetime.now()-starttime))

我在高复制应用程序上运行了很多次。

数据总是在那里，让我相信除非数据存储方面出现故障（不太可能），否则它会被写入。

这是有趣的部分。当使用 put_async() (?a=2) 写入数据时，（处理请求）的时间量平均大约快 2 到 3 倍如 put()(?a=1) （不是一个非常科学的测试 - 只是目测它）。

但 ?a=1 和 ?a=2 的 cpu_ms 和 api_cpu_ms 是相同的。

从日志中：

ms=440 cpu_ms=627 api_cpu_ms=580 cpm_usd=0.036244

与

ms=149 cpu_ms=627 api_cpu_ms=580 cpm_usd=0.036244

在客户端，查看请求的网络延迟，它显示了相同的结果，即“?a=2”请求至少快了 2 倍。绝对是客户端的胜利......但它似乎在服务器端没有任何增益。

GAE 团队中有人愿意发表评论吗？

Answer 2

db.put_async 在没有 get_result 部署时（以“即发即弃”风格）的情况下工作正常，但在 本地，在调用 get_result 不会采取任何操作="https://stackoverflow.com/questions/7244081/appengine-put-async-doesnt-work-at-least-in-the-development-server/7250613#7250613">更多上下文

Answer 3

我不知道，但这可行：

import datetime
from google.appengine.api import urlfetch

def main():
  rpc = urlfetch.create_rpc()
  urlfetch.make_fetch_call(rpc, "some://artificially/slow.url")
  print "Content-type: text/plain"
  print
  print str(datetime.datetime.now())

if __name__ == '__main__':
  main()

远程 URL 休眠 3 秒，然后向我发送一封电子邮件。 App Engine 处理程序立即返回，并且远程 URL 按预期完成。由于这两种服务都抽象了相同的底层 RPC 框架，因此我猜测数据存储的行为类似。

不过，这是个好问题。也许尼克或另一位谷歌员工可以给出明确的答案。