A&SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SS K r /S Qr S rS rS SS\\/rSS/rSSjrSrSrSrSrSr"SS\5rg )z9General formatting utils, App Engine specific formatters.)absolute_import)division)unicode_literals)util)log) resources)timesN)criticalerrorwarninginfodebuganyz nginx.request request_logstderrstdoutz crash.logz&appengine.googleapis.com/nginx.requestz+appengine.googleapis.com/nginx.health_checkc6S/nU(a URSRU55 U(a URSRU55 US:wa.URSRUR555 /n[U5H<nURSRU55 US;dM+URU5 M> [R R USS 9R5nUR[Xh55 U$) aYReturns filters for App Engine app logs. Args: project: string name of project ID. log_sources: List of streams to fetch logs from. service: String name of service to fetch logs from. version: String name of version to fetch logs from. level: A string representing the severity of logs to fetch. Returns: A list of filter strings. zresource.type="gae_app"zresource.labels.module_id="{0}"z resource.labels.version_id="{0}"rz severity>={0}zappengine.googleapis.com/{0})rrzappengine.projects) collection) appendformatuppersortedrREGISTRYParse RelativeName_LogFilterForIds) project log_sourcesserviceversionlevelfilterslog_idslog_typeress +lib/googlecloudsdk/api_lib/app/logs_util.py GetFiltersr'(s' ''  NN4;;GDE  NN5<UR (a![R"UR 5nO UR n[U5up#SRUUUS9$)zApp Engine formatter for `LogPrinter`. Args: entry: A log entry message emitted from the V2 API client. Returns: A string representing the entry or None if there was no text payload. gae_appNz{service}[{version}] {text})rr text) resourcetype protoPayloadsix text_type jsonPayload textPayload_ExtractServiceAndVersionr)entryr3rr s r&FormatAppEntryr=Us ^^I%   ==++ ,D  ==** +D   D.u5' ' . .w7>48 / ::r(c0^TRRS:wag[R"TR5nUS:wag[ T5up#U4SjnU4SjnSR U"S5U"S5U"S 5U"S 5S 9nS R UUUS 9$)zApp Engine request_log formatter for `LogPrinter`. Args: entry: A log entry message emitted from the V2 API client. Returns: A string representing the entry if it is a request entry. r2Nz$appengine.googleapis.com/request_logcZ>^[U4SjTRR5S5$)Nc3t># UH-nURT:XdMURRv M/ g7fN)keyvalue string_value.0xrBs r& 8FormatRequestLogEntry..GetStr..}s2"8+,EESL&%%888-nextr6additionalPropertiesrBr<s`r&GetStr%FormatRequestLogEntry..GetStr|, "##88"#& ((r(cZ>^[U4SjTRR5S5$)Nc3t># UH-nURT:XdMURRv M/ g7frA)rBrC integer_valuerEs r&rH8FormatRequestLogEntry..GetInt..s2"8,-EESL'&&8rJrKrLrOs`r&GetInt%FormatRequestLogEntry..GetIntrRr(z-"{method} {resource} {http_version}" {status}methodr4 httpVersionstatus)rYr4 http_versionr[{service}[{version}] {msg}rr msg)r4r5r ExtractLogIdlogNamer;r)r<r/rr rPrWr_s` r&FormatRequestLogEntryrbms ^^I%    U]] +& 55 .u5'(( 9 &8$Z( /8$  & ' - -g6=25 . 77r(cURRS:wag[R"UR5nU[ ;ag[ U5up#SRURR=(d SURR=(d SURR=(d SS9nSRUUUS9$)zApp Engine nginx.* formatter for `LogPrinter`. Args: entry: A log entry message emitted from the V2 API client. Returns: A string representing the entry if it is a request entry. r2Nz"{method} {resource}" {status}rK)rYr4r[r]r^) r4r5rr`ra NGINX_LOGSr;r httpRequest requestMethod requestUrlr[)r<r/rr r_s r&FormatNginxLogEntryrhs ^^I%    U]] +& : .u5' ) &%%33:s''229c%%,,3  5 ' - -g6=25 . 77r(cURRRn[SU55n[SU55nX#4$)zExtract service and version from a App Engine log entry. Args: entry: An App Engine log entry. Returns: A 2-tuple of the form (service_id, version_id) c3^# UH#nURS:XdMURv M% g7f) module_idNrBrCrFrGs r&rH,_ExtractServiceAndVersion..s)*!QEE[(!--c3^# UH#nURS:XdMURv M% g7f) version_idNrlrms r&rHrns)+!QEE\)!ro)r4labelsrNrM)r<ad_proprr s r&r;r;sT NN ! ! 6 6' *!* *' +!+ +'  r(c:\rSrSrSrS SjrSrSrSrSr S r g) LogPrintera Formats V2 API log entries to human readable text on a best effort basis. A LogPrinter consists of a collection of formatter functions which attempts to format specific log entries in a human readable form. The `Format` method safely returns a human readable string representation of a log entry, even if the provided formatters fails. The output format is `{timestamp} {log_text}`, where `timestamp` has a configurable but consistent format within a LogPrinter whereas `log_text` is emitted from one of its formatters (and truncated if necessary). See https://cloud.google.com/logging/docs/api/introduction_v2 Attributes: api_time_format: str, the output format to print. See datetime.strftime() max_length: The maximum length of a formatted log entry after truncation. Nc*/UlXlX lgrA) formattersapi_time_format max_length)selfryrzs r&__init__LogPrinter.__init__sDO* Or(cURU5nUR5RSS5n[R"[R "UR 5UR5nSRUUS9nUR(a.[U5UR:aUSURS- S -nU$![Ra4 [R"SRUR 55 SnNf=f) zSafely formats a log entry into human readable text. Args: entry: A log entry message emitted from the V2 API client. Returns: A string without line breaks respecting the `max_length` property.  z z8Received timestamp [{0}] does not match expected format.z????-??-?? ??:??:??z{timestamp} {log_text}) timestamplog_textNz...)_LogEntryToTextstripreplacer FormatDateTime ParseDateTimerryErrorrr rrzr-)r{r<r3timeouts r&FormatLogPrinter.Formats    &D ::<  d +D#  ! !%"5"5eoo"F"&"6"68d # ) ) * C 3s8doo5 $1$ % -c J ;;# kk#VEOO46 "d#s?CAD  D c:URRU5 g)a Attach a log entry formatter function to the printer. Note that if multiple formatters are attached to the same printer, the first added formatter that successfully formats the entry will be used. Args: formatter: A formatter function which accepts a single argument, a log entry. The formatter must either return the formatted log entry as a string, or None if it is unable to format the log entry. The formatter is allowed to raise exceptions, which will be caught and ignored by the printer. N)rxr)r{ formatters r&RegisterFormatterLogPrinter.RegisterFormatters OO9%r(cPSnURUR/-HnU"U5nU(a OM U(dR[R"SUR UR UR5 SRUR5nU$![anUeSnAf M=f)z>Use the formatters to convert a log entry to unprocessed text.Nz$Could not format log entry: %s %s %szD< UNREADABLE LOG ENTRY {0}. OPEN THE DEVELOPER CONSOLE TO INSPECT. >) rx_FallbackFormatterKeyboardInterruptrrrrainsertIdr)r{r<rfnes r&rLogPrinter._LogEntryToTexts Coo!8!8 99 i    :  ii6 u~~/ &0 J  sB B%BB%cUR(a [R"UR5$UR(a [R"UR5$UR$rA)r6r7r8r9r:)r{r<s r&rLogPrinter._FallbackFormattersL  ]]5-- ..    ]]5,, --   r()ryrxrz)z%Y-%m-%d %H:%M:%SN) __name__ __module__ __qualname____firstlineno____doc__r|rrrr__static_attributes__r(r&rurus $! 6 &(r(ru)NNr)r __future__rrrgooglecloudsdk.api_lib.loggingrgooglecloudsdk.corerrgooglecloudsdk.core.utilr r7 LOG_LEVELS FLEX_REQUESTSTANDARD_REQUEST DEFAULT_LOGSrdr'rr=rbrhr;objectrurr(r&rs@&'/#)* F   (K.0 -13 B ":07D72(^^r(