Package Methods (3.20.0)

Summary of entries of Methods for bigquerydatatransfer.

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient

DataTransferServiceAsyncClient( *, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[ typing.Union[ str, google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.transports.base.DataTransferServiceTransport, typing.Callable[ [...], google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.transports.base.DataTransferServiceTransport, ], ] ] = "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 )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.check_valid_creds

check_valid_creds( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.CheckValidCredsRequest, 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.bigquery_datatransfer_v1.types.datatransfer.CheckValidCredsResponse

Returns true if valid credentials exist for the given data source and requesting user.

See more: google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.check_valid_creds

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.common_folder_path

common_folder_path(folder: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.common_location_path

common_location_path(project: str, location: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.common_organization_path

common_organization_path(organization: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.common_project_path

common_project_path(project: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.create_transfer_config

create_transfer_config( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.CreateTransferConfigRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, transfer_config: typing.Optional[ google.cloud.bigquery_datatransfer_v1.types.transfer.TransferConfig ] = 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.bigquery_datatransfer_v1.types.transfer.TransferConfig

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.data_source_path

data_source_path(project: str, data_source: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.delete_transfer_config

delete_transfer_config( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.DeleteTransferConfigRequest, 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]]] = () ) -> None

Deletes a data transfer configuration, including any associated transfer runs and logs.

See more: google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.delete_transfer_config

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.delete_transfer_run

delete_transfer_run( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.DeleteTransferRunRequest, 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]]] = () ) -> None

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.enroll_data_sources

enroll_data_sources( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.EnrollDataSourcesRequest, 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

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.from_service_account_file

from_service_account_file(filename: str, *args, **kwargs)

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.from_service_account_info

from_service_account_info(info: dict, *args, **kwargs)

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.from_service_account_json

from_service_account_json(filename: str, *args, **kwargs)

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.get_data_source

get_data_source( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.GetDataSourceRequest, 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.bigquery_datatransfer_v1.types.datatransfer.DataSource

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.get_location

get_location( request: typing.Optional[ google.cloud.location.locations_pb2.GetLocationRequest ] = 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

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.get_transfer_config

get_transfer_config( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.GetTransferConfigRequest, 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.bigquery_datatransfer_v1.types.transfer.TransferConfig

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.get_transfer_run

get_transfer_run( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.GetTransferRunRequest, 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.bigquery_datatransfer_v1.types.transfer.TransferRun

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.get_transport_class

get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.transports.base.DataTransferServiceTransport ]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.list_data_sources

list_data_sources( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListDataSourcesRequest, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListDataSourcesAsyncPager )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.list_locations

list_locations( request: typing.Optional[ google.cloud.location.locations_pb2.ListLocationsRequest ] = 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.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.list_locations

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.list_transfer_configs

list_transfer_configs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferConfigsRequest, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferConfigsAsyncPager )

Returns information about all transfer configs owned by a project in the specified location.

See more: google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.list_transfer_configs

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.list_transfer_logs

list_transfer_logs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferLogsRequest, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferLogsAsyncPager )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.list_transfer_runs

list_transfer_runs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferRunsRequest, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferRunsAsyncPager )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.parse_common_billing_account_path

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.parse_common_folder_path

parse_common_folder_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.parse_common_location_path

parse_common_location_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.parse_common_organization_path

parse_common_organization_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.parse_common_project_path

parse_common_project_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.parse_data_source_path

parse_data_source_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.parse_run_path

parse_run_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.parse_transfer_config_path

parse_transfer_config_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.run_path

run_path(project: str, transfer_config: str, run: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.schedule_transfer_runs

schedule_transfer_runs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ScheduleTransferRunsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, start_time: typing.Optional[google.protobuf.timestamp_pb2.Timestamp] = None, end_time: typing.Optional[google.protobuf.timestamp_pb2.Timestamp] = 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.bigquery_datatransfer_v1.types.datatransfer.ScheduleTransferRunsResponse )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.start_manual_transfer_runs

start_manual_transfer_runs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.StartManualTransferRunsRequest, 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.bigquery_datatransfer_v1.types.datatransfer.StartManualTransferRunsResponse )

Start manual transfer runs to be executed now with schedule_time equal to current time.

See more: google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.start_manual_transfer_runs

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.transfer_config_path

transfer_config_path(project: str, transfer_config: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.unenroll_data_sources

unenroll_data_sources( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.UnenrollDataSourcesRequest, 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

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceAsyncClient.update_transfer_config

update_transfer_config( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.UpdateTransferConfigRequest, dict, ] ] = None, *, transfer_config: typing.Optional[ google.cloud.bigquery_datatransfer_v1.types.transfer.TransferConfig ] = 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.cloud.bigquery_datatransfer_v1.types.transfer.TransferConfig

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient

DataTransferServiceClient( *, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[ typing.Union[ str, google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.transports.base.DataTransferServiceTransport, typing.Callable[ [...], google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.transports.base.DataTransferServiceTransport, ], ] ] = 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 )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.__exit__

__exit__(type, value, traceback)

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.check_valid_creds

check_valid_creds( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.CheckValidCredsRequest, 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.bigquery_datatransfer_v1.types.datatransfer.CheckValidCredsResponse

Returns true if valid credentials exist for the given data source and requesting user.

See more: google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.check_valid_creds

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.common_billing_account_path

common_billing_account_path(billing_account: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.common_folder_path

common_folder_path(folder: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.common_location_path

common_location_path(project: str, location: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.common_organization_path

common_organization_path(organization: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.common_project_path

common_project_path(project: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.create_transfer_config

create_transfer_config( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.CreateTransferConfigRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, transfer_config: typing.Optional[ google.cloud.bigquery_datatransfer_v1.types.transfer.TransferConfig ] = 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.bigquery_datatransfer_v1.types.transfer.TransferConfig

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.data_source_path

data_source_path(project: str, data_source: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.delete_transfer_config

delete_transfer_config( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.DeleteTransferConfigRequest, 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]]] = () ) -> None

Deletes a data transfer configuration, including any associated transfer runs and logs.

See more: google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.delete_transfer_config

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.delete_transfer_run

delete_transfer_run( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.DeleteTransferRunRequest, 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]]] = () ) -> None

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.enroll_data_sources

enroll_data_sources( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.EnrollDataSourcesRequest, 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

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.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.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.from_service_account_file

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.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.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.from_service_account_info

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.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.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.from_service_account_json

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.get_data_source

get_data_source( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.GetDataSourceRequest, 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.bigquery_datatransfer_v1.types.datatransfer.DataSource

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.get_location

get_location( request: typing.Optional[ google.cloud.location.locations_pb2.GetLocationRequest ] = 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

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.get_mtls_endpoint_and_cert_source

get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.get_transfer_config

get_transfer_config( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.GetTransferConfigRequest, 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.bigquery_datatransfer_v1.types.transfer.TransferConfig

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.get_transfer_run

get_transfer_run( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.GetTransferRunRequest, 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.bigquery_datatransfer_v1.types.transfer.TransferRun

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.list_data_sources

list_data_sources( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListDataSourcesRequest, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListDataSourcesPager )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.list_locations

list_locations( request: typing.Optional[ google.cloud.location.locations_pb2.ListLocationsRequest ] = 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.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.list_locations

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.list_transfer_configs

list_transfer_configs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferConfigsRequest, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferConfigsPager )

Returns information about all transfer configs owned by a project in the specified location.

See more: google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.list_transfer_configs

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.list_transfer_logs

list_transfer_logs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferLogsRequest, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferLogsPager )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.list_transfer_runs

list_transfer_runs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferRunsRequest, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferRunsPager )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.parse_common_billing_account_path

parse_common_billing_account_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.parse_common_folder_path

parse_common_folder_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.parse_common_location_path

parse_common_location_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.parse_common_organization_path

parse_common_organization_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.parse_common_project_path

parse_common_project_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.parse_data_source_path

parse_data_source_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.parse_run_path

parse_run_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.parse_transfer_config_path

parse_transfer_config_path(path: str) -> typing.Dict[str, str]

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.run_path

run_path(project: str, transfer_config: str, run: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.schedule_transfer_runs

schedule_transfer_runs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ScheduleTransferRunsRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, start_time: typing.Optional[google.protobuf.timestamp_pb2.Timestamp] = None, end_time: typing.Optional[google.protobuf.timestamp_pb2.Timestamp] = 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.bigquery_datatransfer_v1.types.datatransfer.ScheduleTransferRunsResponse )

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.start_manual_transfer_runs

start_manual_transfer_runs( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.StartManualTransferRunsRequest, 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.bigquery_datatransfer_v1.types.datatransfer.StartManualTransferRunsResponse )

Start manual transfer runs to be executed now with schedule_time equal to current time.

See more: google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.start_manual_transfer_runs

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.transfer_config_path

transfer_config_path(project: str, transfer_config: str) -> str

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.unenroll_data_sources

unenroll_data_sources( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.UnenrollDataSourcesRequest, 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

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.DataTransferServiceClient.update_transfer_config

update_transfer_config( request: typing.Optional[ typing.Union[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.UpdateTransferConfigRequest, dict, ] ] = None, *, transfer_config: typing.Optional[ google.cloud.bigquery_datatransfer_v1.types.transfer.TransferConfig ] = 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.cloud.bigquery_datatransfer_v1.types.transfer.TransferConfig

google.cloud.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListDataSourcesAsyncPager

ListDataSourcesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListDataSourcesResponse ], ], request: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListDataSourcesRequest, response: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListDataSourcesResponse, *, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListDataSourcesPager

ListDataSourcesPager( method: typing.Callable[ [...], google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListDataSourcesResponse, ], request: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListDataSourcesRequest, response: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListDataSourcesResponse, *, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferConfigsAsyncPager

ListTransferConfigsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferConfigsResponse ], ], request: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferConfigsRequest, response: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferConfigsResponse, *, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferConfigsPager

ListTransferConfigsPager( method: typing.Callable[ [...], google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferConfigsResponse, ], request: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferConfigsRequest, response: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferConfigsResponse, *, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferLogsAsyncPager

ListTransferLogsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferLogsResponse ], ], request: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferLogsRequest, response: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferLogsResponse, *, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferLogsPager

ListTransferLogsPager( method: typing.Callable[ [...], google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferLogsResponse, ], request: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferLogsRequest, response: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferLogsResponse, *, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferRunsAsyncPager

ListTransferRunsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferRunsResponse ], ], request: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferRunsRequest, response: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferRunsResponse, *, 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.bigquery_datatransfer_v1.services.data_transfer_service.pagers.ListTransferRunsPager

ListTransferRunsPager( method: typing.Callable[ [...], google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferRunsResponse, ], request: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferRunsRequest, response: google.cloud.bigquery_datatransfer_v1.types.datatransfer.ListTransferRunsResponse, *, 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]]] = () )