我应该关心数据存储错误吗?

DR :默认情况下 datastoreRpcErrors 将自动使用5次重试。

我深入研究了 datastoreio 在beam python sdk中。看起来最终的实体突变是通过 DatastoreWriteFn() 。

# Flush the current batch of mutations to Cloud Datastore.
_, latency_ms = helper.write_mutations(
    self._datastore, self._project, self._mutations,
    self._throttler, self._update_rpc_stats,
    throttle_delay=_Mutate._WRITE_BATCH_TARGET_LATENCY_MS/1000)

rpcerror被以下代码块捕获: write_mutations 在 helper 还有一个装饰工 @retry.with_exponential_backoff 对于 commit 方法;默认重试次数设置为5; retry_on_rpc_error 定义混凝土 RPCError 和 SocketError 触发重试的原因。

for mutation in mutations:
  commit_request.mutations.add().CopyFrom(mutation)
  @retry.with_exponential_backoff(num_retries=5,
                                  retry_filter=retry_on_rpc_error)
  def commit(request):
    # Client-side throttling.
    while throttler.throttle_request(time.time()*1000):
    try:
      response = datastore.commit(request)
      ...
    except (RPCError, SocketError):
      if rpc_stats_callback:
        rpc_stats_callback(errors=1)
      raise
      ...

我认为您首先应该确定发生了哪种错误,以便了解您的选择。

但是,在官方数据存储文档中,有一个列表列出了所有可能的 errors and their error codes . 幸运的是,他们为每个人都提供了推荐的操作。

我的建议是,如果他们的建议对你不起作用,你就执行他们的建议并寻找替代方案。