複製高複製數據存儲中的條目

Question

當調用此POST方法時，我們仍然有重複條目的情況。 我曾詢問過有關堆棧溢出的建議，並給出solution，即利用parent/child方法來保留強烈一致的查詢。

我已將所有數據遷移到該表單，並讓它再運行3個月。 但是問題從未解決。

問題是在這裏與這個條件if recordsdb.count() == 1: 它應該是爲了更新條目，而是HRD可能不會總是找到最新的條目，並創建一個新的條目。

正如你所看到的，我們正在編寫/通過父/子方法從記錄閱讀推薦：

new_record = FeelTrackerRecord(parent=user.key,...) 

，但仍然進行檢索時，HRD仍然並不總是獲取最新的條目：

recordsdb = FeelTrackerRecord.query(ancestor = user.key).filter(FeelTrackerRecord.record_date == ...) 

因此，我們很困擾這一點，不知道如何解決它。

@requires_auth 
    def post(self, ios_sync_timestamp): 
     user = User.query(User.email == request.authorization.username).fetch(1)[0] 
     if user: 
      json_records = request.json['records'] 
      for json_record in json_records: 
       recordsdb = FeelTrackerRecord.query(ancestor = user.key).filter(FeelTrackerRecord.record_date == date_parser.parse(json_record['record_date'])) 
       if recordsdb.count() == 1: 
        rec = recordsdb.fetch(1)[0] 
        if 'timestamp' in json_record: 
         if rec.timestamp < json_record['timestamp']: 
          rec.rating = json_record['rating'] 
          rec.notes = json_record['notes'] 
          rec.timestamp = json_record['timestamp'] 
          rec.is_deleted = json_record['is_deleted'] 
          rec.put() 
       elif recordsdb.count() == 0: 
        new_record = FeelTrackerRecord(parent=user.key, 
             user=user.key, 
             record_date = date_parser.parse(json_record['record_date']), 
             rating = json_record['rating'], 
             notes = json_record['notes'], 
             timestamp = json_record['timestamp']) 
        new_record.put() 
       else: 
        raise Exception('Got more than two records for the same record date - among REST post') 
      user.last_sync_timestamp = create_timestamp(datetime.datetime.today()) 
      user.put() 
      return '', 201 
     else: 
      return '', 401 

可能的解決方案：

的最後想法我就必須解決這個問題將是，辭去父/子策略路程，使用user.key PLUS date-string作爲關鍵的一部分。

保存：

new_record = FeelTrackerRecord(id=str(user.key) + json_record['record_date'], ...) 
new_record.put() 

加載：

key = ndb.Key(FeelTrackerRecord, str(user.key) + json_record['record_date']) 
record = key.get(); 

現在我可以檢查是否記錄是無，我將創建一個新條目，否則我將更新它。希望HRD沒有理由不再找到記錄。 您認爲什麼，這是一個有保證的解決方案？

Answer 1

可能的解決方案似乎與原始代碼具有相同的問題。想象一下，如果兩臺服務器幾乎同時執行相同的指令，競爭條件。由於Google的過度配置，這一定會偶爾發生。

一個更強大的解決方案應該使用Transactions並在併發導致一致性違規時回滾。用戶實體應該是其自己的實體組的母公司。在事務內的用戶實體中增加記錄計數器字段。只有在事務成功完成時才創建新的FeelTrackerRecord。因此，FeelTrackerRecord實體必須有一個用戶作爲父項。

編輯：在你的代碼的情況下，下面的線將用戶之前去= User.query（...：

Transaction txn = datastore.beginTransaction(); 
try { 

和用戶後，以下行會去。put（）：

txn.commit(); 
} finally { 
    if (txn.isActive()) { 
     txn.rollback(); 
    } 
} 

這可能會忽略一些流控制嵌套細節，這是這個答案試圖描述的概念。

對於活動事務，如果多個進程（例如多個服務器因爲過度配置而同時執行相同的POST），第一個進程將通過put和commit來成功執行，而第二個進程將引發記錄的ConcurrentModificationException。

編輯2：增加計數器（並可能拋出異常）的事務也必須創建新記錄。這樣，如果引發異常，則不會創建新記錄。