]j&PdZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z Gd d ejZGd d eZGd deZGddeZddZdZdZdZy)z/Interact with Cloud Logging via JSON-over-HTTP.N) page_iterator)_http) __version__)entry_from_resource)Metric)Sinkc4eZdZdZdedfd ZdZ dZxZS) Connectionzhttps://logging.googleapis.comN) client_info api_endpointctt| ||||_t|j _t|j _y)a,A connection to Google Cloud Logging via the JSON REST API. Args: client (google.cloud.logging_v2.cliet.Client): The client that owns the current connection. client_info (Optional[google.api_core.client_info.ClientInfo]): Instance used to generate user agent. client_options (Optional[google.api_core.client_options.ClientOptions]): Client options used to set user options on the client. API Endpoint should be set through client_options. N)superr __init__ API_BASE_URLr _client_info gapic_versionclient_library_version)selfclientr r __class__s G/root/env/lib/python3.12/site-packages/google/cloud/logging_v2/_http.pyrzConnection.__init__s: j$(=(*5'3>0v2z"{api_base_url}/{api_version}{path})__name__ __module__ __qualname__DEFAULT_API_ENDPOINTr API_VERSIONAPI_URL_TEMPLATE __classcell__)rs@rr r s';.2AU?"KF;:rr cDeZdZdZdZdddddddZddddddd Zd Zy) _LoggingAPIa?Helper mapping logging-related APIs. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.logs :type client: :class:`~google.cloud.logging.client.Client` :param client: The client used to make API requests. cH||_|jj|_yN_client _connection api_requestrrs rrz_LoggingAPI.__init__B !--99rN)filter_order_by max_results page_size page_tokenc  d|i}|||d<|||d<|||d<d}i} tjt| } tj|j |j j j|| d||} d | _t| |S) a#Return a page 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] resourceNamesfilterorderBypageSizez /entries:list)loggersentriesrr(path item_to_value items_keyr/ extra_paramsPOST) functoolspartial_item_to_entryr HTTPIteratorr&r'r( _HTTP_METHOD_entries_pager) rresource_namesr+r,r-r.r/r;r8r5r9iterators r list_entriesz_LoggingAPI.list_entriesFsL(8  %,L "  &.L #  '0L $!)).'J  --<< 00<<'!% !'h 44rTF) logger_nameresourcelabelspartial_successdry_runctt|||d}|||d<|||d<|||d<|jdd|y) aLog an entry resource via a POST request See https://cloud.google.com/logging/docs/reference/v2/rest/v2/entries/write 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. )r6partialSuccessrJNlogNamerGrHr<z/entries:writemethodr8data)listr()rr6rFrGrHrIrJrPs r write_entriesz_LoggingAPI.write_entriess_LG}-   ")DO  'D   #DN -=DIrc4d|}|jd|y)aqDelete all entries in a logger. Args: logger_name (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"``. /DELETErOr8Nr()rrFr8s r logger_deletez_LoggingAPI.logger_deletes#";-  t4r)rrr__doc__rrErRrXrrr"r"7sA:C5R4Jl5rr"cJeZdZdZdZdddddZdddZd Zddd Zd Z y) _SinksAPIz}Helper mapping sink-related APIs. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks cH||_|jj|_yr$r%r)s rrz_SinksAPI.__init__r*rNr-r.r/c i}|||d<d|d}tj|j|jjj|t d||}t ||S)aUList sinks for the parent resource. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.sinks/list 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] r4rT/sinkssinksr7)rr@r&r'r( _item_to_sinkrB)rparentr-r.r/r;r8rDs r list_sinksz_SinksAPI.list_sinksso6  '0L $6(&! --<< 00<<'!% h 44rF)unique_writer_identitycLd|d}|||d}d|i}|jd|||S)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: :: "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. rTr`namer2 destinationuniqueWriterIdentityr<)rOr8rP query_paramsrW) rrc sink_namer+riretargetrPrks r sink_createz_SinksAPI.sink_createsJ8VHF#!W[Q.0FG T    rc2d|}|jd|S)aRetrieve a sink resource. Args: sink_name (str): The resource name of the sink: :: "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 JSON sink object returned from the API. rTGETrVrWrrlrms rsink_getz_SinksAPI.sink_get1s% YKu6::rcrd|}|jdd}|||d}d|i}|jd|||S)a8Update a sink resource. Args: sink_name (str): Required. The resource name of the sink: :: "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 returned (updated) resource. rTrgrjPUT)rOr8rkrP)splitr() rrlr+rirermrhrPrks r sink_updatez_SinksAPI.sink_updateDsZ2YKs#B' L.0FG vLt   rc4d|}|jd|y)a0Delete 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"``. rTrUrVNrWrqs r sink_deletez_SinksAPI.sink_deletees" YK v6r) rrrrYrrdrnrrrwryrZrrr\r\s@ :15QU+5\RW! F;(JO B7rr\c>eZdZdZdZdddddZdZdZdZd Z y) _MetricsAPIz!Helper mapping sink-related APIs.cH||_|jj|_yr$r%r)s rrz_MetricsAPI.__init__|r*rNr^c i}|||d<d|d}tj|j|jjj|t d||}t ||S)aFList 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] r4 /projects//metricsmetricsr7)rr@r&r'r(_item_to_metricrB)rprojectr-r.r/r;r8rDs r list_metricsz_MetricsAPI.list_metricsso,  '0L $G9H- --<< 00<<)!% h 44rcDd|d}|||d}|jd||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. r~rrhr2 descriptionr<rNNrWrr metric_namer+rrmrPs r metric_createz_MetricsAPI.metric_creates3gYh/#w{S V$?rc8d|d|}|jd|S)zRetrieve a metric resource. Args: project (str): ID of the project containing the metric. metric_name (str): The name of the metric Returns: dict: The JSON metric object returned from the API. r~ /metrics/rprVrWrrrrms r metric_getz_MetricsAPI.metric_gets,gYi }=u6::rcFd|d|}|||d}|jd||S)aUpdate a metric resource. See https://cloud.google.com/logging/docs/reference/v2/rest/v2/projects.metrics/update 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: dict: The returned (updated) resource. r~rrrurNrWrs r metric_updatez_MetricsAPI.metric_updates: gYi }=#w{Su6EErc:d|d|}|jd|y)zDelete a metric resource. Args: project (str): ID of the project containing the metric. metric_name (str): The name of the metric r~rrUrVNrWrs r metric_deletez_MetricsAPI.metric_deletes)gYi }= v6r) rrrrYrrrrrrrZrrr{r{ys/+: '+dt%5N@" ;F(7rr{c#fK||dkr tdd}|D]}|||k\ry||dz }yw)Nrzmax_results must be positive) ValueError) page_iterr-ipages rrBrBsP;?788 A  "qK'7   Q s/1c0t||j|S)aConvert a log entry resource to the native object. .. note:: This method does not have the correct signature to be used as the ``item_to_value`` argument to :class:`~google.api_core.page_iterator.Iterator`. It is intended to be patched with a mutable ``loggers`` argument that can be updated on subsequent calls. For an example, see how the method is used above in :meth:`_LoggingAPI.list_entries`. Args: iterator (google.api_core.page_iterator.Iterator): The iterator that is currently in use. resource (dict): Log entry JSON resource returned from the API. loggers (Mapping[str, logging_v2.logger.Logger]): A mapping of logger fullnames -> loggers. If the logger that owns the entry is not in ``loggers``, the entry will have a newly-created logger. Returns: ~logging_v2.entries._BaseEntry: The next log entry in the page. )rr)rDrGr5s rr?r?s0 x' BBrcBtj||jS)a6Convert a sink resource to the native object. Args: iterator (google.api_core.page_iterator.Iterator): The iterator that is currently in use. resource (dict): Sink JSON resource returned from the API. Returns: ~logging_v2.sink.Sink: The next sink in the page. )r from_api_reprrrDrGs rrbrb s   h 88rcBtj||jS)aJConvert a metric resource to the native object. Args: iterator (google.api_core.page_iterator.Iterator): The iterator that is currently in use. resource (dict): Sink JSON resource returned from the API. Returns: ~logging_v2.metric.Metric: The next metric in the page. )rrrrs rrrs   (// ::rr$)rYr=google.api_corer google.cloudrgoogle.cloud.logging_v2r google.cloud.logging_v2._helpersrgoogle.cloud.logging_v2.metricrgoogle.cloud.logging_v2.sinkrJSONConnectionr objectr"r\r{rBr?rbrrZrrrss6)/@1-;%%;6\5&\5~`7`7Fh7&h7V C6 9 ;r