google-app-engine - 在 golang 中使用 datastore.GetAll 没有得到结果

Question

我有两个函数:一个将实体写入数据存储区，另一个用于检索它们。当我在检索中使用 datastore.GetAll() 函数时，它没有返回任何结果。我确实有一个测试来验证写作似乎工作正常。关于为什么检索不起作用的任何想法？

这是应用程序代码:

package tracker

import (
   "fmt"

   "appengine"
   "appengine/datastore"
)

type User struct {
    Email string
}

func createUser(ctx appengine.Context, email string) (*datastore.Key, error) {
    u := &User{
        Email: email,
        }
    incompleteKey := datastore.NewIncompleteKey(ctx, "User", nil)
    key, err := datastore.Put(ctx, incompleteKey, u)
    if err != nil {
        return key, err
    }

    return key, nil
}

func getUser(ctx appengine.Context, email string) (u *User, e error) {
    users := []User{}
    q := datastore.NewQuery("User").Filter("Email", email)
    keys, err := q.GetAll(ctx, &users)
    if err != nil {
        return nil, err
    }
    fmt.Printf("KEYS: %v", keys)
    return &users[0], nil
}

测试代码如下:

package tracker

import (
    "fmt"
    "testing"

    "appengine/datastore"
    "appengine/aetest"
)

// This test is passing.
func TestCreateUser(t *testing.T) {
    ctx, err := aetest.NewContext(nil)
    if err != nil {
        t.Fatal(err)
    }
    defer ctx.Close()

    email := "testing@testing.go"
    newKey, err := createUser(ctx, email)
    if err != nil {
        t.Errorf("Failed to create a new user: %v", err)
    }

    u := User{}
    datastore.Get(ctx, newKey, &u)

    if u.Email != email {
        t.Errorf("Expected email to be %s, found %v.", email, u.Email)
    }
}

func TestGetUser(t *testing.T) {
    ctx, err := aetest.NewContext(nil)
    if err != nil {
        t.Fatal(err)
    }
    defer ctx.Close()

    email := "testing@testing.go"
    newKey, err := createUser(ctx, email)
    fmt.Printf("key, %v; ", newKey)
    u, err := getUser(ctx, newKey)
    fmt.Printf("user, %v; error: %s", u, err)

    if u.Email != email {
        t.Error("Expected email to be %s, found %v.", email, u.Email)
    }
}

Answer 1

datastore.GetAll() 不会向您返回结果，因为对于该查询应用最终一致性。 SDK 模拟最终一致性，不会立即返回新保存的实体。

但是在您的 TestCreateUser() 方法中，当您使用 datastore.Get() 时，即使它是新的(“刚刚”)，它也会返回给您实体已保存，因为它是通过键查找，并且它们高度一致。

在幕后发生的事情是，当您调用 datastore.Put() 时，实体数据(属性值)被保存并且其键被索引，然后 datastore.Put( ) 返回，并且其他属性和复合索引的索引“在后台”异步更新。因此，如果您尝试执行使用索引查找/列出实体的查询(您通过 Email 属性进行查询)，该查询将不会看到(不会包括)新实体，直到它们正确索引。当您执行 datastore.Get() 时，它通过键而不是其他(非键属性或复合)索引加载实体，因此通过键获取实体将看到新实体“立即”(在 datastore.Put() 返回后)。

如果您想在本地环境中对此进行测试，您可以在创建将用于创建新上下文的实例时提供 StronglyConsistentDatastore 选项，如下所示:

inst, err := aetest.NewInstance(&aetest.Options{StronglyConsistentDatastore: true})
if err != nil {
    t.Fatalf("Failed to create instance: %v", err)
}
defer inst.Close()

req, err := inst.NewRequest("GET", "/", nil)
if err != nil {
    t.Fatalf("Failed to create req: %v", err)
}
ctx := appengine.NewContext(req)

另请注意，如果您使用 sleep (例如 time.Sleep(time.Millisecond * 500))，datastore.GetAll() 也将返回新实体, 但上面的选项是测试它的正确方法。

有很多类似的问题(+答案)，阅读它们以获取更多详细信息:

Google App Engine Datastore - Testing Queries fails

How to filter a GAE query?

Google app engine datastore query with cursor won't iterate all items