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」，然後它會導致您需要確保解決的其他警告（例如，您只能每秒鐘向實體組（在同一祖先下編組的實體）寫入一次），例如）。