使用Serilog将日志记录到ElasticSearch不起作用。

Question

我想将日志发送到ElasticSearch并在Kibana中查看它们。但由于某些奇怪的原因，它无法正常工作：项目正在执行某些操作，但是在Kibana中没有任何内容。我下载并尝试了与此主题相关的超过10个项目，尽管它们被介绍为有效的样本，但它们都没有完成任务：在Kibana中没有任何内容！

这里我发布其中一个示例项目的源代码：

public class Startup
{
    public Startup(IConfiguration configuration)
    {
        // Create Serilog Elasticsearch logger
        Log.Logger = new LoggerConfiguration()
           .Enrich.FromLogContext()
           .MinimumLevel.Information() //debug
           .WriteTo.Elasticsearch().WriteTo.Elasticsearch(new ElasticsearchSinkOptions(new Uri("http://localhost:9200"))
           {
               MinimumLogEventLevel = LogEventLevel.Verbose,
               AutoRegisterTemplate = true
           })
           .CreateLogger();

        Configuration = configuration;
    }

    public IConfiguration Configuration { get; }

    // This method gets called by the runtime. Use this method to add services to the container.
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddLogging(loggingBuilder => loggingBuilder.AddSerilog(dispose: true));
        services.AddMvc();
    }

    // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.

    public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
    {
        loggerFactory.AddConsole(Configuration.GetSection("Logging"));
        loggerFactory.AddDebug();


        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }
        else
        {
            app.UseExceptionHandler("/Home/Error");
        }

        app.UseStaticFiles();

        app.UseMvc(routes =>
        {
            routes.MapRoute(
                name: "default",
                template: "{controller=Home}/{action=Index}/{id?}");
        });


    }
}

这是控制器(Controller)：

public IActionResult Index()
{
    _logger.LogInformation("Hello world!");
    return View();
}

public IActionResult About()
{
    var elasticUri = new Uri("http://localhost:9200/cmstest/obj");

    var loggerConfig = new LoggerConfiguration()
                    .WriteTo.Elasticsearch(new ElasticsearchSinkOptions(elasticUri)
                    {
                        AutoRegisterTemplate = true,
                        MinimumLogEventLevel = Serilog.Events.LogEventLevel.Verbose
                    });


    var logger = loggerConfig.CreateLogger();

    logger.Error("Hello world");
    logger.Information("Hello world");
    logger.Warning("Hello world");

    return View();
}




public IActionResult Contact()
{
    _logger.LogInformation("Hello world");

    var logger = new LoggerConfiguration()
                    .WriteTo.Elasticsearch(new ElasticsearchSinkOptions(
                    new Uri("http://localhost:9200"))
                    {
                        AutoRegisterTemplate = true
                    }).CreateLogger();

    logger.Information("Hello world");

    return View();
}

我也发现了使用log4net的示例 - 也没有生效

- J.Doe

---

你有没有问过Elasticsearch sink的开发人员，他们应该能够帮助你。如果你正在运行Logstash，可以尝试使用Serilog HTTP插件。这里还有一个展示Serilog和Elastic Stack的示例：https://github.com/FantasticFiasco/serilog-sinks-http-elastic-stack - FantasticFiasco

尝试添加 Serilog.Debugging.SelfLog.Enable(message => Console.WriteLine(message)); 以将Serilog错误输出到控制台。默认情况下，ES Sink会将任何问题报告给SelfLog。https://github.com/serilog/serilog-sinks-elasticsearch#handling-errors - Justus Burger

你解决了吗？我遇到了类似的问题。 - Green

请查看我对类似问题的回答。 - Christian Davén

谢谢@ChristianDavén-是的，设置了那个，但还是不起作用。文件记录和控制台记录都没有问题... - bbqchickenrobot

我在使用Sink版本时出现了问题，将其降级以匹配ES的版本后问题得到了解决。 - gdp

Answer 1

通过处理失败回调事件，您可以控制台记录响应

.WriteTo.Elasticsearch(new ElasticsearchSinkOptions(new Uri("http://localhost:9200"))
                {
                    FailureCallback = e => Console.WriteLine("Unable to submit event " + e.MessageTemplate),
                    EmitEventFailure = EmitEventFailureHandling.WriteToSelfLog |
                                       EmitEventFailureHandling.WriteToFailureSink |
                                       EmitEventFailureHandling.RaiseCallback,
                    FailureSink = new FileSink("./failures.txt", new JsonFormatter(), null)
                })

更多信息请访问https://github.com/serilog/serilog-sinks-elasticsearch#handling-errors

另外，对于 EmitEventFailureHandling.WriteToSelfLog，您需要在 startup.cs 文件中启用它。

Serilog.Debugging.SelfLog.Enable(Console.WriteLine);

以上代码会把错误日志记录在控制台中

- Niraj Trivedi

Answer 2

ELK v.8最新版 添加选项 批量操作=ElasticOpType.Create， 类型名称=null，

返回一个新的ElasticsearchSinkOptions对象，该对象包含一个指向configuration["ElasticsearchSettings:Uri"]的Uri。 {

    ModifyConnectionSettings = x => x.BasicAuthentication(configuration["ElasticsearchSettings:username"], configuration["ElasticsearchSettings:password"]),
    AutoRegisterTemplate = true,
    AutoRegisterTemplateVersion = AutoRegisterTemplateVersion.ESv7,// < --this was the magic bullet
    IndexFormat = $"{Assembly.GetExecutingAssembly().GetName().Name.ToLower()}-{env.ToLower().Replace(".", "-")}-{DateTime.UtcNow:yyyy-MM}",
    BatchAction = ElasticOpType.Create,
    TypeName = null,
    FailureCallback = e => Console.WriteLine("Unable to submit event " + e.MessageTemplate),
    EmitEventFailure = EmitEventFailureHandling.WriteToSelfLog |
                                     EmitEventFailureHandling.WriteToFailureSink |
                                     EmitEventFailureHandling.RaiseCallback,
    FailureSink = new FileSink("./failures.txt", new JsonFormatter(), null)
};

- promlert

---

目前你的回答不够清晰。请编辑并添加更多细节，以帮助其他人理解它如何回答所提出的问题。你可以在帮助中心找到有关如何撰写好答案的更多信息。 - Community