Examples of com.google.appengine.api.log.LogQuery

com.google.appengine.api.log.LogQuery
opers.google.com/appengine/docs/java/runtime#The_Environment}"> the Java Servlet Environment documentation for how to retrieve these IDs at runtime. Malformed request IDs will cause an exception, while unrecognized request IDs be ignored. This option may not be combined with any filtering options such as startTime, endTime, offset, or minLogLevel. majorVersionIds and moduleVersions is ignored. IDs that do not correspond to a request log will be ignored. Logs will be returned in the order requested.
{@code batchSize} specifies the internal batching strategy of the returned{@link java.lang.Iterable Iterable<RequestLogs>}. Has no impact on the result of the query.
Notes on usage:
The recommended way to instantiate a {@code LogQuery} object is tostatically import {@link Builder}.* and invoke a static creation method followed by an instance mutator (if needed):
```
 import static com.google.appengine.api.log.LogQuery.Builder.*; ... // All requests, including application logs. iter = logService.fetch(withIncludeAppLogs(true)); // All requests ending in the past day (or still running) with an info log or higher. Calendar cal = Calendar.getInstance(); cal.add(Calendar.DAY_OF_MONTH, -1); iter = logService.fetch(withEndTimeMillis(cal.time()) .includeIncomplete(true).minimumLogLevel(LogService.INFO)); 
```

    private RequestLogs getRequestLogs1() throws EntityNotFoundException {
        return getRequestLogs(getRequest1Id());
    }


    private RequestLogs getRequestLogs(String request1Id) {
        LogQuery logQuery = new LogQuery().requestIds(Collections.singletonList(request1Id));
        Iterator<RequestLogs> iterator = findLogLine(logQuery, 2);
        if (iterator == null || !iterator.hasNext()) {
            return null;
        }
        return iterator.next();

View Full Code Here

        String infoLogMsg = "info_incompleteRequest-" + System.currentTimeMillis();
        log.info(infoLogMsg);
        flush(log);
        sync(5000);  // Yes, even after a flush we need to wait for the logs to be available.


        LogQuery debugLogQuery = new LogQuery().includeAppLogs(true).includeIncomplete(true).minLogLevel(DEBUG);
        assertLogQueryReturns("info_createCompleteRequest1", debugLogQuery);
        assertLogQueryReturns("warning_createCompleteRequest1", debugLogQuery);
        assertLogQueryReturns("severe_createCompleteRequest2", debugLogQuery);
        assertLogQueryReturns("info_createCompleteRequest3", debugLogQuery);
        assertLogQueryReturns(infoLogMsg, debugLogQuery);


        LogQuery warnLogQuery = new LogQuery().includeAppLogs(true).includeIncomplete(true).minLogLevel(WARN);
        assertLogQueryReturns("info_createCompleteRequest1", warnLogQuery);
        assertLogQueryReturns("warning_createCompleteRequest1", warnLogQuery);
        assertLogQueryReturns("severe_createCompleteRequest2", warnLogQuery);
        assertLogQueryDoesNotReturn("info_createCompleteRequest3", warnLogQuery);
        assertLogQueryDoesNotReturn(infoLogMsg, warnLogQuery);


        LogQuery errorLogQuery = new LogQuery().includeAppLogs(true).includeIncomplete(true).minLogLevel(ERROR);
        assertLogQueryReturns("severe_createCompleteRequest2", errorLogQuery);
        assertLogQueryDoesNotReturn("info_createCompleteRequest1", errorLogQuery);
        assertLogQueryDoesNotReturn("warning_createCompleteRequest1", errorLogQuery);
        assertLogQueryDoesNotReturn("info_createCompleteRequest3", errorLogQuery);
        assertLogQueryDoesNotReturn(infoLogMsg, errorLogQuery);

View Full Code Here

        String infoLogMsg = "info_incompleteRequest-" + System.currentTimeMillis();
        log.info(infoLogMsg);
        flush(log);
        sync(5000);  // Yes, even after a flush we need to wait for the logs to be available.


        assertLogQueryReturns(infoLogMsg, new LogQuery().includeAppLogs(true).includeIncomplete(true));


        assertLogQueryReturns("info_createCompleteRequest1", new LogQuery().includeAppLogs(true).includeIncomplete(true));
        assertLogQueryDoesNotReturn(infoLogMsg, new LogQuery().includeAppLogs(true)
            .includeIncomplete(false).startTimeMillis(System.currentTimeMillis() - 60000));
    }

