事件源系统中的投影

如何解决事件源系统中的投影

在事件源系统中，我有一个类型为 Order 的聚合根。让我们假设以下事件是 发生：

• OrderPlaced(orderId,placeAt,customerId,orderLines) where OrderLine(lineId,productId,price)
• 接受订单（orderId）

假设我们需要两个不同的投影：

1. 保存所有已接受订单的总价的预测，按年份为每个客户分组。像这样的东西： OrdersByCustomer(customerId,summationOnAcceptedOrdersByYear) 其中 SummationOnAcceptedOrdersByYear(year,sum)

   这里的问题是 OrderAccepted 不包含 customerId。因此，当投影收到 OrderAccepted 时，它无法获取当前 投影状态，因为 customerId 是 documentId。值得注意的是，我将投影存储在 Scylla 中 - 这只能由 分区键 - 投影状态只是一个 json 表示。所以不能被除documentId/projectionId之外的任何东西查询。可能是 这不是用于投影的理想技术选择......？

   如果继续使用 Scylla，我想我有两个选择：

   • 使用 customerId 污染 OrderAccepted。但我认为这不是一个好方法 - 那么我需要将其纳入所有事件 这将与projectionId/documentId 与aggregateId 不同的投影相关。
   • 或者有一个单独的表，其中包含 orderId 和 customerId 之间的映射，因此投影可以查询 customerId - 该表可能需要在命令处理程序中更新 订单汇总。
   • 或者，我们可以对 CustomerIdByOrderId 进行投影 - 但在这里我认为投影可以位于事件流的不同位置 - 这可能 也可能导致问题。

2. 对每种产品的所有已接受订单的价格进行汇总的预测。像这样的东西 SummationForProducts(productId,orderSummation)

   所以这里我们有一个依赖于 OrderPlaced 和 OrderAccepted 的投影。问题是，因为一个 OrderPlaced 可能包含多个 orderLines，因此跨越多个投影 - 我们需要在接收 OrderPlaced 时更新多个投影。这在事件中正常吗 采购预测 - 更新多个预测事件？

   这里出现了同样的问题，即 OrderAccepted 不包含来自 OrderPlaced 事件的 productIds。所以在这里我们可能可以用类似的方法来制作一个包含之间映射的表 orderId 和 productIds

我想知道更有经验的事件源是如何解决这些问题的...？ :) 非常感谢您对此的任何意见。

解决方法

事件源系统的美妙之处在于，您需要的所有信息都 - 或者至少应该 - 封装在事件中。

我将假设您使用的是 CQRS 模式，从您的描述来看，问题的中心在于投影应该是什么样子。换句话说，您不应该真正需要在命令/事件方面进行任何更改，而应该专注于如何从事件中获取所需的数据以构建适当的预测。

我对 Scylla 并不熟悉，但您可以以任何适合您的方式自由建立您的预测。请记住，投影只是您可以从事件中查询的数据。

我能想象的最简单的事情就是存储每个订单，包括状态。像这样（用可怕的伪代码）：

-- Order Summary event handler
on(orderPlaced):
insert into Order(orderId,datePlaced,customerId,orderLines,status)
values (orderPlaced.orderId,orderPlaced.date,orderPlaced.customerId,'placed')

on(orderAccepted):
update Order
set status = 'accepted'
where orderId = orderAccepted.orderId

-- Sum of accepted orders per customer and year
select customerId,year,sum(orderLines.price) from Orders
where status = 'accepted'
group by customerId,year(datePlaced)

-- Sum per product of accepted orders
select productId,sum(orderLines.price) from Orders
where status = 'accepted'
group by orderLines.productId,year(datePlaced)

请注意，上面的代码假设事件是按顺序处理的。

我们需要在接收时更新多个投影 订单已下。这在事件采购预测中是否正常 - 更新 多个投影公关事件？

当然，这是完全正常的。您可以使用单个事件更新多个投影，或使用多个事件更新单个投影，或两者结合使用。