3

Event Store的作者 Greg Young不久前定义了关联 ID 来引用根本原因，而因果 ID 来引用消息的直接原因。

因此，您应该能够通过另一条消息的因果 ID 找到另一条消息直接响应的一条消息。并且您应该能够通过具有相同因果 ID 的消息在同一对话中找到所有消息。

如果应用此模式，则对话中的第二条消息应将相关 ID 和因果 ID 都设置为第一条消息。

在 Commanded 中，我希望第一个事件同时具有相关 ID 和因果 ID，以指向导致事件发生的命令（也可以在此处直观地描述）。

令人困惑的是，在 Commanded 自己的事件存储中，命令之后的第一个事件似乎具有不同的相关性和因果关系 ID。因此，Commanded 似乎不适用于 Greg Young 的定义。

我的问题是，Commanded 中这些 ID 的具体定义是什么？不遵循 Greg Young 的定义是有意识的决定吗？如果是，为什么？

4

1 回答 1

4

Commanded 已按照指南中的说明实施了相关性和因果关系 ID，复制如下。

默认情况下，命令不会被持久化，因此您无法从命令 > 事件 > 命令遵循因果链，除非您还持久化传入的命令。您可以使用Commanded 审计中间件将分派的命令存储到任何 Ecto 支持的数据库。这样做将允许您将命令及其产生的事件联系在一起。相关 id 也可用于关联所有相关消息，假设您在调度命令时复制它们。下面给出了一个这样做的例子。

在 Greg 的事件存储中，我认为因果 id 是从一个事件复制到另一个事件，忽略中间命令，因为他的事件存储只存储事件。

相关性和因果关系 ID

为了帮助监视和调试已部署的应用程序，跟踪命令和事件的因果关系和相关性 ID 很有用。

  • causation_id- 导致事件的命令的 UUID，或导致命令调度的事件。
  • correlation_id- 用于关联相关命令/事件的 UUID。

您可以在调度命令时设置因果关系和相关性 ID：

:ok = ExampleRouter.dispatch(command, causation_id: UUID.uuid4(), correlation_id: UUID.uuid4())

在事件处理程序中调度命令时，您应该从正在处理的事件中复制这些值：

defmodule ExampleHandler do
  use Commanded.Event.Handler, name: "ExampleHandler"

  def handle(%AnEvent{..}, metadata) do
    %{event_id: causation_id, correlation_id: correlation_id} = metadata

    ExampleRouter.dispatch(%ExampleCommand{..},
      causation_id: causation_id,
      correlation_id: correlation_id
    )
  end
end

流程管理器调度的命令将自动从源域事件中分配适当的因果关系和相关性 ID。

于 2018-12-12T10:53:55.313 回答