Class DataTransferServiceAsyncClient (3.15.6)

This API allows users to manage their data transfers into BigQuery.

Return the API endpoint used by the client instance.

Returns the transport used by the client instance.

Return the universe domain used by the client instance.

Instantiates the data transfer service async client.

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

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_check_valid_creds():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.CheckValidCredsRequest(
        name="name_value",
    )

    # Make the request
    response = await client.check_valid_creds(request=request)

    # Handle the response
    print(response)

Returns a fully-qualified billing_account string.

Returns a fully-qualified folder string.

Returns a fully-qualified location string.

Returns a fully-qualified organization string.

Returns a fully-qualified project string.

Creates a new data transfer configuration.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_create_transfer_config():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    transfer_config = bigquery_datatransfer_v1.TransferConfig()
    transfer_config.destination_dataset_id = "destination_dataset_id_value"

    request = bigquery_datatransfer_v1.CreateTransferConfigRequest(
        parent="parent_value",
        transfer_config=transfer_config,
    )

    # Make the request
    response = await client.create_transfer_config(request=request)

    # Handle the response
    print(response)

Returns a fully-qualified data_source string.

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

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_delete_transfer_config():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.DeleteTransferConfigRequest(
        name="name_value",
    )

    # Make the request
    await client.delete_transfer_config(request=request)

Deletes the specified transfer run.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_delete_transfer_run():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.DeleteTransferRunRequest(
        name="name_value",
    )

    # Make the request
    await client.delete_transfer_run(request=request)

Enroll data sources in a user project. This allows users to create transfer configurations for these data sources. They will also appear in the ListDataSources RPC and as such, will appear in the BigQuery UI <https://console.cloud.google.com/bigquery>, and the documents can be found in the public guide for BigQuery Web UI <https://cloud.google.com/bigquery/bigquery-web-ui> and Data Transfer Service <https://cloud.google.com/bigquery/docs/working-with-transfers>__.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_enroll_data_sources():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.EnrollDataSourcesRequest(
        name="name_value",
    )

    # Make the request
    await client.enroll_data_sources(request=request)

Creates an instance of this client using the provided credentials file.

Creates an instance of this client using the provided credentials info.

Creates an instance of this client using the provided credentials file.

Retrieves a supported data source and returns its settings.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_get_data_source():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.GetDataSourceRequest(
        name="name_value",
    )

    # Make the request
    response = await client.get_data_source(request=request)

    # Handle the response
    print(response)

Gets information about a location.

Return the API endpoint and client cert source for mutual TLS.

The client cert source is determined in the following order: (1) if GOOGLE_API_USE_CLIENT_CERTIFICATE environment variable is not "true", the client cert source is None. (2) if client_options.client_cert_source is provided, use the provided one; if the default client cert source exists, use the default one; otherwise the client cert source is None.

The API endpoint is determined in the following order: (1) if client_options.api_endpoint if provided, use the provided one. (2) if GOOGLE_API_USE_CLIENT_CERTIFICATE environment variable is "always", use the default mTLS endpoint; if the environment variable is "never", use the default API endpoint; otherwise if client cert source exists, use the default mTLS endpoint, otherwise use the default API endpoint.

More details can be found at https://google.aip.dev/auth/4114.

Returns information about a data transfer config.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_get_transfer_config():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.GetTransferConfigRequest(
        name="name_value",
    )

    # Make the request
    response = await client.get_transfer_config(request=request)

    # Handle the response
    print(response)

Returns information about the particular transfer run.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_get_transfer_run():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.GetTransferRunRequest(
        name="name_value",
    )

    # Make the request
    response = await client.get_transfer_run(request=request)

    # Handle the response
    print(response)

Returns an appropriate transport class.

Lists supported data sources and returns their settings.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_list_data_sources():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.ListDataSourcesRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_data_sources(request=request)

    # Handle the response
    async for response in page_result:
        print(response)

Lists information about the supported locations for this service.

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

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_list_transfer_configs():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.ListTransferConfigsRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_transfer_configs(request=request)

    # Handle the response
    async for response in page_result:
        print(response)

Returns log messages for the transfer run.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_list_transfer_logs():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.ListTransferLogsRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_transfer_logs(request=request)

    # Handle the response
    async for response in page_result:
        print(response)

Returns information about running and completed transfer runs.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_list_transfer_runs():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.ListTransferRunsRequest(
        parent="parent_value",
    )

    # Make the request
    page_result = client.list_transfer_runs(request=request)

    # Handle the response
    async for response in page_result:
        print(response)

Parse a billing_account path into its component segments.

Parse a folder path into its component segments.

Parse a location path into its component segments.

Parse a organization path into its component segments.

Parse a project path into its component segments.

Parses a data_source path into its component segments.

Parses a run path into its component segments.

Parses a transfer_config path into its component segments.

Returns a fully-qualified run string.

Creates transfer runs for a time range [start_time, end_time]. For each date - or whatever granularity the data source supports

• in the range, one transfer run is created. Note that runs are created per UTC time in the time range. DEPRECATED: use StartManualTransferRuns instead.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_schedule_transfer_runs():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.ScheduleTransferRunsRequest(
        parent="parent_value",
    )

    # Make the request
    response = await client.schedule_transfer_runs(request=request)

    # Handle the response
    print(response)

Start manual transfer runs to be executed now with schedule_time equal to current time. The transfer runs can be created for a time range where the run_time is between start_time (inclusive) and end_time (exclusive), or for a specific run_time.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_start_manual_transfer_runs():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.StartManualTransferRunsRequest(
        parent="parent_value",
    )

    # Make the request
    response = await client.start_manual_transfer_runs(request=request)

    # Handle the response
    print(response)

Returns a fully-qualified transfer_config string.

Unenroll data sources in a user project. This allows users to remove transfer configurations for these data sources. They will no longer appear in the ListDataSources RPC and will also no longer appear in the BigQuery UI <https://console.cloud.google.com/bigquery>__. Data transfers configurations of unenrolled data sources will not be scheduled.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_unenroll_data_sources():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_datatransfer_v1.UnenrollDataSourcesRequest(
        name="name_value",
    )

    # Make the request
    await client.unenroll_data_sources(request=request)

Updates a data transfer configuration. All fields must be set, even if they are not updated.

# This snippet has been automatically generated and should be regarded as a
# code template only.
# It will require modifications to work:
# - It may require correct/in-range values for request initialization.
# - It may require specifying regional endpoints when creating the service
#   client as shown in:
#   https://googleapis.dev/python/google-api-core/latest/client_options.html
from google.cloud import bigquery_datatransfer_v1

async def sample_update_transfer_config():
    # Create a client
    client = bigquery_datatransfer_v1.DataTransferServiceAsyncClient()

    # Initialize request argument(s)
    transfer_config = bigquery_datatransfer_v1.TransferConfig()
    transfer_config.destination_dataset_id = "destination_dataset_id_value"

    request = bigquery_datatransfer_v1.UpdateTransferConfigRequest(
        transfer_config=transfer_config,
    )

    # Make the request
    response = await client.update_transfer_config(request=request)

    # Handle the response
    print(response)