在 golang 中使用 datastore.GetAll 没有得到结果

Question

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

申请代码如下：

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() 不会给您 return 结果，因为对于该查询 最终一致性适用 。 SDK 模拟最终一致性，不会 return 您立即获得新保存的实体。

但是在您的 TestCreateUser() 方法中，当您使用 datastore.Get() 时，即使它是新（"just now"）保存的，也会 return 您的实体，因为它是一键查找，强一致.

幕后发生的事情是，当您调用 datastore.Put() 时，实体数据（属性值）被保存并且其键被索引，然后 datastore.Put() returns，其他属性和综合索引的索引是异步更新的 "in the background"。因此，如果您尝试执行使用 find/list 实体索引的查询（您通过 Email 属性进行查询），该查询将不会看到（不会包括）新实体，直到它们已正确编入索引。当您执行 datastore.Get() 时，它通过其键而不是其他（非键属性或复合）索引加载实体，因此通过键获取实体将看到新实体 "immediately"（在 datastore.Put() 编辑 return 之后）。

如果您想在本地环境中进行测试，您可以在创建将用于创建新上下文的实例时提供 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)

另请注意，如果您使用睡眠（例如 time.Sleep(time.Millisecond * 500)），datastore.GetAll() 也将 return 新实体，但上述选项是测试它的正确方法。

有很多类似的问题（+答案），阅读它们了解更多详情：

在 golang 中使用 datastore.GetAll 没有得到结果

Not getting results with datastore.GetAll in golang

testing

google-app-engine

go

google-cloud-datastore