YT-24500: Introduce structured logging

commit_hash:e6ea4db1e3a66694223008fec3b5064a4d58a8e1

1 files changed, 14 insertions, 0 deletions

diff --git a/yt/cpp/mapreduce/client/init.cpp b/yt/cpp/mapreduce/client/init.cpp
index 2a4e8730309..9e49f2df685 100644
--- a/yt/cpp/mapreduce/client/init.cpp
+++ b/yt/cpp/mapreduce/client/init.cpp
@@ -10,6 +10,7 @@
 #include <yt/cpp/mapreduce/interface/operation.h>
 
 #include <yt/cpp/mapreduce/interface/logging/logger.h>
+#include <yt/cpp/mapreduce/interface/logging/structured.h>
 #include <yt/cpp/mapreduce/interface/logging/yt_log.h>
 
 #include <yt/cpp/mapreduce/io/job_reader.h>
@@ -184,10 +185,17 @@ void CommonInitialize(TGuard<TMutex>& g)
             if (!NLogging::TLogManager::Get()->IsDefaultConfigured()) {
                 return;
             }
+
             auto coreLoggingConfig = NLogging::TLogManagerConfig::CreateStderrLogger(ToCoreLogLevel(logLevel));
             for (const auto& rule : coreLoggingConfig->Rules) {
                 rule->ExcludeCategories = TConfig::Get()->LogExcludeCategories;
             }
+
+            if (auto structuredLogPath = TConfig::Get()->StructuredLog) {
+                InitializeStructuredLogging(coreLoggingConfig, structuredLogPath);
+                RegisterStructuredLogWriterFactory();
+            }
+
             NLogging::TLogManager::Get()->Configure(coreLoggingConfig);
         } else {
             auto logger = CreateStdErrLogger(logLevel);
@@ -198,6 +206,12 @@ void CommonInitialize(TGuard<TMutex>& g)
         for (const auto& rule : coreLoggingConfig->Rules) {
             rule->ExcludeCategories = TConfig::Get()->LogExcludeCategories;
         }
+
+        if (auto structuredLogPath = TConfig::Get()->StructuredLog) {
+            InitializeStructuredLogging(coreLoggingConfig, structuredLogPath);
+            RegisterStructuredLogWriterFactory();
+        }
+
         NLogging::TLogManager::Get()->Configure(coreLoggingConfig);
         SetUseCoreLog();
     }