# Package Methods (1.19.0) 1.19.0 (latest) 1.18.0 1.17.0 1.16.0 1.15.0 1.14.1 1.13.2 1.12.0 1.11.0 1.10.1 1.9.5 1.8.0 1.7.0 1.6.1 1.5.1 1.4.1 1.3.0 1.2.2 1.1.1 1.0.2 0.4.3 0.3.1 0.2.0 0.1.3 Summary of entries of Methods for datastream. ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient DatastreamAsyncClient( *, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[ typing.Union[ str, google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport, typing.Callable[ [...], google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport, ], ] ] = "grpc_asyncio", client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo ) Instantiates the datastream async client. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_DatastreamAsyncClient) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.cancel_operation cancel_operation( request: typing.Optional[ typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> None Starts asynchronous cancellation on a long-running operation. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.cancel_operation](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_cancel_operation) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_billing_account_path common_billing_account_path(billing_account: str) -> str Returns a fully-qualified billing_account string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_billing_account_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_common_billing_account_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_folder_path common_folder_path(folder: str) -> str Returns a fully-qualified folder string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_folder_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_common_folder_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_location_path common_location_path(project: str, location: str) -> str Returns a fully-qualified location string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_location_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_common_location_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_organization_path common_organization_path(organization: str) -> str Returns a fully-qualified organization string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_organization_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_common_organization_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_project_path common_project_path(project: str) -> str Returns a fully-qualified project string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.common_project_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_common_project_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.connection_profile_path connection_profile_path( project: str, location: str, connection_profile: str ) -> str Returns a fully-qualified connection_profile string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.connection_profile_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_connection_profile_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_connection_profile create_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.CreateConnectionProfileRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, connection_profile: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile ] = None, connection_profile_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to create a connection profile in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_create_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_private_connection create_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.CreatePrivateConnectionRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, private_connection: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.PrivateConnection ] = None, private_connection_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to create a private connectivity configuration. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_create_private_connection) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_route create_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.CreateRouteRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, route: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.Route ] = None, route_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to create a route for a private connectivity configuration in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_create_route) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_stream create_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.CreateStreamRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, stream: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.Stream ] = None, stream_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to create a stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.create_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_create_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_connection_profile delete_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DeleteConnectionProfileRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to delete a connection profile. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_delete_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_operation delete_operation( request: typing.Optional[ typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> None Deletes a long-running operation. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_operation](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_delete_operation) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_private_connection delete_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DeletePrivateConnectionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to delete a private connectivity configuration. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_delete_private_connection) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_route delete_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DeleteRouteRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to delete a route. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_delete_route) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_stream delete_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DeleteStreamRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to delete a stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.delete_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_delete_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.discover_connection_profile discover_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileRequest, dict, ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileResponse Use this method to discover a connection profile. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.discover_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_discover_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.fetch_static_ips fetch_static_ips( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager The FetchStaticIps API call exposes the static IP addresses used by Datastream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.fetch_static_ips](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_fetch_static_ips) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_file from_service_account_file(filename: str, *args, **kwargs) Creates an instance of this client using the provided credentials file. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_file](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_from_service_account_file) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_info from_service_account_info(info: dict, *args, **kwargs) Creates an instance of this client using the provided credentials info. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_info](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_from_service_account_info) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_json from_service_account_json(filename: str, *args, **kwargs) Creates an instance of this client using the provided credentials file. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.from_service_account_json](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_from_service_account_json) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_connection_profile get_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.GetConnectionProfileRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile Use this method to get details about a connection profile. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_location get_location( request: typing.Optional[ typing.Union[google.cloud.location.locations_pb2.GetLocationRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.Location Gets information about a location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_location](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_location) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, ) Return the API endpoint and client cert source for mutual TLS. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_mtls_endpoint_and_cert_source) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_operation get_operation( request: typing.Optional[ typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.Operation Gets the latest state of a long-running operation. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_operation](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_operation) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_private_connection get_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.GetPrivateConnectionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.PrivateConnection Use this method to get details about a private connectivity configuration. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_private_connection) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_route get_route( request: typing.Optional[ typing.Union[google.cloud.datastream_v1.types.datastream.GetRouteRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.Route Use this method to get details about a route. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_route) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream get_stream( request: typing.Optional[ typing.Union[google.cloud.datastream_v1.types.datastream.GetStreamRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.Stream Use this method to get details about a stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream_object get_stream_object( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.GetStreamObjectRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject Use this method to get details about a stream object. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_stream_object](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_stream_object) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_transport_class get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport ] Returns an appropriate transport class. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.get_transport_class](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_get_transport_class) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_connection_profiles list_connection_profiles( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager ) Use this method to list connection profiles created in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_connection_profiles](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_list_connection_profiles) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_locations list_locations( request: typing.Optional[ typing.Union[google.cloud.location.locations_pb2.ListLocationsRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.ListLocationsResponse Lists information about the supported locations for this service. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_locations](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_list_locations) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_operations list_operations( request: typing.Optional[ typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponse Lists operations that match the specified filter in the request. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_operations](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_list_operations) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_private_connections list_private_connections( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager ) Use this method to list private connectivity configurations in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_private_connections](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_list_private_connections) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_routes list_routes( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListRoutesRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager Use this method to list routes created for a private connectivity configuration in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_routes](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_list_routes) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_stream_objects list_stream_objects( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager Use this method to list the objects of a specific stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_stream_objects](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_list_stream_objects) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_streams list_streams( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListStreamsRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager Use this method to list streams in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.list_streams](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_list_streams) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.lookup_stream_object lookup_stream_object( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.LookupStreamObjectRequest, dict ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject Use this method to look up a stream object by its source object identifier. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.lookup_stream_object](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_lookup_stream_object) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.network_attachment_path network_attachment_path(project: str, region: str, network_attachment: str) -> str Returns a fully-qualified network_attachment string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.network_attachment_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_network_attachment_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.networks_path networks_path(project: str, network: str) -> str Returns a fully-qualified networks string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.networks_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_networks_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_billing_account_path parse_common_billing_account_path(path: str) -> typing.Dict[str, str] Parse a billing_account path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_billing_account_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_common_billing_account_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_folder_path parse_common_folder_path(path: str) -> typing.Dict[str, str] Parse a folder path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_folder_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_common_folder_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_location_path parse_common_location_path(path: str) -> typing.Dict[str, str] Parse a location path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_location_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_common_location_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_organization_path parse_common_organization_path(path: str) -> typing.Dict[str, str] Parse a organization path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_organization_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_common_organization_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_project_path parse_common_project_path(path: str) -> typing.Dict[str, str] Parse a project path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_common_project_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_common_project_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path parse_connection_profile_path(path: str) -> typing.Dict[str, str] Parses a connection_profile path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_connection_profile_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_network_attachment_path parse_network_attachment_path(path: str) -> typing.Dict[str, str] Parses a network_attachment path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_network_attachment_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_network_attachment_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_networks_path parse_networks_path(path: str) -> typing.Dict[str, str] Parses a networks path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_networks_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_networks_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_private_connection_path parse_private_connection_path(path: str) -> typing.Dict[str, str] Parses a private_connection path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_private_connection_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_private_connection_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_route_path parse_route_path(path: str) -> typing.Dict[str, str] Parses a route path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_route_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_route_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_object_path parse_stream_object_path(path: str) -> typing.Dict[str, str] Parses a stream_object path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_object_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_stream_object_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_path parse_stream_path(path: str) -> typing.Dict[str, str] Parses a stream path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.parse_stream_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_parse_stream_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.private_connection_path private_connection_path( project: str, location: str, private_connection: str ) -> str Returns a fully-qualified private_connection string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.private_connection_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_private_connection_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.route_path route_path(project: str, location: str, private_connection: str, route: str) -> str Returns a fully-qualified route string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.route_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_route_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.run_stream run_stream( request: typing.Optional[ typing.Union[google.cloud.datastream_v1.types.datastream.RunStreamRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to start, resume or recover a stream with a non default CDC strategy. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.run_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_run_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.start_backfill_job start_backfill_job( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.StartBackfillJobRequest, dict ] ] = None, *, object_: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.StartBackfillJobResponse Use this method to start a backfill job for the specified stream object. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.start_backfill_job](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_start_backfill_job) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stop_backfill_job stop_backfill_job( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.StopBackfillJobRequest, dict ] ] = None, *, object_: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.StopBackfillJobResponse Use this method to stop a backfill job for the specified stream object. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stop_backfill_job](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_stop_backfill_job) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_object_path stream_object_path(project: str, location: str, stream: str, object: str) -> str Returns a fully-qualified stream_object string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_object_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_stream_object_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_path stream_path(project: str, location: str, stream: str) -> str Returns a fully-qualified stream string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.stream_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_stream_path) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_connection_profile update_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.UpdateConnectionProfileRequest, dict, ] ] = None, *, connection_profile: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to update the parameters of a connection profile. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_update_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_stream update_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.UpdateStreamRequest, dict ] ] = None, *, stream: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.Stream ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to update the configuration of a stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient.update_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1_services_datastream_DatastreamAsyncClient_update_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamClient DatastreamClient( *, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[ typing.Union[ str, google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport, typing.Callable[ [...], google.cloud.datastream_v1.services.datastream.transports.base.DatastreamTransport, ], ] ] = None, client_options: typing.Optional[ typing.Union[google.api_core.client_options.ClientOptions, dict] ] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo ) Instantiates the datastream client. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_DatastreamClient) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.__exit__ __exit__(type, value, traceback) Releases underlying transport's resources. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.**exit**](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient___exit__) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.cancel_operation cancel_operation( request: typing.Optional[ typing.Union[google.longrunning.operations_pb2.CancelOperationRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> None Starts asynchronous cancellation on a long-running operation. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.cancel_operation](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_cancel_operation) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.common_billing_account_path common_billing_account_path(billing_account: str) -> str Returns a fully-qualified billing_account string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.common_billing_account_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_common_billing_account_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.common_folder_path common_folder_path(folder: str) -> str Returns a fully-qualified folder string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.common_folder_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_common_folder_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.common_location_path common_location_path(project: str, location: str) -> str Returns a fully-qualified location string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.common_location_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_common_location_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.common_organization_path common_organization_path(organization: str) -> str Returns a fully-qualified organization string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.common_organization_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_common_organization_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.common_project_path common_project_path(project: str) -> str Returns a fully-qualified project string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.common_project_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_common_project_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.connection_profile_path connection_profile_path( project: str, location: str, connection_profile: str ) -> str Returns a fully-qualified connection_profile string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.connection_profile_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_connection_profile_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.create_connection_profile create_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.CreateConnectionProfileRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, connection_profile: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile ] = None, connection_profile_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to create a connection profile in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.create_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_create_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.create_private_connection create_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.CreatePrivateConnectionRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, private_connection: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.PrivateConnection ] = None, private_connection_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to create a private connectivity configuration. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.create_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_create_private_connection) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.create_route create_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.CreateRouteRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, route: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.Route ] = None, route_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to create a route for a private connectivity configuration in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.create_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_create_route) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.create_stream create_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.CreateStreamRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, stream: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.Stream ] = None, stream_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to create a stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.create_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_create_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_connection_profile delete_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DeleteConnectionProfileRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to delete a connection profile. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_delete_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_operation delete_operation( request: typing.Optional[ typing.Union[google.longrunning.operations_pb2.DeleteOperationRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> None Deletes a long-running operation. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_operation](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_delete_operation) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_private_connection delete_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DeletePrivateConnectionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to delete a private connectivity configuration. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_delete_private_connection) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_route delete_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DeleteRouteRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to delete a route. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_delete_route) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_stream delete_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DeleteStreamRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to delete a stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.delete_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_delete_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.discover_connection_profile discover_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileRequest, dict, ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.DiscoverConnectionProfileResponse Use this method to discover a connection profile. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.discover_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_discover_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.fetch_static_ips fetch_static_ips( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager The FetchStaticIps API call exposes the static IP addresses used by Datastream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.fetch_static_ips](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_fetch_static_ips) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_file from_service_account_file(filename: str, *args, **kwargs) Creates an instance of this client using the provided credentials file. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_file](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_from_service_account_file) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_info from_service_account_info(info: dict, *args, **kwargs) Creates an instance of this client using the provided credentials info. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_info](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_from_service_account_info) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_json from_service_account_json(filename: str, *args, **kwargs) Creates an instance of this client using the provided credentials file. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.from_service_account_json](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_from_service_account_json) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.get_connection_profile get_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.GetConnectionProfileRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile Use this method to get details about a connection profile. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.get_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_get_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.get_location get_location( request: typing.Optional[ typing.Union[google.cloud.location.locations_pb2.GetLocationRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.Location Gets information about a location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.get_location](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_get_location) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, ) Deprecated. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_get_mtls_endpoint_and_cert_source) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.get_operation get_operation( request: typing.Optional[ typing.Union[google.longrunning.operations_pb2.GetOperationRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.Operation Gets the latest state of a long-running operation. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.get_operation](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_get_operation) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.get_private_connection get_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.GetPrivateConnectionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.PrivateConnection Use this method to get details about a private connectivity configuration. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.get_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_get_private_connection) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.get_route get_route( request: typing.Optional[ typing.Union[google.cloud.datastream_v1.types.datastream.GetRouteRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.Route Use this method to get details about a route. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.get_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_get_route) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream get_stream( request: typing.Optional[ typing.Union[google.cloud.datastream_v1.types.datastream.GetStreamRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.Stream Use this method to get details about a stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_get_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream_object get_stream_object( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.GetStreamObjectRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject Use this method to get details about a stream object. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.get_stream_object](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_get_stream_object) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.list_connection_profiles list_connection_profiles( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager Use this method to list connection profiles created in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.list_connection_profiles](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_list_connection_profiles) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.list_locations list_locations( request: typing.Optional[ typing.Union[google.cloud.location.locations_pb2.ListLocationsRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.location.locations_pb2.ListLocationsResponse Lists information about the supported locations for this service. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.list_locations](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_list_locations) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.list_operations list_operations( request: typing.Optional[ typing.Union[google.longrunning.operations_pb2.ListOperationsRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponse Lists operations that match the specified filter in the request. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.list_operations](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_list_operations) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.list_private_connections list_private_connections( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager Use this method to list private connectivity configurations in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.list_private_connections](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_list_private_connections) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.list_routes list_routes( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListRoutesRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager Use this method to list routes created for a private connectivity configuration in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.list_routes](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_list_routes) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.list_stream_objects list_stream_objects( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager Use this method to list the objects of a specific stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.list_stream_objects](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_list_stream_objects) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.list_streams list_streams( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.ListStreamsRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager Use this method to list streams in a project and location. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.list_streams](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_list_streams) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.lookup_stream_object lookup_stream_object( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.LookupStreamObjectRequest, dict ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream_resources.StreamObject Use this method to look up a stream object by its source object identifier. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.lookup_stream_object](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_lookup_stream_object) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.network_attachment_path network_attachment_path(project: str, region: str, network_attachment: str) -> str Returns a fully-qualified network_attachment string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.network_attachment_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_network_attachment_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.networks_path networks_path(project: str, network: str) -> str Returns a fully-qualified networks string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.networks_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_networks_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_billing_account_path parse_common_billing_account_path(path: str) -> typing.Dict[str, str] Parse a billing_account path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_billing_account_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_common_billing_account_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_folder_path parse_common_folder_path(path: str) -> typing.Dict[str, str] Parse a folder path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_folder_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_common_folder_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_location_path parse_common_location_path(path: str) -> typing.Dict[str, str] Parse a location path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_location_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_common_location_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_organization_path parse_common_organization_path(path: str) -> typing.Dict[str, str] Parse a organization path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_organization_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_common_organization_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_project_path parse_common_project_path(path: str) -> typing.Dict[str, str] Parse a project path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_common_project_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_common_project_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_connection_profile_path parse_connection_profile_path(path: str) -> typing.Dict[str, str] Parses a connection_profile path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_connection_profile_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_connection_profile_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_network_attachment_path parse_network_attachment_path(path: str) -> typing.Dict[str, str] Parses a network_attachment path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_network_attachment_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_network_attachment_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_networks_path parse_networks_path(path: str) -> typing.Dict[str, str] Parses a networks path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_networks_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_networks_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_private_connection_path parse_private_connection_path(path: str) -> typing.Dict[str, str] Parses a private_connection path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_private_connection_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_private_connection_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_route_path parse_route_path(path: str) -> typing.Dict[str, str] Parses a route path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_route_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_route_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_object_path parse_stream_object_path(path: str) -> typing.Dict[str, str] Parses a stream_object path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_object_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_stream_object_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_path parse_stream_path(path: str) -> typing.Dict[str, str] Parses a stream path into its component segments. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.parse_stream_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_parse_stream_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.private_connection_path private_connection_path( project: str, location: str, private_connection: str ) -> str Returns a fully-qualified private_connection string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.private_connection_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_private_connection_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.route_path route_path(project: str, location: str, private_connection: str, route: str) -> str Returns a fully-qualified route string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.route_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_route_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.run_stream run_stream( request: typing.Optional[ typing.Union[google.cloud.datastream_v1.types.datastream.RunStreamRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to start, resume or recover a stream with a non default CDC strategy. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.run_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_run_stream) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.start_backfill_job start_backfill_job( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.StartBackfillJobRequest, dict ] ] = None, *, object_: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.StartBackfillJobResponse Use this method to start a backfill job for the specified stream object. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.start_backfill_job](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_start_backfill_job) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.stop_backfill_job stop_backfill_job( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.StopBackfillJobRequest, dict ] ] = None, *, object_: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1.types.datastream.StopBackfillJobResponse Use this method to stop a backfill job for the specified stream object. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.stop_backfill_job](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_stop_backfill_job) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_object_path stream_object_path(project: str, location: str, stream: str, object: str) -> str Returns a fully-qualified stream_object string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_object_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_stream_object_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_path stream_path(project: str, location: str, stream: str) -> str Returns a fully-qualified stream string. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.stream_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_stream_path) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.update_connection_profile update_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.UpdateConnectionProfileRequest, dict, ] ] = None, *, connection_profile: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.ConnectionProfile ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to update the parameters of a connection profile. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.update_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_update_connection_profile) ### google.cloud.datastream_v1.services.datastream.DatastreamClient.update_stream update_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1.types.datastream.UpdateStreamRequest, dict ] ] = None, *, stream: typing.Optional[ google.cloud.datastream_v1.types.datastream_resources.Stream ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to update the configuration of a stream. See more: [google.cloud.datastream_v1.services.datastream.DatastreamClient.update_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.DatastreamClient#google_cloud_datastream_v1_services_datastream_DatastreamClient_update_stream) ### google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager FetchStaticIpsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse ], ], request: google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest, response: google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsAsyncPager#google_cloud_datastream_v1_services_datastream_pagers_FetchStaticIpsAsyncPager_FetchStaticIpsAsyncPager) ### google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager FetchStaticIpsPager( method: typing.Callable[ [...], google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse ], request: google.cloud.datastream_v1.types.datastream.FetchStaticIpsRequest, response: google.cloud.datastream_v1.types.datastream.FetchStaticIpsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.FetchStaticIpsPager#google_cloud_datastream_v1_services_datastream_pagers_FetchStaticIpsPager_FetchStaticIpsPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager ListConnectionProfilesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse ], ], request: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest, response: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesAsyncPager#google_cloud_datastream_v1_services_datastream_pagers_ListConnectionProfilesAsyncPager_ListConnectionProfilesAsyncPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager ListConnectionProfilesPager( method: typing.Callable[ [...], google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse, ], request: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesRequest, response: google.cloud.datastream_v1.types.datastream.ListConnectionProfilesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListConnectionProfilesPager#google_cloud_datastream_v1_services_datastream_pagers_ListConnectionProfilesPager_ListConnectionProfilesPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager ListPrivateConnectionsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse ], ], request: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest, response: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsAsyncPager#google_cloud_datastream_v1_services_datastream_pagers_ListPrivateConnectionsAsyncPager_ListPrivateConnectionsAsyncPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager ListPrivateConnectionsPager( method: typing.Callable[ [...], google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse, ], request: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsRequest, response: google.cloud.datastream_v1.types.datastream.ListPrivateConnectionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListPrivateConnectionsPager#google_cloud_datastream_v1_services_datastream_pagers_ListPrivateConnectionsPager_ListPrivateConnectionsPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager ListRoutesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1.types.datastream.ListRoutesResponse ], ], request: google.cloud.datastream_v1.types.datastream.ListRoutesRequest, response: google.cloud.datastream_v1.types.datastream.ListRoutesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListRoutesAsyncPager#google_cloud_datastream_v1_services_datastream_pagers_ListRoutesAsyncPager_ListRoutesAsyncPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager ListRoutesPager( method: typing.Callable[ [...], google.cloud.datastream_v1.types.datastream.ListRoutesResponse ], request: google.cloud.datastream_v1.types.datastream.ListRoutesRequest, response: google.cloud.datastream_v1.types.datastream.ListRoutesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListRoutesPager#google_cloud_datastream_v1_services_datastream_pagers_ListRoutesPager_ListRoutesPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager ListStreamObjectsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse ], ], request: google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest, response: google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsAsyncPager#google_cloud_datastream_v1_services_datastream_pagers_ListStreamObjectsAsyncPager_ListStreamObjectsAsyncPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager ListStreamObjectsPager( method: typing.Callable[ [...], google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse ], request: google.cloud.datastream_v1.types.datastream.ListStreamObjectsRequest, response: google.cloud.datastream_v1.types.datastream.ListStreamObjectsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListStreamObjectsPager#google_cloud_datastream_v1_services_datastream_pagers_ListStreamObjectsPager_ListStreamObjectsPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager ListStreamsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1.types.datastream.ListStreamsResponse ], ], request: google.cloud.datastream_v1.types.datastream.ListStreamsRequest, response: google.cloud.datastream_v1.types.datastream.ListStreamsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListStreamsAsyncPager#google_cloud_datastream_v1_services_datastream_pagers_ListStreamsAsyncPager_ListStreamsAsyncPager) ### google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager ListStreamsPager( method: typing.Callable[ [...], google.cloud.datastream_v1.types.datastream.ListStreamsResponse ], request: google.cloud.datastream_v1.types.datastream.ListStreamsRequest, response: google.cloud.datastream_v1.types.datastream.ListStreamsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1.services.datastream.pagers.ListStreamsPager#google_cloud_datastream_v1_services_datastream_pagers_ListStreamsPager_ListStreamsPager) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient DatastreamAsyncClient( *, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[ typing.Union[ str, google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport, typing.Callable[ [...], google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport, ], ] ] = "grpc_asyncio", client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo ) Instantiates the datastream async client. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_DatastreamAsyncClient) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_billing_account_path common_billing_account_path(billing_account: str) -> str Returns a fully-qualified billing_account string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_billing_account_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_common_billing_account_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_folder_path common_folder_path(folder: str) -> str Returns a fully-qualified folder string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_folder_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_common_folder_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_location_path common_location_path(project: str, location: str) -> str Returns a fully-qualified location string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_location_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_common_location_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_organization_path common_organization_path(organization: str) -> str Returns a fully-qualified organization string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_organization_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_common_organization_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_project_path common_project_path(project: str) -> str Returns a fully-qualified project string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.common_project_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_common_project_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.connection_profile_path connection_profile_path( project: str, location: str, connection_profile: str ) -> str Returns a fully-qualified connection_profile string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.connection_profile_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_connection_profile_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_connection_profile create_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.CreateConnectionProfileRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, connection_profile: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile ] = None, connection_profile_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to create a connection profile in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_create_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_private_connection create_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.CreatePrivateConnectionRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, private_connection: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection ] = None, private_connection_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to create a private connectivity configuration. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_create_private_connection) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_route create_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.CreateRouteRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, route: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.Route ] = None, route_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to create a route for a private connectivity in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_create_route) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_stream create_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.CreateStreamRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, stream: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.Stream ] = None, stream_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to create a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.create_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_create_stream) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_connection_profile delete_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DeleteConnectionProfileRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to delete a connection profile. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_delete_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_private_connection delete_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DeletePrivateConnectionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to delete a private connectivity configuration. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_delete_private_connection) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_route delete_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DeleteRouteRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to delete a route. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_delete_route) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_stream delete_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DeleteStreamRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to delete a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.delete_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_delete_stream) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.discover_connection_profile discover_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileRequest, dict, ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileResponse ) Use this method to discover a connection profile. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.discover_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_discover_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_errors fetch_errors( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.FetchErrorsRequest, dict ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to fetch any errors associated with a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_errors](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_fetch_errors) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_static_ips fetch_static_ips( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsAsyncPager ) The FetchStaticIps API call exposes the static ips used by Datastream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.fetch_static_ips](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_fetch_static_ips) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_file from_service_account_file(filename: str, *args, **kwargs) Creates an instance of this client using the provided credentials file. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_file](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_from_service_account_file) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_info from_service_account_info(info: dict, *args, **kwargs) Creates an instance of this client using the provided credentials info. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_info](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_from_service_account_info) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_json from_service_account_json(filename: str, *args, **kwargs) Creates an instance of this client using the provided credentials file. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.from_service_account_json](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_from_service_account_json) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_connection_profile get_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.GetConnectionProfileRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile Use this method to get details about a connection profile. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_get_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, ) Return the API endpoint and client cert source for mutual TLS. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_mtls_endpoint_and_cert_source](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_get_mtls_endpoint_and_cert_source) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_private_connection get_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.GetPrivateConnectionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection Use this method to get details about a private connectivity configuration. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_get_private_connection) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_route get_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.GetRouteRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Route Use this method to get details about a route. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_get_route) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_stream get_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.GetStreamRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Stream Use this method to get details about a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_get_stream) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_transport_class get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport ] Returns an appropriate transport class. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.get_transport_class](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_get_transport_class) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_connection_profiles list_connection_profiles( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesAsyncPager ) Use this method to list connection profiles created in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_connection_profiles](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_list_connection_profiles) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_private_connections list_private_connections( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsAsyncPager ) Use this method to list private connectivity configurations in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_private_connections](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_list_private_connections) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_routes list_routes( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.ListRoutesRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesAsyncPager Use this method to list routes created for a private connectivity in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_routes](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_list_routes) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_streams list_streams( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.ListStreamsRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsAsyncPager Use this method to list streams in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.list_streams](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_list_streams) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_billing_account_path parse_common_billing_account_path(path: str) -> typing.Dict[str, str] Parse a billing_account path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_billing_account_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_common_billing_account_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_folder_path parse_common_folder_path(path: str) -> typing.Dict[str, str] Parse a folder path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_folder_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_common_folder_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_location_path parse_common_location_path(path: str) -> typing.Dict[str, str] Parse a location path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_location_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_common_location_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_organization_path parse_common_organization_path(path: str) -> typing.Dict[str, str] Parse a organization path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_organization_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_common_organization_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_project_path parse_common_project_path(path: str) -> typing.Dict[str, str] Parse a project path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_common_project_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_common_project_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path parse_connection_profile_path(path: str) -> typing.Dict[str, str] Parses a connection_profile path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_connection_profile_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_connection_profile_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_private_connection_path parse_private_connection_path(path: str) -> typing.Dict[str, str] Parses a private_connection path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_private_connection_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_private_connection_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_route_path parse_route_path(path: str) -> typing.Dict[str, str] Parses a route path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_route_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_route_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_stream_path parse_stream_path(path: str) -> typing.Dict[str, str] Parses a stream path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.parse_stream_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_parse_stream_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.private_connection_path private_connection_path( project: str, location: str, private_connection: str ) -> str Returns a fully-qualified private_connection string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.private_connection_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_private_connection_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.route_path route_path(project: str, location: str, private_connection: str, route: str) -> str Returns a fully-qualified route string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.route_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_route_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.stream_path stream_path(project: str, location: str, stream: str) -> str Returns a fully-qualified stream string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.stream_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_stream_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.update_connection_profile update_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.UpdateConnectionProfileRequest, dict, ] ] = None, *, connection_profile: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to update the parameters of a connection profile. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.update_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_update_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.update_stream update_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.UpdateStreamRequest, dict ] ] = None, *, stream: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.Stream ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperation Use this method to update the configuration of a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient.update_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamAsyncClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamAsyncClient_update_stream) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient DatastreamClient( *, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[ typing.Union[ str, google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport, typing.Callable[ [...], google.cloud.datastream_v1alpha1.services.datastream.transports.base.DatastreamTransport, ], ] ] = None, client_options: typing.Optional[ typing.Union[google.api_core.client_options.ClientOptions, dict] ] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = google.api_core.gapic_v1.client_info.ClientInfo ) Instantiates the datastream client. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_DatastreamClient) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.__exit__ __exit__(type, value, traceback) Releases underlying transport's resources. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.**exit**](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient___exit__) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_billing_account_path common_billing_account_path(billing_account: str) -> str Returns a fully-qualified billing_account string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_billing_account_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_common_billing_account_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_folder_path common_folder_path(folder: str) -> str Returns a fully-qualified folder string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_folder_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_common_folder_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_location_path common_location_path(project: str, location: str) -> str Returns a fully-qualified location string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_location_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_common_location_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_organization_path common_organization_path(organization: str) -> str Returns a fully-qualified organization string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_organization_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_common_organization_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_project_path common_project_path(project: str) -> str Returns a fully-qualified project string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.common_project_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_common_project_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.connection_profile_path connection_profile_path( project: str, location: str, connection_profile: str ) -> str Returns a fully-qualified connection_profile string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.connection_profile_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_connection_profile_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_connection_profile create_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.CreateConnectionProfileRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, connection_profile: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile ] = None, connection_profile_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to create a connection profile in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_create_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_private_connection create_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.CreatePrivateConnectionRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, private_connection: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection ] = None, private_connection_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to create a private connectivity configuration. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_create_private_connection) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_route create_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.CreateRouteRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, route: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.Route ] = None, route_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to create a route for a private connectivity in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_create_route) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_stream create_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.CreateStreamRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, stream: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.Stream ] = None, stream_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to create a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.create_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_create_stream) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_connection_profile delete_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DeleteConnectionProfileRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to delete a connection profile. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_delete_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_private_connection delete_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DeletePrivateConnectionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to delete a private connectivity configuration. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_delete_private_connection) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_route delete_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DeleteRouteRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to delete a route. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_delete_route) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_stream delete_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DeleteStreamRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to delete a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.delete_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_delete_stream) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.discover_connection_profile discover_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileRequest, dict, ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.types.datastream.DiscoverConnectionProfileResponse ) Use this method to discover a connection profile. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.discover_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_discover_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.fetch_errors fetch_errors( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.FetchErrorsRequest, dict ] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to fetch any errors associated with a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.fetch_errors](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_fetch_errors) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.fetch_static_ips fetch_static_ips( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsPager The FetchStaticIps API call exposes the static ips used by Datastream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.fetch_static_ips](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_fetch_static_ips) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.from_service_account_file from_service_account_file(filename: str, *args, **kwargs) Creates an instance of this client using the provided credentials file. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.from_service_account_file](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_from_service_account_file) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.from_service_account_info from_service_account_info(info: dict, *args, **kwargs) Creates an instance of this client using the provided credentials info. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.from_service_account_info](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_from_service_account_info) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.from_service_account_json from_service_account_json(filename: str, *args, **kwargs) Creates an instance of this client using the provided credentials file. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.from_service_account_json](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_from_service_account_json) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_connection_profile get_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.GetConnectionProfileRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile Use this method to get details about a connection profile. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_get_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, ) Deprecated. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_mtls_endpoint_and_cert_source](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_get_mtls_endpoint_and_cert_source) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_private_connection get_private_connection( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.GetPrivateConnectionRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.PrivateConnection Use this method to get details about a private connectivity configuration. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_private_connection](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_get_private_connection) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_route get_route( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.GetRouteRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Route Use this method to get details about a route. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_route](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_get_route) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_stream get_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.GetStreamRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.types.datastream_resources.Stream Use this method to get details about a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.get_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_get_stream) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_connection_profiles list_connection_profiles( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesPager ) Use this method to list connection profiles created in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_connection_profiles](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_list_connection_profiles) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_private_connections list_private_connections( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsPager ) Use this method to list private connectivity configurations in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_private_connections](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_list_private_connections) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_routes list_routes( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.ListRoutesRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesPager Use this method to list routes created for a private connectivity in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_routes](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_list_routes) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_streams list_streams( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.ListStreamsRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPager Use this method to list streams in a project and location. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.list_streams](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_list_streams) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_billing_account_path parse_common_billing_account_path(path: str) -> typing.Dict[str, str] Parse a billing_account path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_billing_account_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_common_billing_account_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_folder_path parse_common_folder_path(path: str) -> typing.Dict[str, str] Parse a folder path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_folder_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_common_folder_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_location_path parse_common_location_path(path: str) -> typing.Dict[str, str] Parse a location path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_location_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_common_location_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_organization_path parse_common_organization_path(path: str) -> typing.Dict[str, str] Parse a organization path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_organization_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_common_organization_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_project_path parse_common_project_path(path: str) -> typing.Dict[str, str] Parse a project path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_common_project_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_common_project_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_connection_profile_path parse_connection_profile_path(path: str) -> typing.Dict[str, str] Parses a connection_profile path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_connection_profile_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_connection_profile_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_private_connection_path parse_private_connection_path(path: str) -> typing.Dict[str, str] Parses a private_connection path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_private_connection_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_private_connection_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_route_path parse_route_path(path: str) -> typing.Dict[str, str] Parses a route path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_route_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_route_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_stream_path parse_stream_path(path: str) -> typing.Dict[str, str] Parses a stream path into its component segments. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.parse_stream_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_parse_stream_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.private_connection_path private_connection_path( project: str, location: str, private_connection: str ) -> str Returns a fully-qualified private_connection string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.private_connection_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_private_connection_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.route_path route_path(project: str, location: str, private_connection: str, route: str) -> str Returns a fully-qualified route string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.route_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_route_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.stream_path stream_path(project: str, location: str, stream: str) -> str Returns a fully-qualified stream string. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.stream_path](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_stream_path) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.update_connection_profile update_connection_profile( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.UpdateConnectionProfileRequest, dict, ] ] = None, *, connection_profile: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.ConnectionProfile ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to update the parameters of a connection profile. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.update_connection_profile](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_update_connection_profile) ### google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.update_stream update_stream( request: typing.Optional[ typing.Union[ google.cloud.datastream_v1alpha1.types.datastream.UpdateStreamRequest, dict ] ] = None, *, stream: typing.Optional[ google.cloud.datastream_v1alpha1.types.datastream_resources.Stream ] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.Operation Use this method to update the configuration of a stream. See more: [google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient.update_stream](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.DatastreamClient#google_cloud_datastream_v1alpha1_services_datastream_DatastreamClient_update_stream) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsAsyncPager FetchStaticIpsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsRequest, response: google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsAsyncPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_FetchStaticIpsAsyncPager_FetchStaticIpsAsyncPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsPager FetchStaticIpsPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsResponse ], request: google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsRequest, response: google.cloud.datastream_v1alpha1.types.datastream.FetchStaticIpsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.FetchStaticIpsPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_FetchStaticIpsPager_FetchStaticIpsPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesAsyncPager ListConnectionProfilesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesRequest, response: google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesAsyncPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_ListConnectionProfilesAsyncPager_ListConnectionProfilesAsyncPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesPager ListConnectionProfilesPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesResponse, ], request: google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesRequest, response: google.cloud.datastream_v1alpha1.types.datastream.ListConnectionProfilesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.ListConnectionProfilesPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_ListConnectionProfilesPager_ListConnectionProfilesPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsAsyncPager ListPrivateConnectionsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsRequest, response: google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsAsyncPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_ListPrivateConnectionsAsyncPager_ListPrivateConnectionsAsyncPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsPager ListPrivateConnectionsPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsResponse, ], request: google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsRequest, response: google.cloud.datastream_v1alpha1.types.datastream.ListPrivateConnectionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.ListPrivateConnectionsPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_ListPrivateConnectionsPager_ListPrivateConnectionsPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesAsyncPager ListRoutesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.ListRoutesResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.ListRoutesRequest, response: google.cloud.datastream_v1alpha1.types.datastream.ListRoutesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesAsyncPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_ListRoutesAsyncPager_ListRoutesAsyncPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesPager ListRoutesPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.ListRoutesResponse ], request: google.cloud.datastream_v1alpha1.types.datastream.ListRoutesRequest, response: google.cloud.datastream_v1alpha1.types.datastream.ListRoutesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.ListRoutesPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_ListRoutesPager_ListRoutesPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsAsyncPager ListStreamsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.datastream_v1alpha1.types.datastream.ListStreamsResponse ], ], request: google.cloud.datastream_v1alpha1.types.datastream.ListStreamsRequest, response: google.cloud.datastream_v1alpha1.types.datastream.ListStreamsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiates the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsAsyncPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsAsyncPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_ListStreamsAsyncPager_ListStreamsAsyncPager) ### google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPager ListStreamsPager( method: typing.Callable[ [...], google.cloud.datastream_v1alpha1.types.datastream.ListStreamsResponse ], request: google.cloud.datastream_v1alpha1.types.datastream.ListStreamsRequest, response: google.cloud.datastream_v1alpha1.types.datastream.ListStreamsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) Instantiate the pager. See more: [google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPager](https://cloud.google.com/python/docs/reference/datastream/latest/google.cloud.datastream_v1alpha1.services.datastream.pagers.ListStreamsPager#google_cloud_datastream_v1alpha1_services_datastream_pagers_ListStreamsPager_ListStreamsPager)