Criar um cliente para iniciar um modelo de fluxo de trabalho do Dataproc

Cria um cliente usando o Application Default Credentials para iniciar um modelo de fluxo de trabalho do Dataproc. Usa o endpoint global ou regional.

Exemplo de código

Python

Antes de testar este exemplo, siga as instruções de configuração do Python no Guia de início rápido do Managed Service for Apache Spark: como usar bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API do Managed Service for Apache Spark.Python

Para autenticar o Managed Service for Apache Spark, configure o Application Default Credentials. Se quiser mais informações, consulte Configurar a autenticação para um ambiente de desenvolvimento local.

if global_region:
    region = "global"
    # Use the default gRPC global endpoints.
    dataproc_workflow_client = dataproc_v1.WorkflowTemplateServiceClient()
else:
    region = get_region_from_zone(zone)
    # Use a regional gRPC endpoint. See:
    # https://cloud.google.com/dataproc/docs/concepts/regional-endpoints
    client_transport = workflow_template_service_grpc_transport.WorkflowTemplateServiceGrpcTransport(
        address=f"{region}-dataproc.googleapis.com:443"
    )
    dataproc_workflow_client = dataproc_v1.WorkflowTemplateServiceClient(
        client_transport
    )

A seguir

Para pesquisar e filtrar exemplos de código de outros Google Cloud produtos, consulte a Google Cloud pesquisa de exemplos de código.