为什么我的 Google App Engine Mail API 调用仍然会导致 DeadlineExceededError，尽管将它们放入任务队列中？

Question

我有一个 Python 函数，它为我的邮件列表中的每个电子邮件地址添加一个任务队列（每次邮寄数千个）。问题是，即使每封邮件都是通过任务队列中的执行发送的，我仍然收到这个可怕的错误：

DeadlineExceededError：API 调用 mail.Send() 花了太长时间来响应并被取消。< /code>

有什么解决办法吗？

Answer 1

截止时间发生在 GAE 实例与处理 mail.Send 调用的 RPC 服务器之间的通信期间。反过来，这可能表明 GAE 存在内部问题或（更有可能）无法及时与 SMTP 服务器通信。

后者在概念上与 URLFetch 调用的截止时间非常相似。但是，可以为 URLFetch 设置自定义截止时间，这在很大程度上缓解了该问题。

不幸的是，没有关于 Mail API 的类比记录。不过，有一个解决方法，即提供您自己的 make_sync_call 方法（该方法允许更宽松的截止日期）作为 EmailMessage.send() 的参数。要生成这样的方法，您需要深入研究用于进行 GAE RPC 调用的 Python 接口的内部结构。我发现可行的解决方案如下所示：

from google.appengine.api import apiproxy_stub_map
from google.appengine.api.apiproxy_stub_map import APIProxyStubMap

class TimeoutAPIStub( object ):
    def __init__( self, service, deadline = 25 ):
        self.service = service
        self.deadline = deadline

    def CreateRPC( self ):
        rpc = apiproxy_stub_map.CreateRPC( self.service )
        rpc.deadline = self.deadline
        return rpc

def create_MakeSyncCall( service, deadline = 25 ):
    apsm = APIProxyStubMap()
    apsm.RegisterStub( service, TimeoutAPIStub( service, deadline ) )
    return apsm.MakeSyncCall

然后，您可以使用它来提供自定义截止日期，生成的 make_sync_call 方法将遵守该截止日期：

msg = EmailMessage()
# ... prepare your email ...
msg.send(make_sync_call = create_MakeSyncCall('mail', deadline = 300))

如果您想了解更多有关 GAE 幕后发生的事情RPC 调用，我建议阅读 Nick Johnson 的博客文章它。如果您想要通过 Python 的 GAE RPC 绑定来解决类似问题，那么这是一个很好的起点。