サービスファブリックアクターとサービスの相関トークン

Question

マイクロサービスプラットフォームとしてService Fabricを使用し始め、アクターパターン、ステートレス/ステートフルサービス、Web API（その他）に関する最初の "hello world"サンプルを正常に実装した後、 auth/autzやアプリケーションのロギングなどの他のコア・アスペクトに対するソリューションを探しています。

私はロギングについて疑問を持っています。私たちが今まで設計してきたすべてのSOAにおいて、関連するすべてのサービスに「相関トークン」を追加しました（しばしばアーキテクチャーレベルで、WCF上にヘッダーとして自動的に追加され、開発者に隠されています）ので、サービスファブリックを使用します。

すべてのアクター/サービスコールを通じてフローに「相関トークン」を提供する最適なソリューションを探しています。すぐに使えるものは何も見つけられていないため、探しているかどうかは疑問です理論的には間違っている

何か提案がありますか？

Answer 1

serilogとseqを使用して多くの成功を収め、ログメッセージにプロパティを追加するためにエンリッチャーを使用しました。

私のサービスでは、ServiceLogger.CreateLogger（this）を呼び出して、サービスに関するすべての状態を豊かにしたログを取得します。相関トークンが必要な場合は、それを比較的簡単に追加できるはずですが、それはまだ私が行ったことではありません。

私は以下の関連コードをコピーしたと思います！ @

public class ServiceFabricEnricher<T> : ILogEventEnricher where T : ServiceContext 
{ 
    protected T Context { get; } 
    private LogEventProperty _nodeName; 

    public ServiceFabricEnricher(T context) 
    { 
     Context = context; 
    } 

    public virtual void Enrich(LogEvent logEvent, ILogEventPropertyFactory propertyFactory) 
    { 
     if (_nodeName == null) _nodeName = propertyFactory.CreateProperty("NodeName", Context.NodeContext.NodeName); 
     logEvent.AddPropertyIfAbsent(_nodeName); 
    } 
} 


public class ServiceEnricher<T> : ServiceFabricEnricher<T> where T : ServiceContext 
{ 
    private LogEventProperty _serviceName; 
    private LogEventProperty _partitionId; 
    private LogEventProperty _applicationName; 

    public ServiceEnricher(T context) : base(context) 
    { 
    } 

    public override void Enrich(LogEvent logEvent, ILogEventPropertyFactory propertyFactory) 
    { 
     base.Enrich(logEvent, propertyFactory); 

     if (_serviceName == null) _serviceName = propertyFactory.CreateProperty("ServiceName", Context.ServiceName); 
     if (_partitionId == null) _partitionId = propertyFactory.CreateProperty("PartitionId", Context.PartitionId); 
     if (_applicationName == null) _applicationName = propertyFactory.CreateProperty("ApplicationName", Context.CodePackageActivationContext.ApplicationName); 

     logEvent.AddPropertyIfAbsent(_serviceName); 
     logEvent.AddPropertyIfAbsent(_partitionId); 
     logEvent.AddPropertyIfAbsent(_applicationName); 
    } 
} 

public static class ServiceFabricLogger 
{ 
    private static ILogger CreaterDefaultLogger() 
    { 
     var configurationProvider = new FabricConfigurationProvider("SeqConfig"); 

     var loggerConfiguration = new LoggerConfiguration(); 
     if (configurationProvider.HasConfiguration) 
     { 
      var seqServer = configurationProvider.GetValue("SeqServer"); 
      loggerConfiguration = 
       loggerConfiguration 
       .WriteTo.Seq(seqServer, period: TimeSpan.FromMilliseconds(500)) 
       ; 

      var level = configurationProvider.GetValue("MinimumLevel"); 
      LogEventLevel minimumLevel; 
      if (!string.IsNullOrWhiteSpace(level) && Enum.TryParse<LogEventLevel>(level, true, out minimumLevel)) 
      { 
       loggerConfiguration = loggerConfiguration.MinimumLevel.Is(minimumLevel); 
      } 
     } 
     else 
     { 
      loggerConfiguration = 
       loggerConfiguration 
       .MinimumLevel.Error() 
       ; 
     } 

     Log.Logger = loggerConfiguration.CreateLogger(); 
     return Log.Logger; 
    } 

    public static ILogger Logger { get; } = CreaterDefaultLogger(); 
} 

public static class ServiceLogger 
{ 
    public static ILogger CreateLogger(this StatefulServiceBase service) => 
     ServiceFabricLogger.Logger.ForContext(new[] { new StatefulServiceEnricher(service.Context) }); 

    public static ILogger CreateLogger(this StatelessService service) => 
     ServiceFabricLogger.Logger.ForContext(new[] { new StatelessServiceEnricher(service.Context) }); 
}