ElasticSearchLoggingWriter.cs 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. using Microsoft.Extensions.Logging;
  2. using Nest;
  3. using LogLevel = Microsoft.Extensions.Logging.LogLevel;
  4. namespace Admin.NET.Core;
  5. /// <summary>
  6. /// ES日志写入器
  7. /// </summary>
  8. public class ElasticSearchLoggingWriter : IDatabaseLoggingWriter
  9. {
  10. private readonly ElasticClient _esClient;
  11. public ElasticSearchLoggingWriter(ElasticClient esClient)
  12. {
  13. _esClient = esClient;
  14. }
  15. public void Write(LogMessage logMsg, bool flush)
  16. {
  17. _esClient.IndexDocument(new LogContent
  18. {
  19. Time = DateTime.Now,
  20. LogLevel = logMsg.LogLevel,
  21. LogName = logMsg.LogName,
  22. EventId = logMsg.EventId,
  23. Message = logMsg.Message,
  24. Exception = logMsg.Exception
  25. });
  26. }
  27. }
  28. /// <summary>
  29. /// 日志内容
  30. /// </summary>
  31. public class LogContent
  32. {
  33. /// <summary>
  34. /// 记录器类别名称
  35. /// </summary>
  36. public string LogName { get; set; }
  37. /// <summary>
  38. /// 日志级别
  39. /// </summary>
  40. public LogLevel LogLevel { get; set; }
  41. /// <summary>
  42. /// 事件 Id
  43. /// </summary>
  44. public EventId EventId { get; set; }
  45. /// <summary>
  46. /// 异常对象
  47. /// </summary>
  48. public Exception Exception { get; set; }
  49. /// <summary>
  50. /// 日志上下文
  51. /// </summary>
  52. public LogContext Context { get; set; }
  53. /// <summary>
  54. /// 日志消息
  55. /// </summary>
  56. public string Message { get; internal set; }
  57. /// <summary>
  58. /// 日志时间
  59. /// </summary>
  60. public DateTime Time { get; internal set; }
  61. }