]jQ dZddlZddlZddlZddlmZddlmZddl Zddl m Z ddl m Z ddlmZmZmZmZddlmZdd lmZed i Zd d dddddddefddddf ZgdZGddeZGddeZy)zDefine API Loggers.N)InvalidArgument) DebugInfo)_add_defaults_to_filter)_add_instrumentation)LogEntry ProtobufEntry StructEntry TextEntry)detect_resource)Resourceglobal)typelabels)type_N)log_nameN)payloadN)rN) insert_idN)severityN) http_requestN) timestampNresource)traceN)span_idN) trace_sampledN)source_locationN)rrrceZdZdZddddZedZedZedZedZ d Z dd d Z dd Z dd d Z dd dZdd dZdd dZddd dZddd dZddddddddZy)LoggerzLoggers represent named targets for log entries. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.logs N)rrcj|st|j}||_||_||_||_y)aI Args: name (str): The name of the logger. client (~logging_v2.client.Client): A client which holds credentials and project configuration for the logger (which requires a project). 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. N)r projectname_clientrdefault_resource)selfr clientrrs H/root/env/lib/python3.12/site-packages/google/cloud/logging_v2/logger.py__init__zLogger.__init__@s2&v~~6H   (c|jS)zClent bound to the logger.r!r#s r%r$z Logger.clientVs||r'c.|jjS)zProject bound to the logger.)r!rr*s r%rzLogger.project[s||###r'c:d|jd|jS)z)Fully-qualified name used in logging APIs projects/z/logs/)rr r*s r% full_namezLogger.full_name`s4<<.tyyk::r'c d|jS)z URI path for use in logging APIs/)r.r*s r%pathz Logger.pathes4>>"##r'c"| |j}|S)aCheck client or verify over-ride. Also sets ``parent``. Args: client (Union[None, ~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. Returns: ~logging_v2.client.Client: The client passed in or the currently bound client. r)r#r$s r%_require_clientzLogger._require_clientjs >\\F r')r$c<|j|}t||S)aFReturn a batch to use as a context manager. Args: client (Union[None, ~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. Returns: Batch: A batch to use as a context manager. )r4Batchr3s r%batchz Logger.batchzs!%%f-T6""r'c "|j|}|jd|j|d<|jd|j|d<|jd|j|d<|j dd}t |tr|j|d<t |dtjjr td i|d|d<| |d d|i|}n|d i|}|j}|g} tj j"j$dur+t'| fi|} d tj j"_|j(j+| d y#t$r}td|d}~wwxYw) z4Helper for :meth:`log_empty`, :meth:`log_text`, etc.rrrrNzinvalid resource dictrFT)partial_success)r4popr.rr"get isinstancestrupper collectionsabcMappingr TypeError to_api_reprgooglecloud logging_v2_instrumentation_emittedr logging_api write_entries) r#r$ _entry_classrkwreentryapi_reprentriess r%_do_logzLogger._do_logsk%%f- DNN;:vvh 48  D,A,AB:66*d+ h $%^^-BzN bnkoo&=&= > @!)!;BzN!;:   77B7E &2&E$$&* << " " ; ;u D*79b9G?CFLL # # <(($(G! @ 78a? @s E44 F= F  Fc 4|j|tfi|y)aLog an empty message See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries/write Args: client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. kw (Optional[dict]): additional keyword arguments for the entry. See :class:`~logging_v2.entries.LogEntry`. N)rQr)r#r$rLs r% log_emptyzLogger.log_emptys  VX,,r'c 6|j|t|fi|y)aLog a text message See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries/write Args: text (str): the log message client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. kw (Optional[dict]): additional keyword arguments for the entry. See :class:`~logging_v2.entries.LogEntry`. N)rQr )r#textr$rLs r%log_textzLogger.log_texts  VY33r'c ptD]}||vs||vs ||||<|j|t|fi|y)aaLogs a dictionary message. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries/write The message must be able to be serializable to a Protobuf Struct. It must be a dictionary of strings to one of the following: - :class:`str` - :class:`int` - :class:`float` - :class:`bool` - :class:`list[str|float|int|bool|list|dict|None]` - :class:`dict[str, str|float|int|bool|list|dict|None]` For more details on Protobuf structs, see https://protobuf.dev/reference/protobuf/google.protobuf/#value. If the provided dictionary cannot be serialized into a Protobuf struct, it will not be logged, and a :class:`ValueError` will be raised. Args: info (dict[str, str|float|int|bool|list|dict|None]): the log entry information. client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. kw (Optional[dict]): additional keyword arguments for the entry. See :class:`~logging_v2.entries.LogEntry`. Raises: ValueError: if the dictionary message provided cannot be serialized into a Protobuf struct. N)_STRUCT_EXTRACTABLE_FIELDSrQr )r#infor$rLfields r% log_structzLogger.log_structsGD0 (E}b K5  (  V[$5"5r'c 6|j|t|fi|y)a3Log a protobuf message See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries/list Args: message (google.protobuf.message.Message): The protobuf message to be logged. client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. kw (Optional[dict]): additional keyword arguments for the entry. See :class:`~logging_v2.entries.LogEntry`. N)rQrr#messager$rLs r% log_protozLogger.log_protos  V]G:r:r'c ~t|tjjjr|j |fd|i|yt|t jjr|j|fd|i|yt|tr|j|fd|i|y|j|t|fi|y)aRLog an arbitrary message. Type will be inferred based on the input. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries/list Args: message (Optional[str or dict or google.protobuf.Message]): The message. to log client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current sink. kw (Optional[dict]): additional keyword arguments for the entry. See :class:`~logging_v2.entries.LogEntry`. r$N)r=rEprotobufr^Messager_r@rArBr[r>rVrQrr]s r%logz Logger.logs gv66>> ? DNN7 86 8R 8 !8!8 9 DOOG 9F 9b 9  % DMM' 7& 7B 7 DLL7 9b 9r'cx|j|}| |j}|jj|y)aDelete all entries in a logger via a DELETE request See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.logs/delete Args: logger_name (Optional[str]): The resource name of the log to delete: :: "projects/[PROJECT_ID]/logs/[LOG_ID]" "organizations/[ORGANIZATION_ID]/logs/[LOG_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]/logs/[LOG_ID]" "folders/[FOLDER_ID]/logs/[LOG_ID]" ``[LOG_ID]`` must be URL-encoded. For example, ``"projects/my-project-id/logs/syslog"``, ``"organizations/1234567890/logs/cloudresourcemanager.googleapis.com%2Factivity"``. If not passed, defaults to the project bound to the client. client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current logger. N)r4r.rI logger_delete)r# logger_namer$s r%deletez Logger.deletes70%%f-  ..K((5r'resource_namesfilter_order_by max_results page_size page_tokenc|d|jg}d|j}||d|}n|}t|}|jj ||||||S)a)Return a generator of log entry resources. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries/list Args: resource_names (Optional[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 client. filter_ (Optional[str]): a filter expression. See https://cloud.google.com/logging/docs/view/advanced_filters By default, a 24 hour filter is applied. order_by (Optional[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] r-zlogName=z AND rh)rr.rr$ list_entries)r#rirjrkrlrmrn log_filters r%rpzLogger.list_entries9sX  ! )$,,89N/0   zl3G G)'2{{'')#! (  r'N)__name__ __module__ __qualname____doc__r&propertyr$rr.r1r4r7rQrSrVr[r_rcrgrpr:r'r%rr:s 04d),$$;;$$ # ##HJ#' -(,4 *.&6P,0;":$:.66@< r'rcXeZdZdddZdZdZdZdZdZd Z dd Z dd d d Z dZ y)r6N)rc<||_g|_||_||_y)a_Context manager: collect entries to log via a single API call. Helper returned by :meth:`Logger.batch` Args: logger (logging_v2.logger.Logger): the logger to which entries will be logged. client (~logging_V2.client.Client): The client to use. resource (Optional[~logging_v2.resource.Resource]): Monitored resource of the batch, defaults to None, which requires that every entry should have a resource specified. Since the methods used to write entries default the entry's resource to the global resource type, this parameter is only required if explicitly set to None. If no entries' resource are set to None, this parameter will be ignored on the server. N)loggerrPr$r)r#rzr$rs r%r&zBatch.__init__ys &     r'c|Srrr:r*s r% __enter__zBatch.__enter__s r'c*||jyyrr)commit)r#exc_typeexc_valexc_tbs r%__exit__zBatch.__exit__s   KKM r'c L|jjtdi|y)zAdd a entry without payload to be logged during :meth:`commit`. Args: kw (Optional[dict]): Additional keyword arguments for the entry. See :class:`~logging_v2.entries.LogEntry`. Nr:)rPappendr)r#rLs r%rSzBatch.log_emptys HNrN+r'c P|jjtdd|i|y)zAdd a text entry to be logged during :meth:`commit`. Args: text (str): the text entry kw (Optional[dict]): Additional keyword arguments for the entry. See :class:`~logging_v2.entries.LogEntry`. rNr:)rPrr )r#rUrLs r%rVzBatch.log_texts# I9d9b9:r'c P|jjtdd|i|y)aAdd a struct entry to be logged during :meth:`commit`. The message must be able to be serializable to a Protobuf Struct. It must be a dictionary of strings to one of the following: - :class:`str` - :class:`int` - :class:`float` - :class:`bool` - :class:`list[str|float|int|bool|list|dict|None]` - :class:`dict[str, str|float|int|bool|list|dict|None]` For more details on Protobuf structs, see https://protobuf.dev/reference/protobuf/google.protobuf/#value. If the provided dictionary cannot be serialized into a Protobuf struct, it will not be logged, and a :class:`ValueError` will be raised during :meth:`commit`. Args: info (dict[str, str|float|int|bool|list|dict|None]): The struct entry, kw (Optional[dict]): Additional keyword arguments for the entry. See :class:`~logging_v2.entries.LogEntry`. rNr:)rPrr )r#rYrLs r%r[zBatch.log_structs#, K;;;r rPr)r#r^rL entry_types r%rcz Batch.logso gv66>> ?&J !8!8 9$J  %"J J=w="=>r'T)r$r9c| |j}d|jji}|j|jj |d<|jj |jj |d<|j Dcgc]}|j}} |jj|fd|i||j dd=ycc}w#t$r}|j||d}~wwxYw)aoSend saved log entries as a single API call. Args: client (Optional[~logging_v2.client.Client]): The client to use. If not passed, falls back to the ``client`` stored on the current batch. partial_success (Optional[bool]): Whether a batch's valid entries should be written even if some other entry failed due to a permanent error such as INVALID_ARGUMENT or PERMISSION_DENIED. Raises: ValueError: if one of the messages in the batch cannot be successfully parsed. Nrfrrr9) r$rzr.r_to_dictrrPrDrIrJr_append_context_to_error)r#r$r9kwargsrNrPrMs r%r~z Batch.commits >[[F!6!67 == $!%!7!7!9F:  ;;   )#{{11F8 48LLA55$$&AA  ,F   , , )8 z1Batch._append_context_to_error..sQA 1i8PaQsz(?<=key: )[0-9]+rz: z.2000z...N) nextdetailsresearchdetailgrouprPintr>rDr^ Exception)r#err debug_info error_idx found_entry str_entrys r%rzBatch._append_context_to_errors QQQJ "4j6G6GHNNqQI,,s9~6KK3356I [[MIe+rs 62DI R5"5!" >{ V{ | fFfr'