AppEngine实现强一致性

Question

我试图实现强一致性。让我们把我的模型PVPPlayer：

class PVPPlayer(ndb.Model): 
    points = ndb.IntegerProperty() 

为模型中的每个关键是这样创建的：

pvp_player = PVPPlayer(key=ndb.Key(Profile, "test_id", PVPPlayer, "test_id")) 

其中Profile是父模型：

class Profile(ndb.Model): 
    def build_key(cls, some_id): 
     return ndb.Key(cls, some_id) 

我有2个REST API URL：

1) update_points 
2) get_points 

在1）我做的：

# I use transaction because I have to update all the models in single batch 
@ndb.transactional(xg=True, retries=3) 
def some_func(points): 
    pvp_player = ndb.Key(Profile, "test_id", PVPPlayer, "test_id").get() 
    pvp_player.points += points 
    pvp_player.put() 
    # update other models here` 

在2）我做的：

pvp_player = ndb.Key(Profile, "test_id", PVPPlayer, "test_id").get() 
return pvp_player.points` 

我的流程是这样的：

1) update_points() 
2) get_points() 
3) update_points() 
4) get_points()` 
... 

问题：

使用get()保证强一致性o我不明白的是为什么有时候由于get_points()的结果，我得到的数据像陈旧的数据根本没有更新。

例：

POST get_points -> 0 
POST sleep 1-3 sec 
POST update_points -> 15 
POST sleep 1-3 sec 
POST get_points -> 15 
POST sleep 1-3 sec 
POST update_points -> 20 
POST sleep 1-3 sec 
POST get_points -> 15 !!!` 

Answer 1

有你超过每实体组的写入限制的情况下，即每秒更新？我认为这可能会破坏文档中提到的实体组的强大一致性。

Answer 2

首先检查您的日志，其中一个更新必须失败，错误，因为您的逻辑基本上是正确的。

同时仔细检查您的所有更新是否包含在交易中以避免竞争。 Cloud Datastore: ways to avoid race conditions

---

这种情况很可能不是一致性问题，但跺脚更新，结帐这个链接一些有趣的案例：

http://engineering.khanacademy.org/posts/transaction-safety.htm http://engineering.khanacademy.org/posts/user-write-lock.htm