Class AutoscalingPolicyServiceClient (5.0.3)

The API interface for managing autoscaling policies in the Dataproc API.

Returns the transport used by the client instance.

Instantiates the autoscaling policy service client.

Releases underlying transport's resources.

Returns a fully-qualified autoscaling_policy string.

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 new autoscaling policy.

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

def sample_create_autoscaling_policy():
    # Create a client
    client = dataproc_v1.AutoscalingPolicyServiceClient()

    # Initialize request argument(s)
    policy = dataproc_v1.AutoscalingPolicy()
    policy.basic_algorithm.yarn_config.scale_up_factor = 0.1578
    policy.basic_algorithm.yarn_config.scale_down_factor = 0.1789
    policy.worker_config.max_instances = 1389

    request = dataproc_v1.CreateAutoscalingPolicyRequest(
        parent="parent_value",
        policy=policy,
    )

    # Make the request
    response = client.create_autoscaling_policy(request=request)

    # Handle the response
    print(response)

Deletes an autoscaling policy. It is an error to delete an autoscaling policy that is in use by one or more clusters.

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

def sample_delete_autoscaling_policy():
    # Create a client
    client = dataproc_v1.AutoscalingPolicyServiceClient()

    # Initialize request argument(s)
    request = dataproc_v1.DeleteAutoscalingPolicyRequest(
        name="name_value",
    )

    # Make the request
    client.delete_autoscaling_policy(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 autoscaling policy.

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

def sample_get_autoscaling_policy():
    # Create a client
    client = dataproc_v1.AutoscalingPolicyServiceClient()

    # Initialize request argument(s)
    request = dataproc_v1.GetAutoscalingPolicyRequest(
        name="name_value",
    )

    # Make the request
    response = client.get_autoscaling_policy(request=request)

    # Handle the response
    print(response)

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 variabel 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.

Lists autoscaling policies in the project.

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

def sample_list_autoscaling_policies():
    # Create a client
    client = dataproc_v1.AutoscalingPolicyServiceClient()

    # Initialize request argument(s)
    request = dataproc_v1.ListAutoscalingPoliciesRequest(
        parent="parent_value",
    )

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

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

Parses a autoscaling_policy path into its component segments.

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.

Updates (replaces) autoscaling policy.

Disabled check for update_mask, because all updates will be full replacements.

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

def sample_update_autoscaling_policy():
    # Create a client
    client = dataproc_v1.AutoscalingPolicyServiceClient()

    # Initialize request argument(s)
    policy = dataproc_v1.AutoscalingPolicy()
    policy.basic_algorithm.yarn_config.scale_up_factor = 0.1578
    policy.basic_algorithm.yarn_config.scale_down_factor = 0.1789
    policy.worker_config.max_instances = 1389

    request = dataproc_v1.UpdateAutoscalingPolicyRequest(
        policy=policy,
    )

    # Make the request
    response = client.update_autoscaling_policy(request=request)

    # Handle the response
    print(response)