GAE/P：API 调用的交易安全

Question

假设您使用交易来处理 Stripe 支付并更新用户实体：

@ndb.transactional
def process_payment(user_key, amount):
    user = user_key.get()
    user.stripe_payment(amount) # API call to Stripe
    user.balance += amount
    user.put()

Stripe API 调用可能成功，但 put 由于争用而失败。然后会向用户收费，但他的帐户不会反映付款。

您可以将 Stripe API 调用从事务中提取出来，然后再进行事务，但您似乎仍然遇到同样的问题。收费成功，但交易失败，用户账户未记入贷方。

这似乎是一个非常常见的情况。如何正确处理这个问题？

Answer 1

为了正确操作，事务函数需要是幂等的。所以你不能在这样的函数中进行条带调用，因为它会使它成为非幂等的。

我会单独调用条带，并且在 API 成功后，我会调用一个事务函数来更新用户的帐户余额（在发生争用时可以安全地重试）。

甚至可以创建一个单独的、独立的实体来反映条带 API 调用结果？这样的实体应该没有争用的余地，因为它只被写入一次——当条带事务发生时。这将允许您：

• 保留帐户交易历史记录 - 指向这些实体
• 进行一些健全性检查以查找孤立条带交易（如果出于某种原因，即使在重试后帐户交易调用仍失败）并对此采取措施。

@thebjorn 的评论很好：多步骤的方法可以使这个过程非常可靠：

• 一个交易函数更新帐户以执行条带交易，这也是transactionally enqueues a push task 执行条带 API 调用。仅当事务成功时任务才入队
• 推送队列任务进行条带 API 调用（最终创建条带事务实体），并在成功时调用事务函数来更新帐户余额