a !fW@sNdZddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd l mZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZGdddeZGdddeZGdddeZd.ddZ ddZ!ddZ"ddZ#d d!Z$d"d#Z%d$d%Z&d&d'Z'd(d)Z(d*d+Z)d,d-Z*dS)/z%GAX wrapper for Logging API requests.N) CallOptions) INITIAL_PAGE)GaxError) exc_to_code) LogSeverity)LogSink) LogMetric)LogEntry)Parse) StatusCode)Conflict)NotFound)_datetime_to_pb_timestamp)_datetime_to_rfc3339)_pb_timestamp_to_datetimec@s4eZdZdZddZd ddZdd d Zd d ZdS) _LoggingAPIzHelper mapping logging-related APIs. :type gax_api: :class:`google.logging.v2.logging_service_v2_api.LoggingServiceV2Api` :param gax_api: API object used to make GAX requests. cCs ||_dSN_gax_apiselfZgax_apirT/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/logging/_gax.py__init__.sz_LoggingAPI.__init__rNc Cs@t|}|j|||||}dd|D}|jp6d} || fS)aReturn a page of log entry resources. :type projects: list of strings :param projects: project IDs to include. If not passed, defaults to the project bound to the API's client. :type filter_: str :param filter_: a filter expression. See: https://cloud.google.com/logging/docs/view/advanced_filters :type order_by: str :param order_by: One of :data:`gcloud.logging.ASCENDING` or :data:`gcloud.logging.DESCENDING`. :type page_size: int :param page_size: maximum number of entries to return, If not passed, defaults to a value set by the API. :type page_token: str :param page_token: opaque marker for the next "page" of entries. If not passed, the API will return the first page of entries. :rtype: tuple, (list, str) :returns: list of mappings, plus a "next page token" string: if not None, indicates that more entries can be retrieved with another call (pass that value as ``page_token``). cSsg|] }t|qSr)_log_entry_pb_to_mapping).0entry_pbrrr Rsz,_LoggingAPI.list_entries..N)_build_paging_optionsrZlist_log_entriesnext page_token) rZprojectsfilter_Zorder_by page_sizer!options page_iterentriestokenrrr list_entries1s  z_LoggingAPI.list_entriescCs0d}d}dd|D}|j||||||dS)aAPI call: log an entry resource via a POST request :type entries: sequence of mapping :param entries: the log entry resources to log. :type logger_name: string :param logger_name: name of default logger to which to log the entries; individual entries may override. :type resource: mapping :param resource: default resource to associate with entries; individual entries may override. :type labels: mapping :param labels: default labels to associate with entries; individual entries may override. NFcSsg|] }t|qSr)_log_entry_mapping_to_pb)rentryrrrrlz-_LoggingAPI.write_entries..)rZwrite_log_entries)rr& logger_nameresourcelabelsr$Zpartial_successZ entry_pbsrrr write_entriesWs  z_LoggingAPI.write_entriescCs"d}d||f}|j||dS)a$API call: delete all entries in a logger via a DELETE request :type project: string :param project: ID of project containing the log entries to delete :type logger_name: string :param logger_name: name of logger containing the log entries to delete Nzprojects/%s/logs/%s)rZ delete_log)rprojectr,r$pathrrr logger_deleteps  z_LoggingAPI.logger_delete)rrrN)NNN)__name__ __module__ __qualname____doc__rr(r/r2rrrrr's & rc@sBeZdZdZddZdddZdd Zd d Zd d ZddZ dS) _SinksAPIzHelper mapping sink-related APIs. :type gax_api: :class:`google.logging.v2.config_service_v2_api.ConfigServiceV2Api` :param gax_api: API object used to make GAX requests. cCs ||_dSrrrrrrrsz_SinksAPI.__init__rNc CsFt|}d|f}|j|||}dd|D}|jp.N)rr list_sinksr r!) rr0r#r!r$r1r%Zsinksr'rrrr:s  z_SinksAPI.list_sinksc Csd}d|f}t|||d}z|j|||WnJtyz}z2t|jtjkrdd||f} t| WYd}~n d}~00dS)aAPI call: create a sink resource. See: https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/projects.sinks/create :type project: string :param project: ID of the project in which to create the sink. :type sink_name: string :param sink_name: the name of the sink :type filter_: string :param filter_: the advanced logs filter expression defining the entries exported by the sink. :type destination: string :param destination: destination URI for the entries exported by the sink. Nr8namefilter destinationprojects/%s/sinks/%s) rrZ create_sinkrrcauser FAILED_PRECONDITIONr ) rr0 sink_namer"r>r$parentsink_pbexcr1rrr sink_creates  z_SinksAPI.sink_createc Csjd}d||f}z|j||}Wn>ty`}z&t|jtjkrJt|WYd}~n d}~00t|S)ahAPI call: retrieve a sink resource. :type project: string :param project: ID of the project containing the sink. :type sink_name: string :param sink_name: the name of the sink :rtype: dict :returns: The sink object returned from the API (converted from a protobuf to a dictionary). Nr?) rZget_sinkrrr@r NOT_FOUNDr r9)rr0rBr$r1rDrErrrsink_gets  z_SinksAPI.sink_getc Cszd}d||f}t|||d}z|j|||Wn>typ}z&t|jtjkrZt|WYd}~n d}~00t |S)aAPI call: update a sink resource. :type project: string :param project: ID of the project containing the sink. :type sink_name: string :param sink_name: the name of the sink :type filter_: string :param filter_: the advanced logs filter expression defining the entries exported by the sink. :type destination: string :param destination: destination URI for the entries exported by the sink. :rtype: dict :returns: The sink object returned from the API (converted from a protobuf to a dictionary). Nr?r;) rrZ update_sinkrrr@r rGr r9) rr0rBr"r>r$r1rDrErrr sink_updates z_SinksAPI.sink_updatec Csfd}d||f}z|j||Wn>ty`}z&t|jtjkrJt|WYd}~n d}~00dS)zAPI call: delete a sink resource. :type project: string :param project: ID of the project containing the sink. :type sink_name: string :param sink_name: the name of the sink Nr?)rZ delete_sinkrrr@r rGr )rr0rBr$r1rErrr sink_deletes  z_SinksAPI.sink_delete)rN) r3r4r5r6rr:rFrHrIrJrrrrr7~s   r7c@sBeZdZdZddZdddZdd Zd d Zd d ZddZ dS) _MetricsAPIzHelper mapping sink-related APIs. :type gax_api: :class:`google.logging.v2.metrics_service_v2_api.MetricsServiceV2Api` :param gax_api: API object used to make GAX requests. cCs ||_dSrrrrrrrsz_MetricsAPI.__init__rNc CsFt|}d|f}|j|||}dd|D}|jp.N)rrZlist_log_metricsr r!) rr0r#r!r$r1r%Zmetricsr'rrr list_metricss  z_MetricsAPI.list_metricsc Csd}d|f}t|||d}z|j|||WnJtyz}z2t|jtjkrdd||f} t| WYd}~n d}~00dS)aVAPI call: create a metric resource. See: https://cloud.google.com/logging/docs/api/ref_v2beta1/rest/v2beta1/projects.metrics/create :type project: string :param project: ID of the project in which to create the metric. :type metric_name: string :param metric_name: the name of the metric :type filter_: string :param filter_: the advanced logs filter expression defining the entries exported by the metric. :type description: string :param description: description of the metric. Nr8r<r= descriptionprojects/%s/metrics/%s) rrZcreate_log_metricrrr@r rAr ) rr0 metric_namer"rOr$rC metric_pbrEr1rrr metric_create4s  z_MetricsAPI.metric_createc Csjd}d||f}z|j||}Wn>ty`}z&t|jtjkrJt|WYd}~n d}~00t|S)atAPI call: retrieve a metric resource. :type project: string :param project: ID of the project containing the metric. :type metric_name: string :param metric_name: the name of the metric :rtype: dict :returns: The metric object returned from the API (converted from a protobuf to a dictionary). NrP) rZget_log_metricrrr@r rGr rL)rr0rQr$r1rRrErrr metric_getSs  z_MetricsAPI.metric_getc Cszd}d||f}t|||d}z|j|||Wn>typ}z&t|jtjkrZt|WYd}~n d}~00t |S)alAPI call: update a metric resource. :type project: string :param project: ID of the project containing the metric. :type metric_name: string :param metric_name: the name of the metric :type filter_: string :param filter_: the advanced logs filter expression defining the entries exported by the metric. :type description: string :param description: description of the metric. :rtype: dict :returns: The metric object returned from the API (converted from a protobuf to a dictionary). NrPrN) rrZupdate_log_metricrrr@r rGr rL) rr0rQr"rOr$r1rRrErrr metric_updatejs z_MetricsAPI.metric_updatec Csfd}d||f}z|j||Wn>ty`}z&t|jtjkrJt|WYd}~n d}~00dS)zAPI call: delete a metric resource. :type project: string :param project: ID of the project containing the metric. :type metric_name: string :param metric_name: the name of the metric NrP)rZdelete_log_metricrrr@r rGr )rr0rQr$r1rErrr metric_deletes  z_MetricsAPI.metric_delete)rN) r3r4r5r6rrMrSrTrUrVrrrrrKs  rKcCs"|dur t}d|i}tfi|S)z6Helper for :meth:'_PublisherAPI.list_topics' et aliae.Nr!)rr)r!r$rrrrsrcCsd|ji}|jr|j|d<|S)*Helper for :func:_log_entry_pb_to_mappingtyper.)rXr.)Z resource_pbmappingrrr_mon_resource_pb_to_mappings  rZcCst|}t|S)rW)rr)Z timestamp_pb timestamprrr_pb_timestamp_to_rfc3339sr\cCs|d}|durd}nn|dkr(|j}n^|dkr8|j}nN|dkrH|j}n>|dkrddd|jjD}n"|d krxt|j}ntd |f|S) ,Helper for :func:`_log_entry_pb_to_mapping`.kindN string_value bool_value number_value list_valuecSsg|] }t|qSr)_value_pb_to_value)relementrrrrsz&_value_pb_to_value.. struct_valuez#Value protobuf had unknown kind: %s) Z WhichOneofr_r`rarbvalues_struct_pb_to_mappingre ValueError)Zvalue_pbr^resultrrrrcs"  rccstfddjDS)r]csg|]}|tj|fqSr)rcfields)rkeyZ struct_pbrrrsz)_struct_pb_to_mapping..)dictrjrlrrlrrgs rgc Cs|jt|jt|j|jt|j|j d}| dr@|j |d<| drXt |j |d<| drl|j|d<|jr|j}|j|j|j|j|j|j|j|j|jd |d <|jr|j}|j|j|j|jd |d <|S) zHelper for :meth:`list_entries`, et aliae Ideally, would use a function from :mod:`protobuf.json_format`, but the right one isn't public. See: https://github.com/google/protobuf/issues/1351 )logNamer-severityinsertIdr[r. text_payload textPayload json_payload jsonPayload proto_payload protoPayload Z requestMethodZ requestUrlstatusrefererZ userAgentZcacheHitZ requestSizeZ responseSizeZremoteIp httpRequestproduceridfirstlast operation)log_namerZr-rNamero insert_idr\r[r.ZHasFieldrqrgrsru http_requestrequest_method request_urlrxry user_agent cache_hit request_size response_size remote_iprr|r}r~r)rrYrequestrrrrrsB        rc CsFddddddddd d }|D] \}}||vr t||||q d S) #Helper for _log_entry_mapping_to_pbrrrxryrrrrrrwN)itemssetattr)inforZoptional_request_keysrkpb_namerrr_http_request_mapping_to_pb s rcCs<|d|_|d|_d|vr&|d|_d|vr8|d|_dS)rr|r}r~rNr{)rrrrr_log_operation_mapping_to_pbs    rcCsFt}dddd}|D] \}}||vrt||||qd|vrT|dd|j_d|vr~|d}t|trxt|}||_ d|vrt |d}|j |d |vr|d D]\}}||j |<qd |vr|d D]\}}||j|<qd |vrtt|d |jd |vr(t|d |jd |vrBt|d |j|S)zHelper for :meth:`write_entries`, et aliae Ideally, would use a function from :mod:`protobuf.json_format`, but the right one isn't public. See: https://github.com/google/protobuf/issues/1351 rrrq)rnrprrr-rXror[r.rtrvrzr)r rrr-rX isinstancestrrValuerorr[ZCopyFromr.rsr jsondumpsrurrrr)rYrZoptional_scalar_keysrkrror[valuerrrr)(sF           r)cCs|j|j|jdS)zHelper for :meth:`list_sinks`, et aliae Ideally, would use a function from :mod:`protobuf.json_format`, but the right one isn't public. See: https://github.com/google/protobuf/issues/1351 r<r>r=r)rDrrrr9`sr9cCs|j|j|jdS)zHelper for :meth:`list_metrics`, et aliae Ideally, would use a function from :mod:`protobuf.json_format`, but the right one isn't public. See: https://github.com/google/protobuf/issues/1351 r<rOr=r)rRrrrrLnsrL)N)+r6rZ google.gaxrrZgoogle.gax.errorsrZgoogle.gax.grpcrZ$google.logging.type.log_severity_pb2rZ$google.logging.v2.logging_config_pb2rZ%google.logging.v2.logging_metrics_pb2rZgoogle.logging.v2.log_entry_pb2r Zgoogle.protobuf.json_formatr Zgrpc.beta.interfacesr Zgcloud.exceptionsr r Zgcloud._helpersrrrobjectrr7rKrrZr\rcrgrrrr)r9rLrrrrs@               W  2 8