Google App Engine Datastore 查询返回陈旧数据

Question

我有一个基于 GAE 的项目，使用 db Datastore。在我的项目中，我每 15 分钟运行一次作业，并更新 Datastore 中的数据。然后我有一个查询Datastore 并显示结果的端点。但是，我得到的结果是陈旧的，而不是更新的结果。似乎 GAE 没有命中 Datastore 并从缓存中返回数据，但我不确定。这是我的代码：

class MainHandler(webapp2.RequestHandler):

    def get(self):
        query = Contests.all()
        contests_data = query.fetch(1) # fetch the data from datastore
        self.response.write(contests_data[0].data)

class DataBaseHandler(webapp2.RequestHandler):

    # the job that runs every 15 minutes
    def get(self):
        contests_data = get_all_contests() # get the new data
        query = Contests.all()
        contests = query.fetch(1)
        contests[1].data = contests_data # update the data
        db.put(contests[0])
        self.response.write(json.dumps({"message":"updated"}))

这是我的模型：

class Contests(db.Model):
    """Models Contests"""
    data = db.TextProperty(default="{}")
    created = db.DateTimeProperty(auto_now_add=True)
    modified = db.DateTimeProperty(auto_now=True)

我尝试使用memcache.flush_all() 清除缓存，但即使这样也不能解决问题。为什么 GAE 不返回更新的数据？我该如何解决这个问题？

编辑：我将查询更改为祖先查询，但数据仍然过时（而且已经有好几天了）。

main.py

class MainHandler(webapp2.RequestHandler):

        def get(self):
            contest_list = ContestList.get_or_insert('contest_list', name='ContestList')
            query = Contests.all()
            query.ancestor(contest_list) 
            contests = query.fetch(1)
            self.response.write(contests[0].data)

    class DataBaseHandler(webapp2.RequestHandler):

        def get(self):
            contests_data = get_all_contests()
            contest_list = ContestList.get_or_insert('contest_list', name='ContestList')
            query = Contests.all()
            query.ancestor(contest_list)
            contests = query.fetch(1)
            contests[0].data = contests_data
            contests[0].put()
            self.response.write(json.dumps({"message":"updated"}))

models.py:

class ContestList(db.Model):
    name = db.StringProperty()

class Contests(db.Model):
    """Models Contests"""
    data = db.TextProperty(default="{}")
    created = db.DateTimeProperty(auto_now_add=True)
    modified = db.DateTimeProperty(auto_now=True)

我什至尝试使用key获取数据：

class MainHandler(webapp2.RequestHandler):

    def get(self):
        q = ndb.Key('Contests', 'contest_data').get()
        if q:
            self.response.write(q.data)
        else:
            self.response.write("error")

class DataBaseHandler(webapp2.RequestHandler):

    def get(self):
        Contests(key=ndb.Key('Contests', "contest_data"), data=get_all_contests()).put()
        self.response.write(json.dumps({"message":"updated"})) 

GAE 没有击中数据存储区的是什么？我在这里错过了什么？

Answer 1

数据存储区仅对查询具有最终一致性。在复制数据期间，确实有可能遇到“陈旧”数据。

为确保在查询中强制实现强一致性，您需要使用祖先查询或按键获取。

阅读更多关于这个here

例如：祖先查询

(documentation) 要做到这一点，你显然需要稍微改变你的结构。我不知道模型“竞赛”的祖先可能是什么，但假设它们都属于“mainAncestor”实体。

当您创建实体时，您需要有类似的东西：

newContest = Contest(parent=mainAncestor)

然后，当您检索时，将其添加到您的代码中：

query = Contests.all()
query.ancestor(mainAncestor) 
contests = query.fetch(1)

这将强制您的数据保持高度一致性。您显然需要创建该“mainAncestor”，然后它会导致您需要确保解决的其他警告（例如，您只能每秒写入一次实体组（分组在同一祖先下的实体） )。