]j1dZddlZddlZddlZddlmZmZmZddlm Z ddl m Z m Z ddl mZmZddlmZdZ d Z d Z d ZGd d ej,ZGddej0ZdZeej6ddZy)z1Python :mod:`logging` handlers for Cloud Logging.N)IOOptionalType)get_request_data)add_resource_labelsdetect_resource)BackgroundThreadTransport Transport)Resourcepython)zgoogle.api_core.bidiwerkzeug)z google.cloudz google.authgoogle_auth_httplib2)gae_appcloud_functionc.eZdZdZddZedZdZy)CloudLoggingFiltera5Python standard ``logging`` Filter class to add Cloud Logging information to each LogRecord. When attached to a LogHandler, each incoming log will be modified to include new Cloud Logging relevant data. This data can be manually overwritten using the `extras` argument when writing logs. Nc4||_|r||_yi|_y)Nprojectdefault_labels)selfrrs S/root/env/lib/python3.12/site-packages/google/cloud/logging_v2/handlers/handlers.py__init__zCloudLoggingFilter.__init__=s 0>nBct|dr |jSgd}i}|D]\}}t||d}||||<|r|SdS)zHelper function to infer source location data from a LogRecord. Will default to record.source_location if already set source_location))linelineno)filepathname)functionfuncNameN)hasattrrgetattr)recordname_mapoutputgcp_name std_lib_namevalues r_infer_source_locationz)CloudLoggingFilter._infer_source_locationAsj 6, -)) )H F*2 -&, d;$',F8$ -$6 - -rcnt|di}t\}}}}||jd|jd|}t|dd|_t|d|xsd|_t|d|xsd|_t t|d||_t|d ||_tj||_ |jrd |jini}i||j|xsd|_|jxsd |_|j xsd |_|jrd nd |_t%j&|jxsid|_t%j&|jxsid|_t%j&|jxsid|_y)zM Add new Cloud Logging data to each LogRecord as it comes in labelsNz projects/z/traces/resourcetracespan_id trace_sampled http_request python_loggertruefalseF) ensure_asciiT)r$rr _resource_trace_span_idbool_trace_sampled _http_requestrr+_source_locationnamer_labels _trace_str _span_id_str_trace_sampled_strjsondumps_http_request_str_source_location_str _labels_str)rr% user_labels inferred_httpinferred_trace inferred_spaninferred_sampled logger_labels rfilterzCloudLoggingFilter.filterUsfh3          %$,,*B(h~>NON"6:t<@HD !&)]CKt $WV_FV%W X&v~}M"4"K"KF"S9?5" OLOD,?,?O;OWSW"MM/R$oo3.4.C.CF!#'::  &BU$  '+jj  # # )r' #"ZZ(<"5Qr)NN)__name__ __module__ __qualname____doc__r staticmethodr+rOrrrr4s&G..&$rrc neZdZdZeedddddedeede de e de e f fd Z d Zfd Zd ZxZS) CloudLoggingHandlera6Handler that directly makes Cloud Logging API calls. This is a Python standard ``logging`` handler using that can be used to route Python standard logging messages directly to the Stackdriver Logging API. This handler is used when not in GAE or GKE environment. This handler supports both an asynchronous and synchronous transport. Example: .. code-block:: python import logging import google.cloud.logging from google.cloud.logging_v2.handlers import CloudLoggingHandler client = google.cloud.logging.Client() handler = CloudLoggingHandler(client) cloud_logger = logging.getLogger('cloudLogger') cloud_logger.setLevel(logging.INFO) cloud_logger.addHandler(handler) cloud_logger.error('bad news') # API call N)r? transportr.r-streamr?rXr.r-rYc vtt| ||st|j}||_||_|jj||||||_ d|_ ||_ |j|_ ||_ ||_t|j|}|j!|y)a Args: client (~logging_v2.client.Client): The authenticated Google Cloud Logging client for this handler to use. name (str): the name of the custom log in Cloud Logging. Defaults to 'python'. The name of the Python logger will be represented in the ``python_logger`` field. transport (~logging_v2.transports.Transport): Class for creating new transport objects. It should extend from the base :class:`.Transport` type and implement :meth`.Transport.send`. Defaults to :class:`.BackgroundThreadTransport`. The other option is :class:`.SyncTransport`. resource (~logging_v2.resource.Resource): Resource for this Handler. If not given, will be inferred from the environment. labels (Optional[dict]): Additional labels to attach to logs. stream (Optional[IO]): Stream to be used by the handler. r.TrN)superrWrrrr?client _handlersaddrX_transport_open_transport_cls project_idr.r-r addFilter) rr]r?rXr.r-rYkwargs log_filter __class__s rrzCloudLoggingHandler.__init__s< !41&9&v~~6H  T""64(C#' ..   'PVW  z"rc |jxs |j}|j}t||}it |||xsixsd}|j s>|j |j|j|j|_ d|_|jj|||||j|j|j|j|j y)aActually log the specified logging record. Overrides the default emit behavior of ``StreamHandler``. See https://docs.python.org/2/library/logging.html#handler-objects Args: record (logging.LogRecord): The record to be logged. Nr[T)r.r-r/r0r1r2r)r8r.r@_format_and_parse_messagerr`rar]r?rXsendr9r:r<r=r>)rr%r.r-messages remitzCloudLoggingHandler.emits##4t}}+FD9L'&9LflLTPT##!00 TYY1DN$(D    --OO //--"33  rcxtt| |jr|jjyy)ztForces the Transport object to submit any pending log records. For SyncTransport, this is a no-op. N)r\rWflushr`rX)rrfs rrmzCloudLoggingHandler.flushs1 !4.0    NN " rcn|jr)|jjd|_d|_yy)z@Closes the log handler and cleans up all Transport objects used.NF)r`rXclose)rs rrozCloudLoggingHandler.closes/    NN "!DN#(D  r)rPrQrRrSDEFAULT_LOGGER_NAMEr strrr r rdictrrrkrmro __classcell__)rfs@rrWrW|sn@(%>!!%#-# -#  ? -#  -#-# -#^! F#)rrWc~t|di}t|jtjj r:|j}|r*t|tjj ri||}|S|j |} |ddk(r;tj|}t|tjj r|}|r@t|tjj r|j}|dk7r||d<|S|dk7r|SdS#tjjtf$rYpwxYw)ae Helper function to apply formatting to a LogRecord message, and attempt to parse encoded JSON into a dictionary object. Resulting output will be of type (str | dict | None) Args: record (logging.LogRecord): The record object representing the log formatter_handler (logging.Handler): The handler used to format the log json_fieldsr{NonerjN) r$ isinstancemsg collectionsabcMappingformatrDloadsdecoderJSONDecodeError IndexErrorcopy)r%formatter_handlerpassed_json_fieldspayloadrj json_messages rrhrhs"!;&**koo556** *   7 7# 87$67G&&v.G 1: ::g.L, (?(?@& j);[__=T=TU/446 f ,3 y )!!'71T1 LL ( (* 5   sAD#D<;D<)excluded_loggers log_levelcBt|tz}tj}t j t vr|jj|j||j||D]}tj|}d|_ y)aAttach a logging handler to the Python root logger Excludes loggers that this library itself uses to avoid infinite recursion. Example: .. code-block:: python import logging import google.cloud.logging from google.cloud.logging_v2.handlers import CloudLoggingHandler client = google.cloud.logging.Client() handler = CloudLoggingHandler(client) google.cloud.logging.handlers.setup_logging(handler) logging.getLogger().setLevel(logging.DEBUG) logging.error('bad news') # API call Args: handler (logging.handler): the handler to attach to the global handler excluded_loggers (Optional[Tuple[str]]): The loggers to not attach the handler to. This will always include the loggers in the path of the logging client itself. log_level (Optional[int]): The logging level threshold of the attached logger, as set by the :meth:`logging.Logger.setLevel` method. Defaults to :const:`logging.INFO`. FN) set_INTERNAL_LOGGERSlogging getLoggerrtype_CLEAR_HANDLER_RESOURCE_TYPEShandlersclearsetLevel addHandler propagate)handlerrrall_excluded_loggerslogger logger_names r setup_loggingr&s@/2CCD    F!>> OOI g+! "";/ !r)rSrzrDrtypingrrr)google.cloud.logging_v2.handlers._helpersr5google.cloud.logging_v2.handlers._monitored_resourcesrr+google.cloud.logging_v2.handlers.transportsr r google.cloud.logging_v2.resourcer rpEXCLUDED_LOGGER_DEFAULTSrrFilterr StreamHandlerrWrhINFOrrUrrrs8 %%F6. > F =EEP})'//})@'2V":W\\,!r