每次使用应用程序引擎中的数据存储时超时

Question

我第一次使用谷歌云环境，特别是谷歌应用程序引擎和数据存储，当我在本地运行时，一切都很好。我正在通过根据文档设置环境变量GOOGLE\u APPLICATION\u凭据来验证数据存储。但一旦我部署到应用程序引擎，请求总是超时，似乎GetAll方法永远不会返回。以下是我的应用程序代码：

package app

import (
    "fmt"
    "net/http"
    "time"
    "golang.org/x/net/context"
    "google.golang.org/appengine"
    "google.golang.org/cloud/datastore"
)

type User struct {
    FirstName string
    LastName string
    Email string
    Created time.Time
    id      int64
}

func init() {
    http.HandleFunc("/", handler)
}

func handler(w http.ResponseWriter, r *http.Request) {
    var err error
    var dbClient *datastore.Client
    var ctx context.Context

    ctx = appengine.NewContext(r)

    dbClient, err = datastore.NewClient(ctx, "app-id")//this has the real app id, not sure if this is meant to be secret
    if err != nil {
        fmt.Fprintf(w, "Could not create datastore client: %+v", err)
        return
    }
    defer dbClient.Close()

    var users []*User

    query := datastore.NewQuery("User").Filter("Email=", "[e-mail]")
    keys, err := dbClient.GetAll(ctx, query, &users)
    if err != nil {
        fmt.Fprintf(w, "Could not query users: %+v", err)
        return
    }

    for i, key := range keys {
        users[i].id = key.ID()
        fmt.Fprintf(w, "%+v\n",users[i])
    }
    fmt.Fprintf(w, "done!!!")
}

应用程序引擎日志中的错误有以下两行：

This request caused a new process to be started for your application, and thus caused your application code to be loaded for the first time. This request may thus take longer and use more CPU than a typical request for your application.

Process terminated because the request deadline was exceeded. (Error code 123)

顺便说一句，这在我的本地服务器上以闪电般的速度完成，并且我的数据存储中只有一条记录。猜测一下为什么会发生这种情况，或者如何调试它？谢谢

Answer 1

我的问题的解决方案是切换数据存储库

发件人：google.golang.org/cloud/datastore

到："google.golang.org/appengine/datastore"

appengine/datastore似乎使用了不同的协议，因此您不必使用GOOGLE\u APPLICATION\u CREDENTIALS环境变量进行身份验证。在本地使用时，它将为不同的应用引擎服务使用dev服务器，在部署时，将为云资源使用dev服务器。

Answer 2

数据存储包使用gRPC连接到数据存储服务。您不能在应用程序引擎上直接使用此选项，因为您不能直接建立TCP连接。

您需要使用套接字API为您制作传输控制协议：

import "google.golang.org/appengine/socket" // et al

ctx := appengine.NewContext(r)
ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
defer cancel()

dialer := func(addr string, timeout time.Duration) (net.Conn, error) {
    return socket.DialTimeout(ctx, "tcp", addr, timeout)
}

client, err := datastore.NewClient(ctx, "app-id", cloud.WithGRPCDialOption(grpc.WithDialer(dialer)))

您还可以在调试时直接调用拨号程序，以确保它能够访问数据存储。googleapis。通讯：443，如预期：

conn, err := dialer("datastore.googleapis.com:443", 5*time.Second)
if err != nil {
    log.Errorf(ctx, "Dial: %v", err)
    http.Error(w, "Dial failed: "+err.Error(), http.StatusInternalServerError)
    return
}
fmt.Fprintf(w, "Addr: %v\n", conn.RemoteAddr())
conn.Close()