Google Cloud Datastore 提交冲突检测

大家好，今天本人给大家带来文章《Google Cloud Datastore 提交冲突检测》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

我在数据存储模式下使用 Firestore。我没有使用 Google 或任何人提供的客户端库，而是通过 proto grpc 库（任何人都可以生成的库）生成（由 Google）直接与数据存储进行通信。我使用它是因为高级客户端不应该使用实体版本和冲突检测机制。

我正在执行事务更新并指定冲突检测策略基本版本（每个实体可能包含先前已知的版本）。

问题是，当任何实体中存在版本冲突时，整个提交操作会失败吗？如果它没有失败，这样的提交是否会应用在数据存储中，并且我不会通过简单的事务回滚调用进行回滚。

我是否仍需要通过单独调用数据存储区在该事务之外实现自己的独立回滚？

突变产生

承诺并决定下一步做什么

我已经浏览了文档，但这个问题还远未完成。这是我唯一找到的东西。

https://cloud.google.com/datastore/docs/reference/data/rpc/google.datastore.v1#google.datastore.v1.MutationResult

解决方案

数据存储对单个事务内可以完成的操作施加限制。通常，当存在提交冲突时，并发事务/修改会得到回复。您可以通过启动两个写入同一文档的事务、提交并查看预期行为来重现此情况。

Documentation：

当两个或多个事务同时尝试修改一个或多个公共实体组中的实体时，只有第一个提交其更改的事务才能成功；所有其他人都会在提交时失败。由于这种设计，使用实体组会限制您可以对组中的任何实体执行的并发写入数量。当事务启动时，datastore 通过检查事务中使用的实体组的上次更新时间来使用乐观并发控制。提交实体组事务后，数据存储区会再次检查事务中使用的实体组的上次更新时间。如果自初始检查以来它已更改，则会引发异常。

最好的方法是快速重现它并查看确切的行为。问题是，当任何实体中存在版本冲突时，整个提交操作会失败吗？

是的。

包装器将自动重试您的交易。运行事务库的 golang 数据存储应该可以更深入地了解其行为方式。有关更多信息，请查看下面的 RunInTransaction 并了解它如何评估交易。

func (c *Client) RunInTransaction(ctx context.Context, f func(tx *Transaction) error, opts ...TransactionOption) (cmt *Commit, err error) {
        ctx = trace.StartSpan(ctx, "cloud.google.com/go/datastore.RunInTransaction")
        defer func() { trace.EndSpan(ctx, err) }()
     
        settings := newTransactionSettings(opts)
        for n := 0; n < settings.attempts; n++ {
     tx, err := c.newTransaction(ctx, settings)
     if err != nil {
     return nil, err
     }
     if err := f(tx); err != nil {
     _ = tx.Rollback()
     return nil, err
     }
     if cmt, err := tx.Commit(); err != ErrConcurrentTransaction {
     return cmt, err
     }
     // Pass this transaction's ID to the retry transaction to preserve
     // transaction priority.
     if !settings.readOnly {
     settings.prevID = tx.id
     }
        }
        return nil, ErrConcurrentTransaction
    }

以上就是《Google Cloud Datastore 提交冲突检测》的详细内容，更多关于的资料请关注golang学习网公众号！