Azure 表实体存在/同步



我正在使用 azure 表查询来检索分配给用户的所有错误实体。我更改实体的属性以声明实体处于处理模式。处理完实体后,我从表中删除了实体。

当我进行并行测试时,可能会发生在查询期间,一个实体已经被另一个线程处理和删除的情况。因此,当我想替换实体时,我收到错误 404 ResourceNotFound。

有没有办法测试实体是否在线程外部更改或仍然存在?是捕获错误 404 并忽略它更好,还是应该再次查询实体(似乎不适合我)?

TableQuery<ErrorObjectTableEntity> query = new TableQuery<ErrorObjectTableEntity>().Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, user));
List<ErrorObjectTableEntity> queryResult = table.ExecuteQuery(query).OrderBy(x => x.action).ToList();
foreach (ErrorObjectTableEntity entity in queryResult)
{
     entity.inProcess = true;
     try
     {
         TableOperation updateOperation = TableOperation.Replace(entity);
         table.Execute(updateOperation);     
      }
      catch
      {
          //..some logging here
          //catch error 404?
      }
      //do some action
      try
      {
          TableOperation deleteOperation = TableOperation.Delete(entity);
          table.Execute(deleteOperation);
      }
      catch{...}
}

就最佳实践而言,这里有几个问题。假设另一个工作线程删除了异常,编写的代码可以简单地忽略异常,但这最终可能会掩盖其他类别的错误。一种解决方案是使用队列为每个用户查询插入消息,然后让各种工作线程检索消息并处理特定用户的查询。这样,如果节点出现故障,应用程序将吸收故障并继续运行。此外,这可以防止您的工作人员重复工作,从而优化整个应用程序。最后,如果您不关心实体的状态并且键是可预测的,则可以使用 Merge 语义简单地更新实体的给定属性,而无需替换整个内容。

你应该只抓住404错误。尽管它们在 .NET 中表示为异常,但 HTTP 4xx 错误代码的信息性大于异常性。(5xx 错误代码是例外。

即使您在执行替换之前检查了实体是否存在,您仍然需要捕获 NotFound 错误,以防它在检查和替换调用之间被删除。所以你不妨跳过检查。

相关内容

最新更新