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 Python no Guia de início rápido do Serviço Gerenciado para Apache Spark: como usar bibliotecas de cliente. Para mais informações, consulte a documentação de referência da APIPython do Serviço Gerenciado para Apache Spark.

Para autenticar o Serviço Gerenciado para 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.