在运行时添加Sentry Log4j2附加器

我一直在浏览以前关于在运行时添加Log4j 2附加器的线程，但似乎没有一个真正适合我的场景。
我们将一个长时间运行的Flink作业打包到一个FAT jar文件中，并将其提交给一个正在运行的Flink集群。我们希望将错误日志转发给Sentry。Sentry提供了一个我希望能够使用的Log4j2 appender，但所有尝试让Log4j 2工作的尝试都失败了--为此有点疯狂（花了几天时间）。
由于Flink（也使用log4j 2）提供了一组默认的日志记录配置，它优先于我们捆绑在jar中的任何配置文件;我基本上只剩下尝试在运行时配置appender，看看这是否会使它注册appender并将LogEvent转发给它。

附带说明：我试图覆盖Flink提供的配置文件（实际上是将appender直接添加到Log4j2.properties文件中），但是Flink无法加载插件，因为缺少依赖项-io.sentry.IHub-这没有意义，因为所有的examples/sentry文档都没有提到log4j相关依赖项之外的任何其他依赖项，这些依赖项已经存在于类路径中。

我遵循了log4j文档中的示例：Programmatically Modifying the Current Configuration after Initialization，但日志无法传送到Sentry。

发送日志4j.scala

package com.REDACTED.thoros.config

import io.sentry.log4j2.SentryAppender
import org.apache.logging.log4j.Level
import org.apache.logging.log4j.LogManager
import org.apache.logging.log4j.core.LoggerContext
import org.apache.logging.log4j.core.config.AppenderRef
import org.apache.logging.log4j.core.config.Configuration
import org.apache.logging.log4j.core.config.LoggerConfig

object SentryLog4j2 {
 val SENTRY_LOGGER_NAME = "Sentry"
 val SENTRY_BREADCRUMBS_LEVEL: Level = Level.ALL
 val SENTRY_MINIMUM_EVENT_LEVEL: Level = Level.ERROR
 val SENTRY_DSN =
   "REDACTED"

 def init(): Unit = {
   // scalafix:off
   val loggerContext: LoggerContext =
     LogManager.getContext(false).asInstanceOf[LoggerContext]
   val configuration: Configuration = loggerContext.getConfiguration

   val sentryAppender: SentryAppender = SentryAppender.createAppender(
     SENTRY_LOGGER_NAME,
     SENTRY_BREADCRUMBS_LEVEL,
     SENTRY_MINIMUM_EVENT_LEVEL,
     SENTRY_DSN,
     false,
     null
   )
   sentryAppender.start()
   configuration.addAppender(sentryAppender)
   // Creating a new dedicated logger for Sentry
   val ref: AppenderRef =
     AppenderRef.createAppenderRef("Sentry", null, null)
   val refs: Array[AppenderRef] = Array(ref)
   val loggerConfig: LoggerConfig = LoggerConfig.createLogger(
     false,
     Level.ERROR,
     "org.apache.logging.log4j",
     "true",
     refs,
     null,
     configuration,
     null
   )
   loggerConfig.addAppender(sentryAppender, null, null)
   configuration.addLogger("org.apache.logging.log4j", loggerConfig)
   println(configuration.getAppenders)
   loggerContext.updateLoggers()
   // scalafix:on
 }
}

然后调用Main模块中的SentryLog4j.init（）。

import org.apache.logging.log4j.LogManager
import org.apache.logging.log4j.Logger
import org.apache.logging.log4j.core.LoggerContext
import org.apache.logging.log4j.core.config.Configuration

object Main {
  val logger: Logger = LogManager.getLogger()
  sys.env.get("ENVIRONMENT") match {
    case Some("dev") | Some("staging") | Some("production") =>
      SentryLog4j2.init()
    case _ => SentryLog4j2.init() // <-- this was only added during debugging
  }

    def main(args: Array[String]): Unit = {
       logger.error("test") // this does not forward the logevent to the appender
    }
}

我想我需要以某种方式将附加器注册到rootLogger使用的loggerConfig，以便所有logger.error语句都传播到配置的Sentry附加器。
非常感谢与此的任何指导！

虽然这不是如何让log4j 2和SentryAppender工作的答案。对于遇到这个问题的其他人，我将简要地解释一下我是如何让sentry集成工作的。我最终决定放弃使用SentryAppender，而使用原始的sentry客户机。添加一个 Package 类，公开典型的debug、infowarn和error方法。然后对于warn+方法，我还将向Sentry发送日志事件。
这基本上是我在Flink集群中实现此功能的唯一方法。
请参见以下示例：

sealed trait LoggerLike {
  type LoggerFn = (String, Option[Object]) => Unit
  val debug: LoggerFn
  val info: LoggerFn
  val warn: LoggerFn
  val error: LoggerFn
}

trait LazyLogging {
  @transient
  protected lazy val logger: CustomLogger =
    CustomLogger.getLogger(getClass.getName, enableSentry = true)
}

final class CustomLogger(slf4JLogger: Logger) extends LoggerLike {...your implementation...}

然后，对于每个类/对象（至少是scala语言），只需扩展LazyLogging特征以获得一个logger示例。

在运行时添加Sentry Log4j2附加器

1条答案

相关问题

热门标签

最新问答