go - 无法从使用 IncompleteKey() 创建的数据存储中检索实体

标签 go google-cloud-datastore

我正在使用“cloud.google.com/go/datastore”来存储、更新和检索数据存储中的实体。我创建的结构是 -

type TExp struct {
    Key        string   `json:"key" datastore:"key,noindex"`
    Value      string   `json:"value" datastore:"value,noindex"`
} 

type service struct {
DataLayer *datastore.Client
}

当我使用 datastore.IncompleteKey("TExp", nil) 为此创建 id 时,我能够创建实体并可以在真实数据存储中看到它。

func (s service)addTExp(ctx context.Context, request interface{}) (interface{}, error) {

req := request.(*TExp)
var tExp []TExp
var tExp2 TExp
tExp2.Key   = req.Key
tExp2.Value =   req.Value

query := datastore.NewQuery("TExp").Filter("key =", req.Key).Namespace("AdLive")
keys, err := s.DataLayer.GetAll(ctx, query, &tExp)
if err != nil {
    log.Errorf(ctx,"Error occurred while checking existence of key in kind")
}

if keys == nil {
log.Infof(ctx,"Keys: %v ", keys)
k := datastore.IncompleteKey("TExp", nil)
k.Namespace = "AdLive"
k.Kind = "TExp"

if _, err := s.DataLayer.Put(ctx, k, &tExp2); err != nil {
    return nil, marvin.NewJSONStatusResponse(
        "could not add TExp in DS",
        http.StatusBadRequest,
    )} 
   }
   return "OK",nil
}

问题是在创建任何实体之前,我想确保任何具有相同键值的实体都不存在于该数据存储区中。为此,首先我尝试使用 GetAll 方法检查是否存在,如果键为零,我想调用 datastore.Put 来添加新实体。但是,在每种情况下(即使对于数据存储中已经存在的实体),“keys”变量总是获得 nil 值。

keys, err := s.DataLayer.GetAll(ctx, query, &tExp)

因此,在数据存储区中创建了多个具有相同键值的实体。我无法找到如何在 golang 中解决此问题。

注意:- 在数据存储实体中有结构

[“Datastore 在调用 IncompleteKey 方法时自动生成的名称/ID”,Key,Value]。

最佳答案

首先,如果你想获取一个特定的实体,你应该使用Get而不是 GetAll,因为 Get 是强一致的,而 GetAll 不是。

其次,由于您正在使用不完整的 key 执行 Put,因此您永远不会与您仅添加到数据存储区的新实体发生冲突。您似乎想使用 transaction获取和放置具有传递到您的函数的完整 key 的实体。

关于go - 无法从使用 IncompleteKey() 创建的数据存储中检索实体,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56186201/

相关文章:

go - 如何为静态文件设置http header ?

go - 推迟到一个函数之外

google-app-engine - 应用程序引擎上的故障安全数据存储区更新

firebase - 在 Xcode 中存档时 Flutter Firestore 插件抛出错误

java - 如何从 AppEngine 访问 Cloud Datastore?

google-app-engine - Google App Engine(数据存储)- 删除的 key 会重新生成吗?

csv - 如何读取大型 CSV 文件

go - 是否有与 Perl6 中的 Go goroutines 等效的东西?

concurrency - 为什么我的并发函数在 Go 中过早退出?

google-app-engine - 我无法使用 google.golang.org/appengine 模块将 Go 模块部署到 App Engine