1

我必须在单个事务中增加三个不同的计数器。除此之外，我还必须操纵其他三个实体。我明白了

too many entity groups in a single transaction

我使用来自https://developers.google.com/appengine/articles/sharding_counters的食谱来实现我的计数器。我根据业务逻辑在一些模型（类）方法中增加我的计数器。

作为一种解决方法，我实现了一个使用任务来更新计数器的延迟增量方法。但是，如果计数器的数量进一步增加，则无法很好地扩展，因为单个事务中的任务也有限制（我认为是 5），我想这不是最有效的方式。

我还发现https://github.com/DocSavage/sharded_counter/blob/master/counter.py即使在通过 memcache 出现 db 错误的情况下，它似乎也能确保更新计数器。但如果交易失败，我不想增加我的计数器。

另一个想法是记住我必须在 Web 请求期间增加的计数器，并在单个延迟任务中增加它们。我不知道如何在不将请求中创建的对象传递给模型方法的情况下以干净且线程安全的方式实现这一点。我认为这段代码会很丑陋，而且不在同一个交易中：

def my_request_handler():
    counter_session = model.counter_session()
    model.mylogic(counter_session, other_params)
    counter_session.write()

有什么经验或想法吗？

顺便说一句：我正在使用 python、ndb 和 flask 如果计数器不是 100% 准确，那也没关系。

4

1 回答 1

0

如交易和实体组中所述：

最简单的方法是确定您需要能够在同一事务中处理哪些实体。然后，当您创建这些实体时，将它们放置在同一个实体组中，方法是用一个共同的祖先声明它们。然后它们都将位于同一个实体组中，您将始终能够以事务方式更新和读取它们。

于 2013-11-24T13:43:09.903 回答