事件溯源 - 处理批量事务

Question

我想对我拥有的现有 Web 应用程序实施事件溯源。我的实现是一个 .NET Core WEB API，但这无关紧要。该网络应用将包含银行账户交易（类似于从您的银行账户导出）的 CSV 文件导入到 API。

API 获取所有事务，对其进行验证，并删除之前导入的任何事务，然后将它们存储到事务表中。然后根据这些数据生成报告，例如，上个月购买的天然气总量、2017 年外出就餐的总支出等。

在我看来，这种类型的应用程序非常适合事件溯源（反之亦然），但我很难理解如何实现它。我正在尝试实现类似this simple example 的东西。它有一个包含交易事件的帐户聚合，类似于我想做的。

我的第一个问题是，我该如何处理批量交易，因为有些可能是重复的，所以并不是所有的交易都被保存了？ This question 确实涉及该主题，但不同之处在于，在某些情况下，由于文件可能相同，因此在重复检查后可能不会保存任何交易，或者自上次导入以来没有新交易。

其次，如何检查交易是否重复？目前，我的重复检查如下所示：

        var all = await _transactionRepository.GetAll(-1);
        var lookup = all.ToLookup(x => Tuple.Create(x.PostingDate, x.Description, x.Amount, x.Balance));

        foreach (var o in original)
        {
            o.Created = DateTime.Now;

            if (!lookup.Contains(Tuple.Create(o.PostingDate, o.Description, o.Amount, o.Balance)))
            {
                // does not currently exist in the db so add to clean list
                final.Add(o);
            }
        }

我会创建一个投影来寻找那个特定的事件吗？我无法理解如何检查现有数据。

在此先感谢您对理解这一点的任何帮助。

Answer 1

在这种情况下，您的聚合边界在哪里？我认为您有一个单独的 Transaction 聚合，而不仅仅是一个 Batch 聚合，但从您的情况来看并不清楚。如果你确实有一个交易聚合，你如何获得交易聚合的身份（即聚合密钥）？你只是生成一个Guid吗？

您有一个表示交易唯一 ID 的元组。根据这些值，您应该能够创建一个唯一且可重现的 ID，也许是一个哈希。当您向该事务 ID 发出“创建”命令时，如果事务已经存在，则操作应该是幂等的，因此不应该执行任何操作。为了防止可能的重复 ID，您还可以在聚合中检查详细信息（例如 PostingDate、Description、Amount...）是否与 Create 命令中的匹配。如果他们这样做，则忽略该命令。如果没有，则发出“CreateFailed”事件以指示生成了重复 ID。您可以在 Saga 中侦听该事件，然后生成一个新的但仍可重现的 ID 并向其发出 Create 命令。

这样，您就不会依赖于最终一致的预测，并且会发生变化，因此不可靠。