Commanded 中的相关性和因果关系 ID

Question

Greg Young，作者 Event Store, defined a while ago 关联 ID 引用根本原因，因果关系 ID 引用消息的直接原因。

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

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

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

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

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

Answer 1

Commanded 已按照指南中所述实施 correlation and causation ids，复制如下。

默认情况下命令不会被持久化，因此你不能从命令>事件>命令中追踪因果链，除非你也持久化传入的命令。您可以使用 Commanded audit middleware 将分派的命令存储到任何 Ecto 支持的数据库。这样做将使您能够将命令及其结果事件联系在一起。关联 ID 也可用于关联所有相关消息，假设您在发送命令时复制它们。下面给出了一个这样做的例子。

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

相关性和因果关系 ID

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

causation_id - 导致事件的命令的 UUID，或导致命令分派的事件。
correlation_id - 用于关联相关 commands/events.

您可以在发送命令时设置因果关系和相关性 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。

Commanded 中的相关性和因果关系 ID

Correlation and causation ID in Commanded

events

elixir

cqrs

event-sourcing

commanded

相关性和因果关系 ID