AppEngine实现强一致性

Question

我正在努力实现强烈的一致性。让我们调用我的模型PVPPlayer：

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

模型的每个关键点都是这样创建的：

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

其中，配置文件是父模型：

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（）保证了很强的一致性，所以我不明白的是为什么有时由于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

首先检查您的日志，其中一个更新肯定会出错，因为您的逻辑基本正确。

还要仔细检查所有更新是否包装在事务中，以避免竞争。云数据存储：避免竞争条件的方法

这个案例可能不是关于一致性问题，而是践踏更新，查看以下链接以获取一些有趣的案例：

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