GAE 数据存储，如何在没有祖先或已知实体键的情况下进行原子查询和插入？答案

【问题标题】：GAE datastore, how to atomically query and insert without ancestor or known entity key?GAE 数据存储，如何在没有祖先或已知实体键的情况下进行原子查询和插入？
【发布时间】：2014-10-13 19:13:49
【问题描述】：

例如我有这个用户模型：

class User(ndb.Model):
    email = ndb.StringProperty()

只有在没有其他实体具有特定 email 属性值的情况下，我才想自动添加一个新的 User 实体。

在 SQL 中，我可以执行以下操作来检查并插入事务：

begin; 
if count(select * from User where email='user@email.com') > 0 {
    insert into User values('user@email.com');
}
end;

但在 GAE 中这是不允许的，因为事务内部不允许非祖先查询。我不想使用电子邮件地址作为实体键，因为用户的稳定 id 可能不是基于电子邮件地址。

【问题讨论】：

不明白为什么不能用email作为id。
@Bruyere 使用电子邮件作为 ID 通常不是一个好主意，因为用户的电子邮件最终可能会更改并且 ID 是不可更改的..

标签： python google-app-engine transactions google-cloud-datastore

【解决方案1】：

这个问题已经在 webapp2 微框架中解决了。查看this 文档和this 博客文章。复制粘贴带有基本示例的代码：

from google.appengine.ext.ndb import model

class Unique(model.Model):
    @classmethod
    def create_multi(cls, values):
        keys = [model.Key(cls, value) for value in values]
        entities = [cls(key=key) for key in keys]
        func = lambda e: e.put() if not e.key.get() else None
        created = [model.transaction(lambda: func(e)) for e in entities]

        if created != keys:
            # A poor man's "rollback": delete all recently created records.
            model.delete_multi(k for k in created if k)
            return False, [k.id() for k in keys if k not in created]

        return True, []

    @classmethod
    def delete_multi(cls, values):
        return model.delete_multi(model.Key(cls, v) for v in values)

# Assemble the unique values for a given class and attribute scope.
uniques = [
    'User.username.%s' % username,
    'User.auth_id.%s' % auth_id,
    'User.email.%s' % email,
]

# Create the unique username, auth_id and email.
success, existing = Unique.create_multi(uniques)

if success:
    # The unique values were created, so we can save the user.
    user = User(username=username, auth_id=auth_id, email=email)
    user.put()
    return user
else:
    # At least one of the values is not unique.
    # Make a list of the property names that failed.
    props = [name.split('.', 2)[1] for name in uniques]
    raise ValueError('Properties %r are not unique.' % props)

【讨论】：

【解决方案2】：

您可以在以下用例中遇到此问题：

线程 A 检查电子邮件地址并收到“无”响应
具有此电子邮件地址的实体由线程 B 提交到数据存储区
线程 A 还提交了具有相同电子邮件地址的实体

解决此问题的一种方法是使用电子邮件地址作为实体名称（即密钥）。请注意，它不必是用户实体：它可以是自己的电子邮件实体 - 用户实体的子实体。它甚至可能根本没有其他属性，除非您需要它们。这样您就可以使用事务，因为电子邮件实体和用户实体属于同一个实体组。

【讨论】：

【解决方案3】：

由于您没有祖先，您可能会在最后一次写信后遇到inconsistent state for some hundred milliseconds or so，但在现实生活中，当涉及到电子邮件时，这种情况非常罕见，但当然并非不可能发生。

考虑到这一点，您可以通过以下方式检查电子邮件是否已经存在：

if User.query(User.email == 'test@example.com').count() == 0:
  # do something with the email, it is safe to assume that is unique :)
else:
  # that email already taken

【讨论】：