2016-05-02 60 views
1

我想POST将日志记录到Stackdriver的“自定义日志”。这些功能是测试版,可能因此没有说明,因此如何在App Engine上使用Logging with Java API。无论如何,我想说明我的问题:我使用这个API版本:Google App Engine。为Stackdriver。使用Java记录

"com.google.apis:google-api-services-logging:v2beta1-rev10-1.21.0" 

所以,首先我建的日志对象像这样(我希望这是正确的):

public static Logging createAuthorizedClient() throws IOException { 
    // Create the credential 
    HttpTransport transport = new NetHttpTransport(); 
    JsonFactory jsonFactory = new JacksonFactory(); 
    GoogleCredential credential = GoogleCredential.getApplicationDefault(transport, jsonFactory); 

    if (credential.createScopedRequired()) { 
     credential = credential.createScoped(LoggingScopes.all()); 
    } 

    return new Logging.Builder(transport, jsonFactory, credential).setApplicationName(SharedConstants.APPLICATION_ID).build(); 
} 

我拿到后登录客户端,我试图推动一个条目记录:

LogEntry lEntry = new LogEntry(); 
    lEntry.setTextPayload("I want to see this log!"); 

    WriteLogEntriesRequest writeLogEntriesRequest = new WriteLogEntriesRequest(); 

    writeLogEntriesRequest.setLogName("My Super log"); 
    List<LogEntry> listEntries = new ArrayList<>(); 
    listEntries.add(lEntry); 

    writeLogEntriesRequest.setEntries(listEntries); 

    Logging logging = LoggingManager.createAuthorizedClient(); 
    Write write = logging.entries().write(writeLogEntriesRequest); 
    WriteLogEntriesResponse writeLogResponse = write.execute(); 

但我得到的是:

com.google.api.client.googleapis.json.GoogleJsonResponseException: 400 OK 
{ 
    "code" : 400, 
    "errors" : [ { 
    "domain" : "global", 
    "message" : "Invalid resource id", 
    "reason" : "badRequest" 
    } ], 
    "message" : "Invalid resource id", 
    "status" : "INVALID_ARGUMENT" 
} 

===更新:工作解决方案===

感谢mshamma。下面是完整的代码,如何将数据发送到日志:

public boolean send() { 
     WriteLogEntriesResponse response = null; 
     try { 
      final String now = getNowUtc(); 
      final String insertId = "entry-at-" + now; 
      final Map<String, String> labels = ImmutableMap.of("project_id", SharedConstants.APPLICATION_ID, "name", 
        "projects/" + SharedConstants.APPLICATION_ID + "/logs/" + this.logName); 

      Logging service = createAuthorizedClient(); 
      MonitoredResource ressource = new MonitoredResource(); 
      ressource.setType("logging_log"); 
      ressource.setLabels(labels); 

      LogEntry entry = new LogEntry().setInsertId(insertId).setResource(ressource).setTimestamp(now) 
        .setJsonPayload(this.entriesMap) 
        .setLogName("projects/" + SharedConstants.APPLICATION_ID + "/logs/" + this.logName) 
        .setSeverity(this.severity); 
      WriteLogEntriesRequest content = (new WriteLogEntriesRequest()) 
        .setEntries(Collections.singletonList(entry)); 
      response = service.entries().write(content).execute(); 
     } catch (Exception e) { 
     } 
     return response != null; 
    } 

    private static String getNowUtc() { 
     SimpleDateFormat dateFormatUtc = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'"); 
     dateFormatUtc.setTimeZone(TimeZone.getTimeZone("UTC")); 
     return dateFormatUtc.format(new Date()); 
    } 

此代码工作正常日志记录API的最新版本

由此,EntriesMap是:

private Map<String, Object> entriesMap; 

回答

1

我跑到非托管Python环境中的相同问题。我得到的东西工作,我可以看到你的代码中至少有两个问题。

  1. 日志名称需要遵循的模式: “项目/ <项目编号> /日志/ <登录ID >”。请参阅此处的文档:https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/LogEntry#SCHEMA_REPRESENTATION

  2. 应该为日志条目(lEntry)和写入日志条目请求(writeLogEntriesRequest)添加资源描述符。在GAE的情况下,资源类型字段应设置为“gae_app”,并且您必须向资源添加三个用于标识GAE部署的标签:“project_id”,“module_id”和“version_id”。

我希望这将有助于解决您的问题!