Class AnalyticsHubServiceAsyncClient (0.4.13)

# 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_analyticshub_v1

async def sample_create_data_exchange():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    data_exchange = bigquery_analyticshub_v1.DataExchange()
    data_exchange.display_name = "display_name_value"

    request = bigquery_analyticshub_v1.CreateDataExchangeRequest(
        parent="parent_value",
        data_exchange_id="data_exchange_id_value",
        data_exchange=data_exchange,
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_create_listing():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    listing = bigquery_analyticshub_v1.Listing()
    listing.display_name = "display_name_value"

    request = bigquery_analyticshub_v1.CreateListingRequest(
        parent="parent_value",
        listing_id="listing_id_value",
        listing=listing,
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_delete_data_exchange():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.DeleteDataExchangeRequest(
        name="name_value",
    )

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

# 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_analyticshub_v1

async def sample_delete_listing():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.DeleteListingRequest(
        name="name_value",
    )

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

# 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_analyticshub_v1

async def sample_delete_subscription():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.DeleteSubscriptionRequest(
        name="name_value",
    )

    # Make the request
    operation = client.delete_subscription(request=request)

    print("Waiting for operation to complete...")

    response = (await operation).result()

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_get_data_exchange():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.GetDataExchangeRequest(
        name="name_value",
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1
from google.iam.v1 import iam_policy_pb2  # type: ignore

async def sample_get_iam_policy():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = iam_policy_pb2.GetIamPolicyRequest(
        resource="resource_value",
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_get_listing():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.GetListingRequest(
        name="name_value",
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_get_subscription():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.GetSubscriptionRequest(
        name="name_value",
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_list_data_exchanges():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.ListDataExchangesRequest(
        parent="parent_value",
    )

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

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

# 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_analyticshub_v1

async def sample_list_listings():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.ListListingsRequest(
        parent="parent_value",
    )

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

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

# 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_analyticshub_v1

async def sample_list_org_data_exchanges():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.ListOrgDataExchangesRequest(
        organization="organization_value",
    )

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

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

# 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_analyticshub_v1

async def sample_list_shared_resource_subscriptions():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.ListSharedResourceSubscriptionsRequest(
        resource="resource_value",
    )

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

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

# 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_analyticshub_v1

async def sample_list_subscriptions():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.ListSubscriptionsRequest(
        parent="parent_value",
    )

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

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

# 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_analyticshub_v1

async def sample_refresh_subscription():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.RefreshSubscriptionRequest(
        name="name_value",
    )

    # Make the request
    operation = client.refresh_subscription(request=request)

    print("Waiting for operation to complete...")

    response = (await operation).result()

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_revoke_subscription():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.RevokeSubscriptionRequest(
        name="name_value",
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1
from google.iam.v1 import iam_policy_pb2  # type: ignore

async def sample_set_iam_policy():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = iam_policy_pb2.SetIamPolicyRequest(
        resource="resource_value",
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_subscribe_data_exchange():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = bigquery_analyticshub_v1.SubscribeDataExchangeRequest(
        name="name_value",
        destination="destination_value",
        subscription="subscription_value",
    )

    # Make the request
    operation = client.subscribe_data_exchange(request=request)

    print("Waiting for operation to complete...")

    response = (await operation).result()

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_subscribe_listing():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    destination_dataset = bigquery_analyticshub_v1.DestinationDataset()
    destination_dataset.dataset_reference.dataset_id = "dataset_id_value"
    destination_dataset.dataset_reference.project_id = "project_id_value"
    destination_dataset.location = "location_value"

    request = bigquery_analyticshub_v1.SubscribeListingRequest(
        destination_dataset=destination_dataset,
        name="name_value",
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1
from google.iam.v1 import iam_policy_pb2  # type: ignore

async def sample_test_iam_permissions():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    request = iam_policy_pb2.TestIamPermissionsRequest(
        resource="resource_value",
        permissions=['permissions_value1', 'permissions_value2'],
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_update_data_exchange():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    data_exchange = bigquery_analyticshub_v1.DataExchange()
    data_exchange.display_name = "display_name_value"

    request = bigquery_analyticshub_v1.UpdateDataExchangeRequest(
        data_exchange=data_exchange,
    )

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

    # Handle the response
    print(response)

# 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_analyticshub_v1

async def sample_update_listing():
    # Create a client
    client = bigquery_analyticshub_v1.AnalyticsHubServiceAsyncClient()

    # Initialize request argument(s)
    listing = bigquery_analyticshub_v1.Listing()
    listing.display_name = "display_name_value"

    request = bigquery_analyticshub_v1.UpdateListingRequest(
        listing=listing,
    )

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

    # Handle the response
    print(response)