1

我对有关 Datastore 的以下内容迷失了：

  • 建议对数据进行非规范化处理，因为 Datastore 不支持连接查询。这意味着在多个实体中复制相同的信息

  • 非规范化意味着无论何时必须更新数据，都必须在不同的实体中更新

  • 但是在单个实体组中存在 1 次写入/秒的限制。

因此，我遇到的问题如下：

  • 为了更新记录，我打开一个事务然后

  • 更新所有必需的实体。要更新的实体在同一个实体组中，但涉及到不同的种类

  • 我收到“资源争用”异常

==>因此，更新非规范化数据的唯一方法似乎是在事务之外。但是这样做真的很糟糕，因为某些实体可以更新，而其他实体则不能。

我是唯一有这个问题的人吗？你是怎么解决的？

谢谢，

雨果

（简化版）代码如下：

Objectify ofy=ObjectifyService.beginTransaction();

try {
  Key<Party> partyKey=new Key<Party>(realEstateKey, Party.class, partyDTO.getId());

  //--------------------------------------------------------------------------
  //-- 1 - We update the party
  //--------------------------------------------------------------------------
  Party party=ofy.get(partyKey);
  party.update(partyDTO);

 //---------------------------------------------------------------------------------------------
 //-- 2 - We update the kinds which have Party as embedded field, all in the same entity group
 //--------------------------------------------------------------------------------------------- 

  //2.1 Invoices

  Query<Invoice> q1=ofy.query(Invoice.class).ancestor(realEstateKey).filter("partyKey", partyKey);
    for (Invoice invoice: q1) {
      invoice.setParty(party);
     ofy.put(invoice);
   }
  //2.2Payments 
  Query<Payment> q2=ofy.query(Payment.class).ancestor(realEstateKey).filter("partyKey", partyKey);
    for (Payment payment: q2) {
      payment.setParty(payment);
     ofy.put(payment);
   }
}

  ofy.getTxn().commit();
  return (RPCResults.SUCCESS);
}

catch (Exception e) {       
        final Logger log = Logger.getLogger(InternalServiceImpl.class.getName());       
        log.severe("Problem while updating party : " + e.getLocalizedMessage()); 
       return (RPCResults.FAILURE)  ;    
}

finally {
    if (ofy.getTxn().isActive()) {
      ofy.getTxn().rollback();
     partyDTO.setCreationResult(RPCResults.FAILURE);
    return (RPCResults.FAILURE) ;        
    }              
}
4

2 回答 2

3

发生这种情况是因为在短时间内发生了多个更新同一实体组的请求，而不是因为您一次更新同一实体组中的许多实体。

由于您没有显示您的代码，我可以假设正在发生以下两种情况之一：

  1. 您上面描述的方法实际上并未使用事务，并且您正在put_multi()使用同一实体组的许多实体运行。（如果我不得不猜测，那就是这个。）
  2. 您有一个高流量的站点，并且许多其他更新同时发生。
于 2012-07-31T17:50:26.480 回答
1

以防万一有人遇到同样的问题。

问题出在 party.update(partyDTO) 中，在某些特定条件下，我正在启动另一笔交易。

我今天学到的是：

--> 在一个事务中，即使超过 1 个实体/秒，您也可以包含多个 put

--> 但是，您应该注意不要在您的事务中启动另一个事务

于 2012-07-31T19:45:05.410 回答