Google App Engine数据存储查询返回陈旧数据

Question

我有一个基于GAE的项目，使用dbDatastore。在我的项目中，我每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

数据存储区最终只对查询一致。在数据复制过程中，确实存在一种可能性，那就是您打到“陈旧”的数据。

为了确保您在查询中强制保持一致性，您需要使用祖先查询或get by键。

了解更多关于这个here

例：祖先查询

（documentation）为了做到这一点，你显然需要改变你的结构位。我不知道什么可能是模型“竞赛”的祖先，但我们假设他们都属于“主祖先”实体。

当您创建实体，你需要有一个类似于：

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

这将迫使强：

newContest = Contest(parent=mainAncestor) 

然后，当您检索，您在代码中添加此数据的一致性。您显然需要创建该“mainAncestor”，然后它会导致您需要确保解决的其他警告（例如，您只能每秒钟向实体组（在同一祖先下编组的实体）写入一次），例如）。