如何在App Engine Flex Java环境中使用Stackdriver Structured日志记录

Question

Google App
Engine灵活的环境会自动将stdout和stderr传递到Stackdriver（Google云日志）。但这仅支持纯文本日志消息，而没有任何元数据（甚至不包括日志级别）。

我找到了Google Cloud日志记录的Logback附加程序。

https://cloud.google.com/logging/docs/setup/java

但这似乎还不支持结构化日志记录。而且，它还可以对内部的每个日志条目进行GRPC调用。因此，我想知道它的可扩展性（尤其是与具有单独Fluentd代理处理日志的当前应用程序引擎结构进行比较）。

是否有任何现成的或简单的解决方案将结构化日志从App Engine发送到Stackdriver？

Answer 1

您可以使用Logback附加程序+实施 LoggingEnhacer

public class LogEnhancer implements LoggingEnhancer {


  @Override
  public void enhanceLogEntry(LogEntry.Builder logEntry) {
    // add Labels
    logEntry.addLabel("project", "conversational-services");

    // Transform textPayload to JSONPayload
    ObjectMapper mapper = new ObjectMapper();
    Builder structBuilder = Struct.newBuilder();
    String textPayload = logEntry.build().getPayload().getData().toString();
    try {
      // Validate JSON Payload
      mapper.readTree(textPayload);
      JsonFormat.parser().merge(textPayload, structBuilder);
      logEntry.setPayload(JsonPayload.of(structBuilder.build()));
    } catch (InvalidProtocolBufferException e) {
      // Error reporting an error! FML
      System.err.println(e.getMessage());
    } catch (IOException e) {
      // Do nothing (there is not a JSON Payload)
    }

  }

}

此类添加标签并在JSONPayload中转换JSON字符串

你需要指定 LoggingEnhacer 上 logback.xml 文件

<!DOCTYPE configuration>
<configuration>
  <appender name="CLOUD" class="com.google.cloud.logging.logback.LoggingAppender">

    <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
      <level>INFO</level>
    </filter>
    <log>application.log</log> 
    <resourceType>gae_app</resourceType> 
    <!--  References to the LoggingEnhacer class -->
     <enhancer>[path_for_your_logging_enhancer_class]</enhancer>
    <flushLevel>WARN</flushLevel> 
  </appender>

  <root level="info">
    <appender-ref ref="CLOUD" />
  </root>
</configuration>