如何查询存储在SQL Persistence表中的Sagas

如何解决如何查询存储在SQL Persistence表中的Sagas

我需要查询Saga Data类的属性以获取列表。它作为序列化对象存储在sqlPersistance表[Data]列中。 考虑一下我的SagaData具有名为UserName的属性的情况，因此我想查询与该用户相关的每个saga。 通过草率的方式，我可以查询列内容，获取列表，并可以通过以下方式从内容中创建Saga对象：

SELECT [Id],[Correlation_TaskId],[Metadata],[Data],[PersistenceVersion],[SagaTypeVersion],[Concurrency]
  FROM [myWonderfulDb].[dbo].[MyWonderfulPeristanceTable]
  where JSON_VALUE(Data,'$.Username') = 'arthur' 

但是我正在寻找一种可能使用NserviceBus API的优雅方法。 在ParticularSoftware文档（链接：https://docs.particular.net/persistence/sql/saga-finder）中描述了一个SagaFinder实现，但这仅返回一个对象，该对象并不完全适合我的情况。

在文档中如何实现它：

class sqlServerSagaFinder :
    IFindSagas<MySagaData>.Using<MyMessage>
{
    public Task<MySagaData> FindBy(MyMessage message,SynchronizedStorageSession session,ReadOnlyContextBag context)
    {
        return session.GetSagaData<MySagaData>(
            context: context,whereClause: "JSON_VALUE(Data,'$.PropertyPathInjson') = @propertyValue",appendParameters: (builder,append) =>
            {
                var parameter = builder();
                parameter.ParameterName = "propertyValue";
                parameter.Value = message.PropertyValue;
                append(parameter);
            });
    }
}

任何想法都值得赞赏。谢谢！

解决方法

有关查询传奇状态的指南，请访问

https://docs.particular.net/nservicebus/sagas/#querying-saga-data

简而言之，您可以查询Saga数据，因此NServiceBus没有开箱即用的方式，因为我们建议改用其他方法：

要发布包含所需数据的事件并具有处理程序来处理这些事件并将其存储在一个或多个读取模型中以进行查询的传说。

在我们看来，我们不建议这样做的主要要点是

• 通过在传奇中将数据暴露在业务逻辑的保护范围之外，可能会导致以下风险：未将数据视为 只读。最终，组件尝试绕过传奇， 直接修改数据。
• 查询数据可能需要其他索引，资源等，这些索引，资源等需要由发出查询的组件来管理。 这些额外的资源可能会影响英雄传奇的表现。

,

SagaFinder 的唯一目的是查找与传入消息相关联的某个saga的单个实例。我不知道用于查询传奇（数据）实例的任何框架功能。