]jCjdZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddl mZddl mZdd l mZdd lmZmZmZdd lmZdd lmZdd lmZddlmZddl m!Z!ddl"m#Z#ejHe dZ%dZ& e%sddl'm(Z(dZ&e&xre% Z*dZ+dZ,dZ-dZ.GddeZ/y#e)$rdZ&dZ(Y&wxYw)z9Client for interacting with the Google Cloud Logging API.N)ClientWithProject) DISABLE_GRPC)_add_defaults_to_filter) Connection) _LoggingAPI) _MetricsAPI) _SinksAPI)CloudLoggingHandlerStructuredLogHandler setup_logging)detect_resource)EXCLUDED_LOGGER_DEFAULTSLoggerMetric)ResourceSinkF)_gapicTgae_app k8s_containercloud_functioncloud_run_revisionceZdZdZdZdZdZdZ dddddddfd Ze dZ e dZ e dZ ddd d Z ddddddd d Zddd dZddddddZddddZdddddZdZej*eddZdZfdZxZS)Clientz7Client to bundle configuration needed for API requests.N)z,https://www.googleapis.com/auth/logging.readz-https://www.googleapis.com/auth/logging.writez-https://www.googleapis.com/auth/logging.adminz.https://www.googleapis.com/auth/cloud-platform)project credentials_http _use_grpc client_infoclient_optionsctt| ||||d|i}|rVt|tr)t j jj|}|jr|j}||d<t|fi||_ ||jj}||_ ||_ | t|_n||_t!|_y)a Args: project (Optional[str]): the project which the client acts on behalf of. If not passed, falls back to the default inferred from the environment. credentials (Optional[google.auth.credentials.Credentials]): Thehe OAuth2 Credentials to use for this client. If not passed (and if no ``_http`` object is passed), falls back to the default inferred from the environment. _http (Optional[requests.Session]): HTTP object to make requests. Can be any object that defines ``request()`` with the same interface as :meth:`requests.Session.request`. If not passed, an ``_http`` object is created that is bound to the ``credentials`` for the current object. This parameter should be considered private, and could change in the future. _use_grpc (Optional[bool]): Explicitly specifies whether to use the gRPC transport or HTTP. If unset, falls back to the ``GOOGLE_CLOUD_DISABLE_GRPC`` environment variable This parameter should be considered private, and could change in the future. client_info (Optional[Union[google.api_core.client_info.ClientInfo, google.api_core.gapic_v1.client_info.ClientInfo]]): The client info used to send a user-agent string along with API requests. If ``None``, then default info will be used. Generally, you only need to set this if you're developing your own library or partner tool. client_options (Optional[Union[dict, google.api_core.client_options.ClientOptions]]): Client options used to set user options on the client. API Endpoint should be set through client_options. )rrrr"r! api_endpointN)superr__init__ isinstancedictgoogleapi_corer" from_dictr$r _connection _client_info_client_options _USE_GRPCr set _handlers) selfrrrr r!r"kw_argsr$ __class__s H/root/env/lib/python3.12/site-packages/google/cloud/logging_v2/client.pyr&zClient.__init__OsT fd$#) % !+. .$/!'!?!?!I!I""**-:: *6'%d6g6  **77K'-  &DN&DNc|jB|jr&tj||_|jSt ||_|jS)zHelper for logging-related API calls. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.logs ) _logging_apir rmake_logging_apiJSONLoggingAPIr2s r5 logging_apizClient.logging_apisS    $~~$*$;$;D$A!   %34$8!   r6c|jB|jr&tj||_|jSt ||_|jS)zHelper for log sink-related API calls. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks ) _sinks_apir rmake_sinks_api JSONSinksAPIr;s r5 sinks_apizClient.sinks_apisK ?? "~~"("7"7"=#/t"4r6c|jB|jr&tj||_|jSt ||_|jS)zHelper for log metric-related API calls. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.metrics ) _metrics_apir rmake_metrics_apiJSONMetricsAPIr;s r5 metrics_apizClient.metrics_apisS    $~~$*$;$;D$A!   %34$8!   r6)labelsresourcec t||||S)a3Creates a logger bound to the current client. Args: name (str): The name of the logger to be constructed. resource (Optional[~logging_v2.Resource]): a monitored resource object representing the resource the code was run on. If not given, will be inferred from the environment. labels (Optional[dict]): Mapping of default labels for entries written via this logger. Returns: ~logging_v2.logger.Logger: Logger created with the current client. )clientrGrHr)r2namerGrHs r5loggerz Client.loggersd4JJr6resource_namesfilter_order_by max_results page_size page_tokenc~|d|jg}t|}|jj||||||S)a|Return a generator of log entry resources. Args: resource_names (Sequence[str]): Names of one or more parent resources from which to retrieve log entries: :: "projects/[PROJECT_ID]" "organizations/[ORGANIZATION_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]" "folders/[FOLDER_ID]" If not passed, defaults to the project bound to the API's client. filter_ (str): a filter expression. See https://cloud.google.com/logging/docs/view/advanced_filters order_by (str) One of :data:`~logging_v2.ASCENDING` or :data:`~logging_v2.DESCENDING`. max_results (Optional[int]): Optional. The maximum number of entries to return. Non-positive values are treated as 0. If None, uses API defaults. page_size (int): number of entries to fetch in each API call. Although requests are paged internally, logs are returned by the generator one at a time. If not passed, defaults to a value set by the API. page_token (str): opaque marker for the starting "page" of entries. If not passed, the API will return the first page of entries. Returns: Generator[~logging_v2.LogEntry] projects/rM)rrr< list_entries)r2rNrOrPrQrRrSs r5rVzClient.list_entriessXR  ! )$,,89N)'2,,)#! -  r6)rO destinationc t||||S)aCreates a sink bound to the current client. Args: name (str): the name of the sink to be constructed. filter_ (Optional[str]): the advanced logs filter expression defining the entries exported by the sink. If not passed, the instance should already exist, to be refreshed via :meth:`Sink.reload`. destination (str): destination URI for the entries exported by the sink. If not passed, the instance should already exist, to be refreshed via :meth:`Sink.reload`. Returns: ~logging_v2.sink.Sink: Sink created with the current client. )rOrWrJr)r2rKrOrWs r5sinkz Client.sink s"D'{4PPr6parentrQrRrScb|d|j}|jj||||S)aList sinks for the a parent resource. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks/list Args: parent (Optional[str]): The parent resource whose sinks are to be listed: :: "projects/[PROJECT_ID]" "organizations/[ORGANIZATION_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]" "folders/[FOLDER_ID]". If not passed, defaults to the project bound to the API's client. max_results (Optional[int]): Optional. The maximum number of entries to return. Non-positive values are treated as 0. If None, uses API defaults. page_size (int): number of entries to fetch in each API call. Although requests are paged internally, logs are returned by the generator one at a time. If not passed, defaults to a value set by the API. page_token (str): opaque marker for the starting "page" of entries. If not passed, the API will return the first page of entries. Returns: Generator[~logging_v2.Sink] rUrZ)rrA list_sinks)r2r[rQrRrSs r5r]zClient.list_sinkssA> > /F~~((#! )  r6)rO descriptionc t||||S)aCreates a metric bound to the current client. Args: name (str): The name of the metric to be constructed. filter_(Optional[str]): The advanced logs filter expression defining the entries tracked by the metric. If not passed, the instance should already exist, to be refreshed via :meth:`Metric.reload`. description (Optional[str]): The description of the metric to be constructed. If not passed, the instance should already exist, to be refreshed via :meth:`Metric.reload`. Returns: ~logging_v2.metric.Metric: Metric created with the current client. )rOrJr_r)r2rKrOr_s r5metricz Client.metricEs dGDkRRr6rQrRrScT|jj|j|||S)aEList metrics for the project associated with this client. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.metrics/list Args: max_results (Optional[int]): Optional. The maximum number of entries to return. Non-positive values are treated as 0. If None, uses API defaults. page_size (int): number of entries to fetch in each API call. Although requests are paged internally, logs are returned by the generator one at a time. If not passed, defaults to a value set by the API. page_token (str): opaque marker for the starting "page" of entries. If not passed, the API will return the first page of entries. Returns: Generator[logging_v2.Metric] rb)rF list_metricsr)r2rQrRrSs r5rdzClient.list_metricsWs2&,, LL#! -  r6c |jdt|j}t|tr|j t k(rt|fd|i|S|j tk(rtdi|d|jiS|j tk(r<|jdtj|d<tdi|d|jiS|j tk(rtdi|d|jiSt|fd|i|S)zReturn the default logging handler based on the local environment. Args: kw (dict): keyword args passed to handler constructor Returns: logging.Handler: The default log handler based on the environment rH project_idstream)popr rr'rtype_GAE_RESOURCE_TYPEr _GKE_RESOURCE_TYPEr _GCF_RESOURCE_TYPEgetsys __stdout___RUN_RESOURCE_TYPE)r2kwmonitored_resources r5get_default_handlerzClient.get_default_handlerqs VVJ 0MN (( 3!&&*<<*4S:LSPRSS#((,>>+JbJT\\JJ#((,>>!vvh?8 +JbJT\\JJ#((,>>+JbJT\\JJ"4K2DKKKr6 log_levelexcluded_loggersc z|jdi|}|jj|t|||y)aUAttach default Cloud Logging handler to the root logger. This method uses the default log handler, obtained by :meth:`~get_default_handler`, and attaches it to the root Python logger, so that a call such as ``logging.warn``, as well as all child loggers, will report to Cloud Logging. Args: 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`. 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. Returns: dict: keyword args passed to handler constructor ruNrh)rtr1addr )r2rvrwrrhandlers r5r zClient.setup_loggings8*+$**0R0 7#gEUVr6cF|jD]}|jy)zrCSCOPEr&propertyr<rArFrLrVrYr]rardrtloggingINFOrr r}r __classcell__)r4s@r5rr@sALJL E H HT ! !   ! !&*DK&4 l%)dQ($$4& P'+S$+/$4 4L2#<<:RW2 r6r)0rrosrogoogle.api_core.client_optionsr)google.cloud.clientrgoogle.cloud.environment_varsr google.cloud.logging_v2._helpersrgoogle.cloud.logging_v2._httprrr:rrEr r@ google.cloud.logging_v2.handlersr r r 5google.cloud.logging_v2.handlers._monitored_resourcesr )google.cloud.logging_v2.handlers.handlersrgoogle.cloud.logging_v2.loggerrgoogle.cloud.logging_v2.metricr google.cloud.logging_v2.resourcergoogle.cloud.logging_v2.sinkrgetenv _DISABLE_GRPC _HAVE_GRPCgoogle.cloud.logging_v2r ImportErrorr/rkrlrmrqrrhr6r5rs@ %16D4GGC RN115- ,.    2  ,}, $%)l lJ Fs B&& B21B2