如何让Google Datastore事务遇竞争时立即失败而非等待？

Google Datastore 默认的读写事务在遇到实体组冲突时，会等待当前持有租约的事务完成后再检查版本并抛出冲突错误。要实现冲突时立即失败不等待，可通过以下方式配置：

• 核心原理：禁用事务租约等待机制
  Datastore 的读写事务依赖实体组租约来保证一致性，默认会等待租约释放。通过显式关闭租约等待，事务在无法立即获取租约时会直接抛出冲突异常。

• 代码实现示例（以 Python 客户端为例）：
  在开启事务时，指定 transaction_options 并将 read_write.wait_for_lease 设置为 False：

  from google.cloud import datastore
  
  client = datastore.Client()
  # 配置事务：禁用租约等待，冲突立即失败
  txn_options = {"read_write": {"wait_for_lease": False}}
  
  try:
      with client.transaction(options=txn_options) as txn:
          # 读写目标实体
          entity_key = client.key("YourEntityKind", "target_entity_id")
          entity = txn.get(entity_key)
          entity["some_field"] = "new_value"
          txn.put(entity)
  except datastore.exceptions.Conflict:
      # 直接处理冲突失败逻辑
      print("检测到事务冲突，立即终止")
  

• 关键注意点：

  • 该配置仅对读写事务生效，只读事务不涉及实体组租约，无等待行为
  • 启用后事务不会等待租约释放，一旦检测到冲突会立刻抛出 Conflict 异常
  • 需自行在代码中捕获异常并处理失败，Datastore 不会自动重试事务

内容的提问来源于stack exchange，提问作者Micro