Shortcuts on this page
r m x toggle line displays
j k next/prev highlighted chunk
0 (zero) top of page
1 (one) first highlighted chunk
1# -*- coding: utf-8 -*-
2# Copyright 2025 Google LLC
3#
4# Licensed under the Apache License, Version 2.0 (the "License");
5# you may not use this file except in compliance with the License.
6# You may obtain a copy of the License at
7#
8# http://www.apache.org/licenses/LICENSE-2.0
9#
10# Unless required by applicable law or agreed to in writing, software
11# distributed under the License is distributed on an "AS IS" BASIS,
12# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13# See the License for the specific language governing permissions and
14# limitations under the License.
15#
16import json
17import logging as std_logging
18import pickle
19import warnings
20from typing import Callable, Dict, Optional, Sequence, Tuple, Union
22from google.api_core import grpc_helpers
23from google.api_core import gapic_v1
24import google.auth # type: ignore
25from google.auth import credentials as ga_credentials # type: ignore
26from google.auth.transport.grpc import SslCredentials # type: ignore
27from google.protobuf.json_format import MessageToJson
28import google.protobuf.message
30import grpc # type: ignore
31import proto # type: ignore
33from google.cloud.logging_v2.types import logging_metrics
34from google.longrunning import operations_pb2 # type: ignore
35from google.protobuf import empty_pb2 # type: ignore
36from .base import MetricsServiceV2Transport, DEFAULT_CLIENT_INFO
38try:
39 from google.api_core import client_logging # type: ignore
41 CLIENT_LOGGING_SUPPORTED = True # pragma: NO COVER
42except ImportError: # pragma: NO COVER
43 CLIENT_LOGGING_SUPPORTED = False
45_LOGGER = std_logging.getLogger(__name__)
48class _LoggingClientInterceptor(grpc.UnaryUnaryClientInterceptor): # pragma: NO COVER
49 def intercept_unary_unary(self, continuation, client_call_details, request):
50 logging_enabled = CLIENT_LOGGING_SUPPORTED and _LOGGER.isEnabledFor(
51 std_logging.DEBUG
52 )
53 if logging_enabled: # pragma: NO COVER
54 request_metadata = client_call_details.metadata
55 if isinstance(request, proto.Message):
56 request_payload = type(request).to_json(request)
57 elif isinstance(request, google.protobuf.message.Message):
58 request_payload = MessageToJson(request)
59 else:
60 request_payload = f"{type(request).__name__}: {pickle.dumps(request)}"
62 request_metadata = {
63 key: value.decode("utf-8") if isinstance(value, bytes) else value
64 for key, value in request_metadata
65 }
66 grpc_request = {
67 "payload": request_payload,
68 "requestMethod": "grpc",
69 "metadata": dict(request_metadata),
70 }
71 _LOGGER.debug(
72 f"Sending request for {client_call_details.method}",
73 extra={
74 "serviceName": "google.logging.v2.MetricsServiceV2",
75 "rpcName": str(client_call_details.method),
76 "request": grpc_request,
77 "metadata": grpc_request["metadata"],
78 },
79 )
80 response = continuation(client_call_details, request)
81 if logging_enabled: # pragma: NO COVER
82 response_metadata = response.trailing_metadata()
83 # Convert gRPC metadata `<class 'grpc.aio._metadata.Metadata'>` to list of tuples
84 metadata = (
85 dict([(k, str(v)) for k, v in response_metadata])
86 if response_metadata
87 else None
88 )
89 result = response.result()
90 if isinstance(result, proto.Message):
91 response_payload = type(result).to_json(result)
92 elif isinstance(result, google.protobuf.message.Message):
93 response_payload = MessageToJson(result)
94 else:
95 response_payload = f"{type(result).__name__}: {pickle.dumps(result)}"
96 grpc_response = {
97 "payload": response_payload,
98 "metadata": metadata,
99 "status": "OK",
100 }
101 _LOGGER.debug(
102 f"Received response for {client_call_details.method}.",
103 extra={
104 "serviceName": "google.logging.v2.MetricsServiceV2",
105 "rpcName": client_call_details.method,
106 "response": grpc_response,
107 "metadata": grpc_response["metadata"],
108 },
109 )
110 return response
113class MetricsServiceV2GrpcTransport(MetricsServiceV2Transport):
114 """gRPC backend transport for MetricsServiceV2.
116 Service for configuring logs-based metrics.
118 This class defines the same methods as the primary client, so the
119 primary client can load the underlying transport implementation
120 and call it.
122 It sends protocol buffers over the wire using gRPC (which is built on
123 top of HTTP/2); the ``grpcio`` package must be installed.
124 """
126 _stubs: Dict[str, Callable]
128 def __init__(
129 self,
130 *,
131 host: str = "logging.googleapis.com",
132 credentials: Optional[ga_credentials.Credentials] = None,
133 credentials_file: Optional[str] = None,
134 scopes: Optional[Sequence[str]] = None,
135 channel: Optional[Union[grpc.Channel, Callable[..., grpc.Channel]]] = None,
136 api_mtls_endpoint: Optional[str] = None,
137 client_cert_source: Optional[Callable[[], Tuple[bytes, bytes]]] = None,
138 ssl_channel_credentials: Optional[grpc.ChannelCredentials] = None,
139 client_cert_source_for_mtls: Optional[Callable[[], Tuple[bytes, bytes]]] = None,
140 quota_project_id: Optional[str] = None,
141 client_info: gapic_v1.client_info.ClientInfo = DEFAULT_CLIENT_INFO,
142 always_use_jwt_access: Optional[bool] = False,
143 api_audience: Optional[str] = None,
144 ) -> None:
145 """Instantiate the transport.
147 Args:
148 host (Optional[str]):
149 The hostname to connect to (default: 'logging.googleapis.com').
150 credentials (Optional[google.auth.credentials.Credentials]): The
151 authorization credentials to attach to requests. These
152 credentials identify the application to the service; if none
153 are specified, the client will attempt to ascertain the
154 credentials from the environment.
155 This argument is ignored if a ``channel`` instance is provided.
156 credentials_file (Optional[str]): Deprecated. A file with credentials that can
157 be loaded with :func:`google.auth.load_credentials_from_file`.
158 This argument is ignored if a ``channel`` instance is provided.
159 This argument will be removed in the next major version of this library.
160 scopes (Optional(Sequence[str])): A list of scopes. This argument is
161 ignored if a ``channel`` instance is provided.
162 channel (Optional[Union[grpc.Channel, Callable[..., grpc.Channel]]]):
163 A ``Channel`` instance through which to make calls, or a Callable
164 that constructs and returns one. If set to None, ``self.create_channel``
165 is used to create the channel. If a Callable is given, it will be called
166 with the same arguments as used in ``self.create_channel``.
167 api_mtls_endpoint (Optional[str]): Deprecated. The mutual TLS endpoint.
168 If provided, it overrides the ``host`` argument and tries to create
169 a mutual TLS channel with client SSL credentials from
170 ``client_cert_source`` or application default SSL credentials.
171 client_cert_source (Optional[Callable[[], Tuple[bytes, bytes]]]):
172 Deprecated. A callback to provide client SSL certificate bytes and
173 private key bytes, both in PEM format. It is ignored if
174 ``api_mtls_endpoint`` is None.
175 ssl_channel_credentials (grpc.ChannelCredentials): SSL credentials
176 for the grpc channel. It is ignored if a ``channel`` instance is provided.
177 client_cert_source_for_mtls (Optional[Callable[[], Tuple[bytes, bytes]]]):
178 A callback to provide client certificate bytes and private key bytes,
179 both in PEM format. It is used to configure a mutual TLS channel. It is
180 ignored if a ``channel`` instance or ``ssl_channel_credentials`` is provided.
181 quota_project_id (Optional[str]): An optional project to use for billing
182 and quota.
183 client_info (google.api_core.gapic_v1.client_info.ClientInfo):
184 The client info used to send a user-agent string along with
185 API requests. If ``None``, then default info will be used.
186 Generally, you only need to set this if you're developing
187 your own client library.
188 always_use_jwt_access (Optional[bool]): Whether self signed JWT should
189 be used for service account credentials.
191 Raises:
192 google.auth.exceptions.MutualTLSChannelError: If mutual TLS transport
193 creation failed for any reason.
194 google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
195 and ``credentials_file`` are passed.
196 """
197 self._grpc_channel = None
198 self._ssl_channel_credentials = ssl_channel_credentials
199 self._stubs: Dict[str, Callable] = {}
201 if api_mtls_endpoint:
202 warnings.warn("api_mtls_endpoint is deprecated", DeprecationWarning)
203 if client_cert_source:
204 warnings.warn("client_cert_source is deprecated", DeprecationWarning)
206 if isinstance(channel, grpc.Channel):
207 # Ignore credentials if a channel was passed.
208 credentials = None
209 self._ignore_credentials = True
210 # If a channel was explicitly provided, set it.
211 self._grpc_channel = channel
212 self._ssl_channel_credentials = None
214 else:
215 if api_mtls_endpoint:
216 host = api_mtls_endpoint
218 # Create SSL credentials with client_cert_source or application
219 # default SSL credentials.
220 if client_cert_source:
221 cert, key = client_cert_source()
222 self._ssl_channel_credentials = grpc.ssl_channel_credentials(
223 certificate_chain=cert, private_key=key
224 )
225 else:
226 self._ssl_channel_credentials = SslCredentials().ssl_credentials
228 else:
229 if client_cert_source_for_mtls and not ssl_channel_credentials:
230 cert, key = client_cert_source_for_mtls()
231 self._ssl_channel_credentials = grpc.ssl_channel_credentials(
232 certificate_chain=cert, private_key=key
233 )
235 # The base transport sets the host, credentials and scopes
236 super().__init__(
237 host=host,
238 credentials=credentials,
239 credentials_file=credentials_file,
240 scopes=scopes,
241 quota_project_id=quota_project_id,
242 client_info=client_info,
243 always_use_jwt_access=always_use_jwt_access,
244 api_audience=api_audience,
245 )
247 if not self._grpc_channel:
248 # initialize with the provided callable or the default channel
249 channel_init = channel or type(self).create_channel
250 self._grpc_channel = channel_init(
251 self._host,
252 # use the credentials which are saved
253 credentials=self._credentials,
254 # Set ``credentials_file`` to ``None`` here as
255 # the credentials that we saved earlier should be used.
256 credentials_file=None,
257 scopes=self._scopes,
258 ssl_credentials=self._ssl_channel_credentials,
259 quota_project_id=quota_project_id,
260 options=[
261 ("grpc.max_send_message_length", -1),
262 ("grpc.max_receive_message_length", -1),
263 ],
264 )
266 self._interceptor = _LoggingClientInterceptor()
267 self._logged_channel = grpc.intercept_channel(
268 self._grpc_channel, self._interceptor
269 )
271 # Wrap messages. This must be done after self._logged_channel exists
272 self._prep_wrapped_messages(client_info)
274 @classmethod
275 def create_channel(
276 cls,
277 host: str = "logging.googleapis.com",
278 credentials: Optional[ga_credentials.Credentials] = None,
279 credentials_file: Optional[str] = None,
280 scopes: Optional[Sequence[str]] = None,
281 quota_project_id: Optional[str] = None,
282 **kwargs,
283 ) -> grpc.Channel:
284 """Create and return a gRPC channel object.
285 Args:
286 host (Optional[str]): The host for the channel to use.
287 credentials (Optional[~.Credentials]): The
288 authorization credentials to attach to requests. These
289 credentials identify this application to the service. If
290 none are specified, the client will attempt to ascertain
291 the credentials from the environment.
292 credentials_file (Optional[str]): Deprecated. A file with credentials that can
293 be loaded with :func:`google.auth.load_credentials_from_file`.
294 This argument is mutually exclusive with credentials. This argument will be
295 removed in the next major version of this library.
296 scopes (Optional[Sequence[str]]): A optional list of scopes needed for this
297 service. These are only used when credentials are not specified and
298 are passed to :func:`google.auth.default`.
299 quota_project_id (Optional[str]): An optional project to use for billing
300 and quota.
301 kwargs (Optional[dict]): Keyword arguments, which are passed to the
302 channel creation.
303 Returns:
304 grpc.Channel: A gRPC channel object.
306 Raises:
307 google.api_core.exceptions.DuplicateCredentialArgs: If both ``credentials``
308 and ``credentials_file`` are passed.
309 """
311 return grpc_helpers.create_channel(
312 host,
313 credentials=credentials,
314 credentials_file=credentials_file,
315 quota_project_id=quota_project_id,
316 default_scopes=cls.AUTH_SCOPES,
317 scopes=scopes,
318 default_host=cls.DEFAULT_HOST,
319 **kwargs,
320 )
322 @property
323 def grpc_channel(self) -> grpc.Channel:
324 """Return the channel designed to connect to this service."""
325 return self._grpc_channel
327 @property
328 def list_log_metrics(
329 self,
330 ) -> Callable[
331 [logging_metrics.ListLogMetricsRequest], logging_metrics.ListLogMetricsResponse
332 ]:
333 r"""Return a callable for the list log metrics method over gRPC.
335 Lists logs-based metrics.
337 Returns:
338 Callable[[~.ListLogMetricsRequest],
339 ~.ListLogMetricsResponse]:
340 A function that, when called, will call the underlying RPC
341 on the server.
342 """
343 # Generate a "stub function" on-the-fly which will actually make
344 # the request.
345 # gRPC handles serialization and deserialization, so we just need
346 # to pass in the functions for each.
347 if "list_log_metrics" not in self._stubs:
348 self._stubs["list_log_metrics"] = self._logged_channel.unary_unary(
349 "/google.logging.v2.MetricsServiceV2/ListLogMetrics",
350 request_serializer=logging_metrics.ListLogMetricsRequest.serialize,
351 response_deserializer=logging_metrics.ListLogMetricsResponse.deserialize,
352 )
353 return self._stubs["list_log_metrics"]
355 @property
356 def get_log_metric(
357 self,
358 ) -> Callable[[logging_metrics.GetLogMetricRequest], logging_metrics.LogMetric]:
359 r"""Return a callable for the get log metric method over gRPC.
361 Gets a logs-based metric.
363 Returns:
364 Callable[[~.GetLogMetricRequest],
365 ~.LogMetric]:
366 A function that, when called, will call the underlying RPC
367 on the server.
368 """
369 # Generate a "stub function" on-the-fly which will actually make
370 # the request.
371 # gRPC handles serialization and deserialization, so we just need
372 # to pass in the functions for each.
373 if "get_log_metric" not in self._stubs:
374 self._stubs["get_log_metric"] = self._logged_channel.unary_unary(
375 "/google.logging.v2.MetricsServiceV2/GetLogMetric",
376 request_serializer=logging_metrics.GetLogMetricRequest.serialize,
377 response_deserializer=logging_metrics.LogMetric.deserialize,
378 )
379 return self._stubs["get_log_metric"]
381 @property
382 def create_log_metric(
383 self,
384 ) -> Callable[[logging_metrics.CreateLogMetricRequest], logging_metrics.LogMetric]:
385 r"""Return a callable for the create log metric method over gRPC.
387 Creates a logs-based metric.
389 Returns:
390 Callable[[~.CreateLogMetricRequest],
391 ~.LogMetric]:
392 A function that, when called, will call the underlying RPC
393 on the server.
394 """
395 # Generate a "stub function" on-the-fly which will actually make
396 # the request.
397 # gRPC handles serialization and deserialization, so we just need
398 # to pass in the functions for each.
399 if "create_log_metric" not in self._stubs:
400 self._stubs["create_log_metric"] = self._logged_channel.unary_unary(
401 "/google.logging.v2.MetricsServiceV2/CreateLogMetric",
402 request_serializer=logging_metrics.CreateLogMetricRequest.serialize,
403 response_deserializer=logging_metrics.LogMetric.deserialize,
404 )
405 return self._stubs["create_log_metric"]
407 @property
408 def update_log_metric(
409 self,
410 ) -> Callable[[logging_metrics.UpdateLogMetricRequest], logging_metrics.LogMetric]:
411 r"""Return a callable for the update log metric method over gRPC.
413 Creates or updates a logs-based metric.
415 Returns:
416 Callable[[~.UpdateLogMetricRequest],
417 ~.LogMetric]:
418 A function that, when called, will call the underlying RPC
419 on the server.
420 """
421 # Generate a "stub function" on-the-fly which will actually make
422 # the request.
423 # gRPC handles serialization and deserialization, so we just need
424 # to pass in the functions for each.
425 if "update_log_metric" not in self._stubs:
426 self._stubs["update_log_metric"] = self._logged_channel.unary_unary(
427 "/google.logging.v2.MetricsServiceV2/UpdateLogMetric",
428 request_serializer=logging_metrics.UpdateLogMetricRequest.serialize,
429 response_deserializer=logging_metrics.LogMetric.deserialize,
430 )
431 return self._stubs["update_log_metric"]
433 @property
434 def delete_log_metric(
435 self,
436 ) -> Callable[[logging_metrics.DeleteLogMetricRequest], empty_pb2.Empty]:
437 r"""Return a callable for the delete log metric method over gRPC.
439 Deletes a logs-based metric.
441 Returns:
442 Callable[[~.DeleteLogMetricRequest],
443 ~.Empty]:
444 A function that, when called, will call the underlying RPC
445 on the server.
446 """
447 # Generate a "stub function" on-the-fly which will actually make
448 # the request.
449 # gRPC handles serialization and deserialization, so we just need
450 # to pass in the functions for each.
451 if "delete_log_metric" not in self._stubs:
452 self._stubs["delete_log_metric"] = self._logged_channel.unary_unary(
453 "/google.logging.v2.MetricsServiceV2/DeleteLogMetric",
454 request_serializer=logging_metrics.DeleteLogMetricRequest.serialize,
455 response_deserializer=empty_pb2.Empty.FromString,
456 )
457 return self._stubs["delete_log_metric"]
459 def close(self):
460 self._logged_channel.close()
462 @property
463 def cancel_operation(
464 self,
465 ) -> Callable[[operations_pb2.CancelOperationRequest], None]:
466 r"""Return a callable for the cancel_operation method over gRPC."""
467 # Generate a "stub function" on-the-fly which will actually make
468 # the request.
469 # gRPC handles serialization and deserialization, so we just need
470 # to pass in the functions for each.
471 if "cancel_operation" not in self._stubs:
472 self._stubs["cancel_operation"] = self._logged_channel.unary_unary(
473 "/google.longrunning.Operations/CancelOperation",
474 request_serializer=operations_pb2.CancelOperationRequest.SerializeToString,
475 response_deserializer=None,
476 )
477 return self._stubs["cancel_operation"]
479 @property
480 def get_operation(
481 self,
482 ) -> Callable[[operations_pb2.GetOperationRequest], operations_pb2.Operation]:
483 r"""Return a callable for the get_operation method over gRPC."""
484 # Generate a "stub function" on-the-fly which will actually make
485 # the request.
486 # gRPC handles serialization and deserialization, so we just need
487 # to pass in the functions for each.
488 if "get_operation" not in self._stubs:
489 self._stubs["get_operation"] = self._logged_channel.unary_unary(
490 "/google.longrunning.Operations/GetOperation",
491 request_serializer=operations_pb2.GetOperationRequest.SerializeToString,
492 response_deserializer=operations_pb2.Operation.FromString,
493 )
494 return self._stubs["get_operation"]
496 @property
497 def list_operations(
498 self,
499 ) -> Callable[
500 [operations_pb2.ListOperationsRequest], operations_pb2.ListOperationsResponse
501 ]:
502 r"""Return a callable for the list_operations method over gRPC."""
503 # Generate a "stub function" on-the-fly which will actually make
504 # the request.
505 # gRPC handles serialization and deserialization, so we just need
506 # to pass in the functions for each.
507 if "list_operations" not in self._stubs:
508 self._stubs["list_operations"] = self._logged_channel.unary_unary(
509 "/google.longrunning.Operations/ListOperations",
510 request_serializer=operations_pb2.ListOperationsRequest.SerializeToString,
511 response_deserializer=operations_pb2.ListOperationsResponse.FromString,
512 )
513 return self._stubs["list_operations"]
515 @property
516 def kind(self) -> str:
517 return "grpc"
520__all__ = ("MetricsServiceV2GrpcTransport",)