我希望能够使用我的日志通过Hangfires context.console发出事件,所以我不需要使用context.writeline将日志事件输出到我的hangfire仪表板。
我试图为此目的实现一个特定的serilog接收器。但是由于需要hangfire的PerformContext(在运行时注入(inject)到task方法中),因此无法在应用程序启动时配置日志接收器。我试图在task方法中创建一个新的记录器,只是为了查看接收器是否真正起作用,而不能-有人可以看到为什么它不起作用,或者可以建议其他方法吗?
这是水槽:
class HangfireContextSink : ILogEventSink {
private readonly IFormatProvider formatProvider;
private readonly PerformContext context;
public HangfireContextSink(IFormatProvider formatProvider, PerformContext context) {
this.formatProvider = formatProvider;
this.context = context;
}
public void Emit(LogEvent logEvent) {
var message = logEvent.RenderMessage(formatProvider);
context.WriteLine(ConsoleTextColor.Blue, DateTimeOffset.Now.ToString() + " " + message);
}
接收器配置:
public static class SinkExtensions {
public static LoggerConfiguration HangfireContextSink(this LoggerSinkConfiguration loggerSinkConfiguration, PerformContext context, IFormatProvider formatProvider = null) {
return loggerSinkConfiguration.Sink(new HangfireContextSink(formatProvider, context));
}
}
任务方法:
public static bool TestJob(PerformContext context) {
using (LogContext.PushProperty("Hangfirejob", "TestJob")) {
try {
using (var hangfireLog = new LoggerConfiguration().WriteTo.HangfireContextSink(context).CreateLogger()) {
var progress = context.WriteProgressBar("Progress");
for (int i = 0; i < 10; i++) {
context.WriteLine("Working with {0}", i);
progress.SetValue((i + 1) * 10);
Log.Debug("Test serilog");
hangfireLog.Debug("Test from hangfirelog");
Thread.Sleep(5000);
}
}
Log.Debug("Done testjob");
return true;
} catch (Exception ex) {
Log.Error(ex, "Error!");
return false;
}
}
}
最佳答案
消息不会记录到Hangfire控制台,因为您使用Debug
日志级别记录了消息,而默认的Serilog级别是Information
。您可以通过调用.MinimumLevel.Debug()
上的LoggerConfiguration
来更改日志记录级别。同样,为了通过Serilog.Log
静态类记录消息,您还应该设置其Logger
属性。
这是将记录到Hangfire控制台的固定代码:
using (LogContext.PushProperty("Hangfirejob", "TestJob"))
{
try
{
using (var hangfireLog = new LoggerConfiguration().MinimumLevel.Debug().WriteTo.HangfireContextSink(context).CreateLogger())
{
// This is a dirty code that will be removed in final solution
var prevLogger = Log.Logger;
Log.Logger = hangfireLog;
var progress = context.WriteProgressBar("Progress");
for (int i = 0; i < 10; i++)
{
context.WriteLine("Working with {0}", i);
progress.SetValue((i + 1) * 10);
Log.Debug("Test serilog");
hangfireLog.Debug("Test from hangfirelog");
Thread.Sleep(5000);
}
Log.Debug("Done testjob");
Log.Logger = prevLogger;
}
return true;
}
catch (Exception ex)
{
Log.Error(ex, "Error!");
return false;
}
}
这将起作用,但是为每个作业创建新日志的整体方法非常糟糕。您可以通过将
PerformContext
实例通过LogEvent
中的属性传递来避免这种情况。您应该定义一个自定义属性类,该类派生自抽象的LogEventPropertyValue
并公开PerformContext
的实例。这是最终代码:
PerformContextProperty.cs:
public class PerformContextProperty : LogEventPropertyValue
{
public PerformContext PerformContext { get; }
public PerformContextProperty(PerformContext performContext)
{
PerformContext = performContext;
}
public override void Render(TextWriter output, string format = null, IFormatProvider formatProvider = null)
{
}
}
PerformContextEnricher.cs:
public class PerformContextEnricher : ILogEventEnricher
{
private readonly PerformContext performContext;
public PerformContextEnricher(PerformContext performContext)
{
this.performContext = performContext;
}
public void Enrich(LogEvent logEvent, ILogEventPropertyFactory propertyFactory)
{
logEvent.AddPropertyIfAbsent(new LogEventProperty(HangfireContextSink.PerformContextProperty, new PerformContextProperty(performContext)));
}
}
TestJob.cs:
public class TestJob
{
public static bool Execute(PerformContext context)
{
using (LogContext.PushProperty("Hangfirejob", "TestJob"))
using (LogContext.Push(new PerformContextEnricher(context)))
{
try
{
var progress = context.WriteProgressBar("Progress");
for (int i = 0; i < 10; i++)
{
context.WriteLine("Working with {0}", i);
progress.SetValue((i + 1) * 10);
Log.Debug("Test serilog", context);
Log.Debug("Test from hangfirelog");
Thread.Sleep(5000);
}
Log.Debug("Done testjob");
return true;
}
catch (Exception ex)
{
Log.Error(ex, "Error!");
return false;
}
}
}
}
HangfireContextSink.cs:
class HangfireContextSink : ILogEventSink
{
public const string PerformContextProperty = "PerformContext";
private readonly IFormatProvider formatProvider;
public HangfireContextSink(IFormatProvider formatProvider)
{
this.formatProvider = formatProvider;
}
public void Emit(LogEvent logEvent)
{
var message = logEvent.RenderMessage(formatProvider);
LogEventPropertyValue propertyValue;
if (logEvent.Properties.TryGetValue(PerformContextProperty, out propertyValue))
{
var context = (propertyValue as PerformContextProperty)?.PerformContext;
context?.WriteLine(ConsoleTextColor.Green, DateTimeOffset.Now + " " + message);
}
}
}
SinkExtensions.cs:
public static class SinkExtensions
{
public static LoggerConfiguration HangfireContextSink(this LoggerSinkConfiguration loggerSinkConfiguration, IFormatProvider formatProvider = null)
{
return loggerSinkConfiguration.Sink(new HangfireContextSink(formatProvider));
}
}
Serilog配置:
Log.Logger = new LoggerConfiguration()
.Enrich.FromLogContext()
.MinimumLevel.Debug()
.WriteTo.HangfireContextSink()
.CreateLogger();
在Serilog配置中,请不要忘记调用
.Enrich.FromLogContext()
,以便日志事件中包含LogContext
中的属性。上面的代码非常简单,这就是为什么我不对其进行详细评论的原因。如果您对代码有任何疑问,请询问,我将尝试解释不清楚的时刻。
关于.net - Serilog输出到hangfire上下文控制台,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/49131101/