View Full Code Here

    @Test
    @InSequence(20)
    public void testRequestIds() throws Exception {
        LogService service = LogServiceFactory.getLogService();


        LogQuery logQuery = new LogQuery().requestIds(Arrays.asList(request1Id, request2Id));
        Iterator<RequestLogs> iterator = service.fetch(logQuery).iterator();
        assertEquals(request1Id, iterator.next().getRequestId());
        assertEquals(request2Id, iterator.next().getRequestId());
        assertFalse(iterator.hasNext());


        logQuery = new LogQuery().requestIds(Arrays.asList(request2Id));
        iterator = service.fetch(logQuery).iterator();
        assertEquals(request2Id, iterator.next().getRequestId());
        assertFalse(iterator.hasNext());
    }

View Full Code Here

    @Test
    @InSequence(20)
    public void testGetBatchSize() throws Exception {
        long size = 1;
        LogService service = LogServiceFactory.getLogService();
        LogQuery logQuery = new LogQuery().requestIds(Arrays.asList(request1Id, request2Id)).batchSize((int)size);


        Iterator<RequestLogs> iterator = service.fetch(logQuery).iterator();
        assertNotNull(iterator.next());
        // TODO: renable when expected behavior is confirmed.
//        assertFalse("Batch size 1 so there should not be another log", iterator.hasNext());
        long batchSize = logQuery.getBatchSize();
        assertEquals(size, batchSize);
    }

View Full Code Here

    public void testGetters() throws Exception {
        long batchSize = 20;
        long startMilliTime = System.currentTimeMillis() - 3000L;
        long endMilliTime = System.currentTimeMillis() - 2000L;
        List<String> majorVersions = Arrays.asList("1", "2", "3");
        LogQuery logQuery =  new LogQuery()
            .batchSize((int) batchSize)
            .startTimeMillis(startMilliTime)
            .endTimeMillis(endMilliTime)
            .minLogLevel(LogService.LogLevel.WARN)
            .includeIncomplete(true)
            .includeAppLogs(true)
            .offset(null)
            .majorVersionIds(majorVersions);


        executeQuery(logQuery);


        // The LogQuery should be unmodified, so you can re-use.
        assertEquals(batchSize, (long)logQuery.getBatchSize());
        assertEquals(startMilliTime, (long)logQuery.getStartTimeMillis());
        assertEquals(startMilliTime * 1000, (long)logQuery.getStartTimeUsec());
        assertEquals(endMilliTime, (long)logQuery.getEndTimeMillis());
        assertEquals(endMilliTime * 1000, (long)logQuery.getEndTimeUsec());
        assertEquals(LogService.LogLevel.WARN, logQuery.getMinLogLevel());
        assertEquals(true, logQuery.getIncludeIncomplete());
        assertEquals(true, logQuery.getIncludeAppLogs());
        assertEquals(null, logQuery.getOffset());
        assertEquals(majorVersions, logQuery.getMajorVersionIds());
        assertEquals(new ArrayList<String>(), logQuery.getRequestIds());


        List<LogQuery.Version> versions = Arrays.asList(new LogQuery.Version("module1", "1"), new LogQuery.Version("module2", "3"));
        logQuery =  new LogQuery()
            .versions(versions)
            .startTimeMillis(startMilliTime);


        executeQuery(logQuery);


        assertEquals(versions, logQuery.getVersions());
    }

View Full Code Here

        }
        return false;
    }


    protected AppLogLine findLogLineContaining(String text, int retryMax) {
        LogQuery logQuery = new LogQuery()
            .includeAppLogs(true)
            .includeIncomplete(true)
                // Not specifying start time causes test to time out since it searches
                // all the logs.
            .startTimeMillis(System.currentTimeMillis() - (20 * 1000));

View Full Code Here

0 1

TOP

Related Classes of com.google.appengine.api.log.LogQuery

com.google.appengine.tck.logservice.LoggingTest

com.google.appengine.tck.logservice.LoggingTestBase

com.google.appengine.tck.logservice.LogQueryTest

com.google.appengine.tck.logservice.LogServiceTest

com.google.appengine.tck.logservice.RequestLogsTest

com.google.appengine.tools.mapreduce.impl.shardedjob.ShardedJobRunner

com.google.appengine.tools.mapreduce.inputs.LogInput

com.google.appengine.tools.mapreduce.inputs.LogInputReaderTest

com.google.appengine.tools.mapreduce.inputs.LogInputTest

com.streak.logging.analysis.LogExportDirectToBigqueryTask

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.