%XdZddlmZddlmZddlmZddlZddlmZddl m Z ddl m Zddl mZdd lmZdd lmZdd lmZdd lmZddlmZdd lmZddlmZddlmZddlZdZdZdZdZdZdZ ejBejDejFjHGddejJZ&ejDejFjNGdde&Z(ejDejFjRGdde(Z*y)z8Displays log entries produced by Google Cloud Functions.)absolute_import)division)unicode_literalsN)util)client)common) arg_parsers)base)parser_extensions)flags)log) properties) resourcesz+table(level,name,execution_id,time_utc,log)c|sytjj|tjj j jtjjjjddS)N) projectsId locationsIdz+cloudfunctions.projects.locations.functions)params collection) rREGISTRYParserVALUEScoreproject GetOrFail functionsregion)names "lib/surface/functions/logs/read.py_GetFunctionRefr(so     ! ! "))..66@@B#**44;;EEG? " cddj|dg}|r,|j}|jdj|dj|S)z(Generates Gen1-specific log filter base.zresource.type="cloud_function"zresource.labels.region="{}"zlogName:"cloud-functions"z"resource.labels.function_name="{}" )format functionsIdappendjoin) function_refr log_filter function_ids r_CreateGen1LogFilterBaser*7sX'#**62!* **K:AA+NO * r cddj|ddg}|rJ|jjjdd}|j dj|dj |S) z(Generates Gen2-specific log filter base.z"resource.type="cloud_run_revision"zresource.labels.location="{}"zlogName:"run.googleapis.com"z)labels."goog-managed-by"="cloudfunctions"_-z!resource.labels.service_name="{}"r")r#r$lowerreplacer%r&)r'rr( service_names r_CreateGen2LogFilterBaser1Fss+%,,V4$1 * ++113;;CEL9@@NO * r c t|j}tjjj j }tjrt||g}nItjrt||g}n'djt||t||g}|jr*|jdj|j|jr8|jdj|jj!|j"r=|jdjt%j&|j"|jdjt%j&|j(xs5t*j*j-t+j.dz dj1|S) zCreates the filter for retrieving function logs based on the given args. Args: args: The arguments that were provided to this command invocation. Returns: z ({}) OR ({})zlabels.execution_id="{}"z severity>={}ztimestamp<="{}"ztimestamp>="{}")daysr")rrrrrrrr ShouldUseGen1r* ShouldUseGen2r1r# execution_idr% min_log_levelupperend_time logging_utilFormatTimestamp start_timedatetimeutcnow timedeltar&)argsr'rr(s r_CreateLogFilterrBYs!+,    & & - - 7 7 9& *<@AJ *<@AJ  $\6 : $\6 : J 0778I8IJK n++D,>,>,D,D,FGH ]]  !=!=dmm!LM   & &ooI""))+h.@.@a.HH  * r c#K|D]}|j}|jrh|jjDcgc]}|jdk(r |j}}t |dk(rt |ddr|dj}d|i}|jr?tj|j}|tjvr |d|d<n||d<|jrY|jjrC|jjjD] }|jdvs|j|d<"|jr:|jjD]!}|jd k(s|j|d <#|jr"t!j"|j|d <|y cc}ww) zProcesses the given entries to yield rows. Args: entries: the log entries to process. Yields: Rows with level, name, execution_id, time_utc, and log properties. messager string_valuer level) function_namer0rr7time_utcN) textPayload jsonPayloadadditionalPropertieskeyvaluelenhasattrrFseveritysix text_typer SEVERITIESresourcelabels timestamprr<)entriesentryrDproppropsrowrQlabels r_YieldLogEntriesr^seG ''<<('' ' C ~~u~~.h U%% %{G  G  ~~%..//>>((==% 999 9 #f+> ||<<44% 99 & % #n 5 ,,U__=c*o I;s7F>"F9CF>,AF>2A F>cDeZdZdZedZejdZy)GetLogs7Display log entries produced by Google Cloud Functions.cPtj|dtjj ||j ddd|j dd |j d d t jjd |j dd t jjd |j dd t jddddtj||jjdtj|y)z Register flags for this command.z4Only show logs generated by functions in the region.) help_textr?ztName of the function which logs are to be displayed. If no name is specified, logs from all functions are displayed.)nargshelpz--execution-idz0Execution ID for which logs are to be displayed.)rfz --start-timeFzReturn only log entries in which timestamps are not earlier than the specified time. If *--start-time* is not specified, a default start time of 1 week ago is assumed. See $ gcloud topic datetimes for information on time formats.)requiredtyperfz --end-timeaReturn only log entries which timestamps are not later than the specified time. If *--end-time* is specified but *--start-time* is not, the command returns *--limit* latest log entries which appeared before --end-time. See *$ gcloud topic datetimes* for information on time formats.z--limitrEizNumber of log entries to be fetched; must not be greater than 1000. Note that the most recent entries in the specified time range are returned, rather than the earliest.)rgrhdefaultrfN)r AddRegionFlagr LIMIT_FLAGRemoveFromParser add_argumentr Datetimer BoundedIntAddMinLogLevelFlag display_infoAddCacheUpdater AddGen2Flag)parsers rArgsz GetLogs.Argss* H OO$$V,  C   ?   ! ! ' ' ?     ! ! ' ' J     # #At , <   V$ ''- fr c|jds t|_t|}t t j |d|j}|jr|stj|j}t|j}|j|js9tj dj|j"|j$t'|S)zThis is what gets called when the user runs this command. Args: args: an argparse namespace. All the arguments that were provided to this command invocation. Returns: A generator of objects representing log entries. r#DESC)order_bylimitzThere is no function named `{}` in region `{}`. Perhaps you meant to specify `--region` or update the `functions/region` configuration property?) IsSpecified_DEFAULT_TABLE_FORMATr#rBlistlogging_common FetchLogsrzr client_v2FunctionsClient ReleaseTrackr GetFunction RelativeNamer warningr$rr^)selfrAr(rXrr's rRunz GetLogs.Runs   H %)dk!$'J  fDJJOG yy(():):)<=f$TYY/l    9 9 ; <  &&,f((,*B*B'  G $$r N) __name__ __module__ __qualname____doc__ staticmethodrvutil_v1 CatchHTTPErrorRaiseHTTPExceptionrr rr`r`s5@99v ++ %, %r r`ceZdZdZy) GetLogsBetaraNrrrrrr rrr?r rceZdZdZy) GetLogsAlpharaNrrr rrrrr r)+r __future__rrrr>#googlecloudsdk.api_lib.functions.v1rr#googlecloudsdk.api_lib.functions.v2rrgooglecloudsdk.api_lib.loggingrr~r;googlecloudsdk.callioper r r $googlecloudsdk.command_lib.functionsr googlecloudsdk.corer rrrRr|rr*r1rBr^DefaultUniverseOnly ReleaseTracksrGA ListCommandr`BETArALPHArrr rrs?&'?CC?/(565#*) E  &+\&RD%%(()`%d`%*`%FD%%**+@'@,@D%%++,@;@-@r