Google Cloudデータストアでget-update-set操作を実行するエンティティをロックする

Question

Google Cloud Datastoreで一貫したread - > update - > set操作を実行するためにエンティティ（user（amount_earned）など）をロックするための推奨方法。

memcacheを使用すると、通常、オブジェクトを変更するプロセス/スレッドのみが存在することを確認するために、memcache.add（lock_key）を実行します。

memcacheのaddはアトミックであり、falseが返されるため、以前にkeyが追加されなかった場合、memcacheを使用して「ロック」をシミュレートするのは簡単です。

Google Cloudデータストアで同様のロックセマンティクスをシミュレートするにはどうすればよいですか。

理想的

with gcp.lock(lock_key)as key: 
    user.get(user_id) # read 
    user.update(amount) # update 
    user.set() # save 

# Release the lock, so that other processes can now updated user (identified by user_id) object 

Answer 1

あなたはおそらくTransactionsとOptimistic Locking戦略を使用することができます。

Userエンティティを更新する例を考えてみましょう。オプティミスティックロックを使用するには、特別なプロパティ（エンティティバージョンなど）を使用する必要があります。バージョンフィールドは、更新ごとに1ずつ増加します。エンティティを更新する手順：

1. エンティティ
2. をロードするには、[ユーザーエンティティの更新を可能にするUIを持っていると仮定します。エンティティを編集モードで画面に表示します。
3. エンドユーザーレビューは/
4. エンドユーザーが[保存]をクリックしたエンティティへの変更を行う
5. 今、トランザクションが
6. ロードエンティティのキ​​ーが
7. が新たにロードされたエンティティとエンティティのバージョンを比較し
使用してUserエンティティを開始以前にUIにロードされている
8. バージョンが一致する場合、他の誰もエンティティを更新していないので、エンティティを更新してトランザクションをコミットします。更新/コミット中にバージョン番号をインクリメントしてください。バージョンが一致しない場合、他の誰かがエンティティを変更しました。エンティティを更新せず、トランザクションをロールバックします。適切な処置をとってください。たとえば、ユーザーにメッセージを表示し、最新のエンティティを確認してさらに変更を加えることができます。