GAE 中的 Objectify 并发

Question

我创建了一个测试 Web 应用程序来测试 Entities 的持久读取删除，我创建了一个简单的循环来持久保存 Entity，检索并修改它，然后将其删除 100 次。

在循环的某个间隔没有问题，但是有一个错误，Entity 已经存在因此无法持久化（我添加的自定义异常处理） .

同样在循环的某个时间间隔，Entity 不存在，因此无法修改，最后在某个时间间隔，Entity 不存在，无法删除。

我知道循环可能非常快，以至于对 Appengine 数据存储的操作尚未完成。因此，当尝试访问它或删除操作尚未完成时，会导致类似Entity does not exist 的错误，因此无法创建具有相同ID 的实体，依此类推。

但是，我想了解如何处理这种使用 Entity 进行并发操作的情况。

Answer 1

据我了解，您正在执行以下操作：

for i in range(0,100):
    ent = My_Entity()    # create and save entity
    db.put(ent)
    ent = db.get(ent.key())   # get, modify and save the entity
    ent.property = 'foo'
    db.put(ent)
    ent.get(ent.key())  # get and delete the entity
    db.delete(my_ent)

进行一些错误检查以确保您有要删除、修改的实体，并且您在查找要删除或修改的实体时遇到了一堆错误。正如您所说，这是因为不能保证调用按顺序执行。

但是，我想了解如何处理这种对实体进行并发操作的情况。

最好的办法是批量处理您为实体持久化所做的任何修改。例如，如果您要创建/保存/修改/保存或修改/保存/删除，请尽可能尝试组合这些步骤（即创建/修改/保存或修改/删除）。这不仅可以避免您看到的错误，还可以减少您的 RPC。按照这个策略，上面的循环将被简化为......

prop = None
for i in range(0,100):
    prop = 'foo'

换句话说，对于任何需要快速设置/删除的东西，只需使用局部变量即可。这就是 GAE 为您提供的答案。在您弄清楚所有快速的东西之后，您无法将这些信息持久保存在实体中。

除此之外，您无能为力。如果您需要确保一堆实体一起更新，Transactions 可以为您提供帮助，但如果您尝试同时对一个实体执行多项操作，则无济于事。

编辑：您还可以查看pipelines API。