建立資料結構以達到嚴格的一致性

附註：我們強烈建議建構新應用程式的開發人員使用 NDB 用戶端程式庫，因為 NDB 用戶端程式庫與本用戶端程式庫相較之下有幾個優點，例如能透過 Memcache API 自動將實體加入快取。如果您目前使用的是舊版的 DB 用戶端程式庫，請參閱從 DB 至 NDB 的遷移指南。

Datastore 能透過許多機器發布資料，還能針對地理範圍廣泛的區域使用同步備用資源，因此能發揮高度的可用性、擴充性以及耐用性。不過，這種設計有利有弊，缺點在於任何一個實體群組的寫入總處理量受限於大約每秒修訂一次。如要跨多個實體群組進行查詢或交易，也會受到限制。本頁詳細說明相關限制，同時以不犧牲應用程式寫入總處理量需求為前提，探討建立資料以利強式一致性的最佳做法。

同步一致性讀取功能一定能夠傳回最新的資料，此外，若是在交易當中執行，則會呈現來源是單一且一致的數據匯報。不過，查詢必須指定祖系篩選條件，才能保持十分一致或參與交易，且交易最多只能與 25 個實體群組相關。能發揮最終一致性的讀取功能沒有以上限制，適用於許多情況。若使用能發揮最終一致性的讀取功能，可以在為數更多的實體群組之間發佈資料，從而在不同的實體群組同時執行提交，以利提高寫入總處理量。但是，要判斷您的應用程式究竟是否適合使用能發揮最終一致性的讀取功能，就必須瞭解這類功能的特性：

  • 這類讀取功能的結果不見得能反映出最新交易，這是因為這類讀取功能並不要求必須執行最新的備用資源，且會在執行查詢時使用備用資源中的任何一項可用資料。備用資源的延遲時間通常不超過幾秒鐘。
  • 跨多個實體的單一修訂交易可能只適用於其中一部分實體，而不適用其他實體。然而請注意，絕對不會發生在單一實體中只適用部分交易的情形。
  • 查詢結果可能會包含根據篩選條件不應包含的實體，也可能會排除應包含的實體。這是因為索引讀取的版本可能會與實體本身所讀取的版本不同所導致。

若要瞭解如何建構資料以實現強式一致性，請為簡單的留言板應用比較兩種不同的方法。第一種方法是為每個已建立的實體建立一個新的根實體。

import webapp2
from google.appengine.ext import db

class Guestbook(webapp2.RequestHandler):
  def post(self):
    greeting = Greeting()
    ...

接下來會查詢最近十句問候語的實體種類 Greeting。

import webapp2
from google.appengine.ext import db

class MainPage(webapp2.RequestHandler):
  def get(self):
    self.response.out.write('<html><body>')
    greetings = db.GqlQuery("SELECT * "
                            "FROM Greeting "
                            "ORDER BY date DESC LIMIT 10")

不過，由於您使用的是非祖系查詢，因此在執行查詢時，這項配置中用於執行查詢的備用資源可能尚未發現新的問候語。儘管如此，幾乎所有寫入均可在提交後幾秒內用於非祖系查詢。就許多應用程式而言，只要能在目前使用者自己所做的變更中提供非祖系查詢結果，即使出現備用資源延遲現象，通常也在可以接受的範圍。

如果您的應用程式十分需要具有同步一致性，您可以選擇採用替代方法，在必須透過具有同步一致性的單一祖系查詢來讀取的所有實體中，使用能識別相同根實體的祖系路徑來寫入實體：

import webapp2
from google.appengine.ext import db

class Guestbook(webapp2.RequestHandler):
  def post(self):
    guestbook_name=self.request.get('guestbook_name')
    greeting = Greeting(parent=guestbook_key(guestbook_name))
    ...

接著您就能夠在透過共同根實體所識別的實體群組中，執行具有同步一致性的祖系查詢：

import webapp2
from google.appengine.ext import db

class MainPage(webapp2.RequestHandler):
  def get(self):
    self.response.out.write('<html><body>')
    guestbook_name=self.request.get('guestbook_name')

    greetings = db.GqlQuery("SELECT * "
                            "FROM Greeting "
                            "WHERE ANCESTOR IS :1 "
                            "ORDER BY date DESC LIMIT 10",
                            guestbook_key(guestbook_name))

這個方法能依留言板寫入單一實體群組，因此效能十分一致，不過，留言板變更也會因此受到限制，每秒最多只能寫入 1 次 (支援範圍內的實體群組限制)。如果應用程式可能會出現較頻繁的寫入使用量，您可能需要考慮採用其他方法：例如，您可以將最近的貼文放入具有到期日的memcache，並顯示 memcache 和 Datastore 中的近期貼文組合，或者您可以將貼文快取到 Cookie 中，將某些狀態放入網址，或完全使用其他方法。這麼做的目的在於找到一個快取解決方案，以利目前使用者在您的應用程式中貼文的期間內提供資料。請記住，若在交易中執行 get 操作、祖系查詢或任何操作，一定會顯示最近寫入的資料。