]j\dZddlmZmZddlmZmZmZddlm Z ddl m Z ddl m Z ddlmZddlmZdd lmZdd lmZmZmZmZmZmZmZmZdd lmZGd d eZ GddeZ!GddeZ"dZ#dZ$dZ%dZ&dZ'dZ(y)zOWrapper for adapting the autogenerated gapic client to the hand-written client.) client_infogapic_v1) MessageToDict ParseDict ParseError)entry_from_resource)Metric)ConfigServiceV2Client)LoggingServiceV2Client)MetricsServiceV2Client)Sink)CreateSinkRequestListLogEntriesRequestListLogMetricsRequestListSinksRequest LogMetricLogSinkUpdateSinkRequestWriteLogEntriesRequest)LogEntrycDeZdZdZdZdddddddZddddddd Zd Zy) _LoggingAPIz$Helper mapping logging-related APIs.c ||_||_yN _gapic_api_clientself gapic_apiclients H/root/env/lib/python3.12/site-packages/google/cloud/logging_v2/_gapic.py__init__z_LoggingAPI.__init__+# N)filter_order_by max_results page_size page_tokenc |}t|||||}jj|}t|} i dkr t d fd} | | 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]" 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] )resource_namesfilterr'r)r*requestrmax_results must be positivec3Kd}|D]H}|k\ryttj|}t|j|dz }Jyw)Nr)loggers)_parse_log_entry LogEntryPBpbrr)log_iterientrylog_entry_dictr2r(rs r"log_entries_pagerz3_LoggingAPI.list_entries..log_entries_pagerks[A! *qK/?!1*--2F!G).$,,PWXXQ  sAA)rrlist_log_entriesiter ValueError) rr,r&r'r(r)r*r/responser7r;r2s ` ` @r" list_entriesz_LoggingAPI.list_entries/swN(')!  ??33G3D>   "{Q;< < !**r%TF) logger_nameresourcelabelspartial_successdry_runc |Dcgc] }t|}}t |||||} |j j | ycc}w#t$r} tdt| | d} ~ wwxYw)aLog an entry resource via a POST request Args: entries (Sequence[Mapping[str, ...]]): sequence of mappings representing the log entry resources to log. logger_name (Optional[str]): name of default logger to which to log the entries; individual entries may override. resource(Optional[Mapping[str, ...]]): default resource to associate with entries; individual entries may override. labels (Optional[Mapping[str, ...]]): default labels to associate with entries; individual entries may override. partial_success (Optional[bool]): Whether valid entries should be written even if some other entries fail due to INVALID_ARGUMENT or PERMISSION_DENIED errors. If any entry is not written, then the response status is the error associated with one of the failed entries and the response includes error details keyed by the entries' zero-based index in the ``entries.write`` method. dry_run (Optional[bool]): If true, the request should expect normal response, but the entries won't be persisted nor exported. Useful for checking whether the logging API endpoints are working properly before sending valuable data. zInvalid log entry: N)log_namerBrCentriesrDr.)_log_entry_mapping_to_pbrr>strrrwrite_log_entries) rrHrArBrCrDrEr9 log_entry_pbser/s r" write_entriesz_LoggingAPI.write_entriesvsD DJQR5e<RMR) !+   ))'):S D23q6(;.E+V.;`9r%rcJeZdZdZdZdddddZdddZd Zddd Zd Z y) _SinksAPI!Helper mapping sink-related APIs.c ||_||_yrrrs r"r#z_SinksAPI.__init__r$r%Nr(r)r*ct|||}jj|}t|}dkr t dfd}||S)aList sinks for the parent resource. Args: parent (str): The parent resource whose sinks are to be listed: :: "projects/[PROJECT_ID]" "organizations/[ORGANIZATION_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]" "folders/[FOLDER_ID]". 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] parentr)r*rr0c3Kd}|D]F}|k\rytjtj|j|dz }HywNr)r!r3)r from_api_reprrto_dictr) sink_iterr8r9r(rs r" sinks_pagerz)_SinksAPI.list_sinks..sinks_pagersTA" *qK/?(()? UUQ  AA)rr list_sinksr=r>) rr^r(r)r*r/r?rcrds ` ` r"rfz_SinksAPI.list_sinkss_0#Y: ??--g6N  "{Q;< < 9%%r%F)unique_writer_identityct|||}t|||}|jj|}t tj |dS)aCreate a sink resource. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks/create Args: parent(str): The resource in which to create the sink, including the parent resource and the sink identifier: :: "projects/[PROJECT_ID]" "organizations/[ORGANIZATION_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]" "folders/[FOLDER_ID]". sink_name (str): The name of the sink. filter_ (str): The advanced logs filter expression defining the entries exported by the sink. destination (str): Destination URI for the entries exported by the sink. unique_writer_identity (Optional[bool]): determines the kind of IAM identity returned as writer_identity in the new sink. Returns: dict: The sink resource returned from the API (converted from a protobuf to a dictionary). namer- destination)r^sinkrgr.Fpreserving_proto_field_name)rrr create_sinkrr6) rr^ sink_namer&rkrgsink_pbr/ created_pbs r" sink_createz_SinksAPI.sink_createsY<ykR#@V __000A  JJz "(-  r%cz|jj|}ttj|dS)aCRetrieve a sink resource. Args: sink_name (str): The resource name of the sink, including the parent resource and the sink identifier: :: "projects/[PROJECT_ID]/sinks/[SINK_ID]" "organizations/[ORGANIZATION_ID]/sinks/[SINK_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]/sinks/[SINK_ID]" "folders/[FOLDER_ID]/sinks/[SINK_ID]" Returns: dict: The sink object returned from the API (converted from a protobuf to a dictionary). rpFrm)rget_sinkrrr6)rrprqs r"sink_getz_SinksAPI.sink_gets9$//**Y*? JJw (-  r%c|jdd}t|||}t|||}|jj |}t tj |dS)aUpdate a sink resource. Args: sink_name (str): Required. The resource name of the sink, including the parent resource and the sink identifier: :: "projects/[PROJECT_ID]/sinks/[SINK_ID]" "organizations/[ORGANIZATION_ID]/sinks/[SINK_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]/sinks/[SINK_ID]" "folders/[FOLDER_ID]/sinks/[SINK_ID]" filter_ (str): The advanced logs filter expression defining the entries exported by the sink. destination (str): destination URI for the entries exported by the sink. unique_writer_identity (Optional[bool]): determines the kind of IAM identity returned as writer_identity in the new sink. Returns: dict: The sink resource returned from the API (converted from a protobuf to a dictionary). /ri)rprlrgr.Frm)splitrrr update_sinkrr6)rrpr&rkrgrjrqr/s r" sink_updatez_SinksAPI.sink_update/sw@s#B'#  $#9  //--g-> JJw (-  r%c<|jj|y)aDelete a sink resource. Args: sink_name (str): Required. The full resource name of the sink to delete, including the parent resource and the sink identifier: :: "projects/[PROJECT_ID]/sinks/[SINK_ID]" "organizations/[ORGANIZATION_ID]/sinks/[SINK_ID]" "billingAccounts/[BILLING_ACCOUNT_ID]/sinks/[SINK_ID]" "folders/[FOLDER_ID]/sinks/[SINK_ID]" Example: ``"projects/my-project-id/sinks/my-sink-id"``. ruN)r delete_sink)rrps r" sink_deletez_SinksAPI.sink_deletecs ##i#8r%) rRrSrTrUr#rfrsrwr}rrVr%r"rXrXs=+15QU*&ZRW& P @ % 2 h9r%rXc>eZdZdZdZdddddZdZdZdZd Z y) _MetricsAPIrYc ||_||_yrrrs r"r#z_MetricsAPI.__init__yr$r%Nr[cd|}t|||}jj|}t|}dkr t dfd} | |S)a,List metrics for the project associated with this client. Args: project (str): ID of the project whose metrics are to be listed. 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] projects/r]r.rr0c3Kd}|D]F}|k\rytjtj|j|dz }Hywr`)r rarrbr) metric_iterr8r9r(rs r" metrics_pagerz/_MetricsAPI.list_metrics..metrics_pagers]A$ *qK/?**%%e,T\\Q re)rrlist_log_metricsr=r>) rprojectr(r)r*pathr/r?rrs ` ` r" list_metricsz_MetricsAPI.list_metrics}sp&7)$'!  ??33G3D8n  "{Q;< < [))r%cdd|}t|||}|jj||y)aCreate a metric resource. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.metrics/create Args: project (str): ID of the project in which to create the metric. metric_name (str): The name of the metric filter_ (str): The advanced logs filter expression defining the entries exported by the metric. description (str): description of the metric. rrjr- description)r^metricN)rrcreate_log_metric)rr metric_namer&rr^ metric_pbs r" metric_createz_MetricsAPI.metric_creates5WI&;wKX  )) )Jr%cd|d|}|jj|}ttj|dS)a8Retrieve a metric resource. Args: project (str): ID of the project containing the metric. metric_name (str): The name of the metric Returns: dict: The metric object returned from the API (converted from a protobuf to a dictionary). r /metrics/rFrm)rget_log_metricrrr6)rrrrrs r" metric_getz_MetricsAPI.metric_getsK7)9[M:OO22t2D  LL #(-  r%cd|d|}t|||}|jj||}ttj|dS)aUpdate a metric resource. Args: project (str): ID of the project containing the metric. metric_name (str): the name of the metric filter_ (str): the advanced logs filter expression defining the entries exported by the metric. description (str): description of the metric. Returns: The metric object returned from the API (converted from a protobuf to a dictionary). rrr)rrFrm)rrupdate_log_metricrr6)rrrr&rrrs r" metric_updatez_MetricsAPI.metric_updatesg(7)9[M:# OO55Y6  LL #(-  r%cLd|d|}|jj|y)zDelete a metric resource. Args: project (str): ID of the project containing the metric. metric_name (str): The name of the metric rrrN)rdelete_log_metric)rrrrs r" metric_deletez_MetricsAPI.metric_deletes+7)9[M: ))d);r%) rRrSrTrUr#rrrrrrVr%r"rrvs/+ '+dt**XK" (" Hrs 2LL@1TVV-   AO9&O9dy9y9xD<&D