我正在尝试测试一个函数，该函数应该从数据存储中获取某种特定类型的所有对象。

在测试中，我似乎必须插休眠眠以使查询找到所有已保存的项目。

下面的代码是一个可重现的例子。第一个日志跟踪来自 sleep 行被注释掉的时间，第二个日志跟踪来自 sleep 未被注释的时间。注意长度:0和长度:3

我假设这是一个最终的一致性问题，如果我持久化多个对象并立即查询它们，就会在生产中出现。但在生产中，这些项目在很久以前就被保留了下来。由于这种情况只出现在我的测试中，我是否打算做些什么来强制数据存储区等到它完全保存项目后再继续？

我尝试将测试保存包装在事务中，但出现“事务中只允许祖先查询”错误。

type Thing struct {
  Str1 string
  Str2 string
}

func (thing Thing) Save(c appengine.Context) error {
  k := datastore.NewKey(c, "Thing", thing.Str1 + "_" + thing.Str2, 0, nil)
  if _, err := datastore.Put(c, k, &thing); err != nil {
    return err
  }
  return nil
}

func GetThings(c appengine.Context) ([]Thing, error) {
  var things []Thing
  q := datastore.NewQuery("Thing").
      Filter("Str1=", "thing")
  _, err := q.GetAll(c, &things)
  if err != nil {
    return nil, err
  }
  return things, nil
}



func TestGetThings(t *testing.T) {
  c, _ := aetest.NewContext(nil)
  defer c.Close()
  thing1 := Thing{"thing", "1"}
  thing2 := Thing{"thing", "2"}
  thing3 := Thing{"thing", "3"}
  thing1.Save(c)
  thing2.Save(c)
  thing3.Save(c)

//  time.Sleep(2000 * time.Millisecond)

  things, err := GetThings(c)
  if err != nil {
    t.Fatal(err)
  }
  t.Log("length:" + strconv.Itoa(len(things)))
}

sleep 注释掉时的日志

C:\Users\XXXX>goapp test thing -test.v

2014/09/23 21:24:05 应用引擎:未在 devappserver2 下运行；使用一些默认配置

=== 运行 TestGetThings

INFO 2014-09-23 21:24:07,328 devappserver2.py:725] 跳过 SDK 更新检查。

警告 2014-09-23 21:24:07,328 devappserver2.py:741] DEFAULT_VERSION_HOSTNAME 将无法使用 --port=0 正确设置

警告 2014-09-23 21:24:07,351 api_server.py:383] 无法初始化图像 API；您可能缺少 Python“PIL”模块。

INFO 2014-09-23 21:24:07,365 api_server.py:171] 在以下位置启动 API 服务器:http://localhost:50153

INFO 2014-09-23 21:24:07,371 dispatcher.py:183] 启动模块“默认”运行于:http://localhost:50154

INFO 2014-09-23 21:24:07,377 admin_server.py:117] 在以下位置启动管理服务器:http://localhost:50155

INFO 2014-09-23 21:24:08,378 api_server.py:583] 应用所有未决事务并保存数据存储

INFO 2014-09-23 21:24:08,388 api_server.py:586] 保存搜索索引 --- 通过:TestGetThings(4.60 秒)

thing_test.go:87: 长度:0

通过

好的东西 4.729s

sleep 未注释掉时的日志

C:\Users\XXXX>goapp test thing -test.v

2014/09/23 21:24:28 应用引擎:未在 devappserver2 下运行；使用一些默认配置

=== 运行 TestGetThings

INFO 2014-09-23 21:24:31,124 devappserver2.py:725] 跳过 SDK 更新检查。

WARNING 2014-09-23 21:24:31,124 devappserver2.py:741] DEFAULT_VERSION_HOSTNAME 将无法使用 --port=0 正确设置

警告 2014-09-23 21:24:31,148 api_server.py:383] 无法初始化图像 API；您可能缺少 Python“PIL”模块。

INFO 2014-09-23 21:24:31,164 api_server.py:171] 在以下位置启动 API 服务器:http://localhost:50191

INFO 2014-09-23 21:24:31,171 dispatcher.py:183] 启动模块“默认”运行于:http://localhost:50192

INFO 2014-09-23 21:24:31,176 admin_server.py:117] 在以下位置启动管理服务器:http://localhost:50193

INFO 2014-09-23 21:24:34,176 api_server.py:583] 应用所有未决事务并保存数据存储

INFO 2014-09-23 21:24:34,176 api_server.py:586] 保存搜索索引 --- 通过:TestGetThings(6.83 秒)

thing_test.go:87: 长度:3

通过

好的东西 6.987s

最佳答案

为了回答我自己的问题，解决方案是在创建 aetest.NewContext 时使用 Options 参数。

c, _ := aetest.NewContext(&aetest.Options{"", true})

选项结构中的第二项是一个名为 StronglyConsistentDatastore 的 bool 值。

关于google-app-engine - appengine aetest 的不一致行为，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26004506/