google-cloud-datastore - 如何在 NDB 中进行批处理操作是原子的或用于更新 ndb 的锁定记录

Question

我是谷歌应用引擎和 NDB 的初学者。我的问题:如果我在模型中有 1 个实体，
我想防止 2 个并行操作时发生冲突，代码示例:

class MyModel(ndb.Model)
  count = ndb.IntegerProperty()
  def update_value(delta)
    count=count +delta

操作1:

my_obj1= MyModel.get_by_id(1)
my_obj1.update_value(10)
my_obj1.put()

操作2:

my_obj2= MyModel.get_by_id(1)
my_obj2.update_value(20)
my_obj2.put()

如果 2 个 session 并行调用 2 个操作，并且在操作之前 count=0 实体(id=1)。我想防止计数值发生冲突，
例如:

 operation1: read my_obj1 from entity(id=1) 
 operation2: read my_obj2 from entity(id=1)
 operation1: update_value(10) #count =10
 operation2: update_value(20) # count=20
 operation1: put() # save to ndb with count =10 
 operation2: put() # save to ndb with count=20

在 ndb 中计数 = 20。
ndb 中 count=30 的期望值。

请告诉我解决方案。

Answer 1

您可以为此使用事务。但它不会扩展。