Akka (JVM) инициализирует регистратор перед ActorSystem

Question

У меня есть приложение, которому необходимо вызвать некоторую внешнюю систему (чтобы дешифровать конфиденциальную информацию, чтобы она была коротка), прежде чем создавать конфигурацию, которую будет использовать система актеров.

Возможно ли инициализировать регистратор в самом начале моего процесса, чтобы средства мониторинга/исследования могли обращаться к журналам, если связь с внешней системой идет не так?

// the following call will modify the config from a secret id read in the conf 
// and write the value "redis.password" after getting the value from an Azure Keyvault 
val updatedConf = KeyVaultHelper.decryptFromKeyVault(ConfigFactory.load("application"), 
    Map(
    "azure.keyvault.redis.password.secret-id", 
    "redis.password" 
)) 

// now we initialize the actor system with the updated conf 
// and the logging system will be initialized 
val system = ActorSystem("ClusterSystem", updatedConf) 

Answer 1

Для достижения этой цели, вы можете использовать akka-slf4j библиотеки вместе с их рекомендуемого лесозаготовительного бэкэндом logback. Необходимо настроить две вещи.

logback.xml файл, который настраивает лесоруб:

<!-- src/main/resources/logback.xml --> 
<configuration> 
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> 
    <encoder> 
     <pattern>%date{ISO8601} %-5level %logger{36} %X{sourceThread} - %msg%n</pattern> 
    </encoder> 
    </appender> 
    <root level="debug"> 
    <appender-ref ref="STDOUT" /> 
    </root> 
</configuration> 

SLF4J регистратор должны быть сконфигурирован из типизированной конфигурации, а также:

# src/main/resources/application.conf 
akka { 
    loggers = ["akka.event.slf4j.Slf4jLogger"] 
    loglevel = "DEBUG" 
    logging-filter = "akka.event.slf4j.Slf4jLoggingFilter" 
} 

Пожалуйста, см дуют образец кода, чтобы проверить конфигурацию.

object LoggingTest extends App { 
    // Do all decryption logging here 
    val logger = LoggerFactory.getLogger(getClass) 
    logger.debug("Starting application. Decrypting info from config") 

    // Now you boot the system which will use the same logging config 
    val system = ActorSystem() 
    val actor = system.actorOf(Props[Echo]) 

    actor ! "hello" 
} 

class Echo extends Actor { 
    override def receive: Receive = { 
    case message => 
     context.system.log.debug(s"echo $message") 
    } 
} 

Я использовал следующий akka-actor & akka-slf4j 2.4.17 и ch.qos.logback 1.1.3.

Дайте мне знать, если у вас есть еще вопросы.