Crie um data pipeline
Este início rápido mostra como fazer o seguinte:
- Crie uma instância do Cloud Data Fusion.
- Implemente um pipeline de exemplo fornecido com a sua instância do Cloud Data Fusion. O pipeline faz o seguinte:
- Lê um ficheiro JSON que contém dados de bestsellers do NYT do Cloud Storage.
- Executa transformações no ficheiro para analisar e limpar os dados.
- Carrega os livros com melhor classificação adicionados na última semana que custam menos de 25 € no BigQuery.
Antes de começar
- Sign in to your Google Cloud account. If you're new to Google Cloud, create an account to evaluate how our products perform in real-world scenarios. New customers also get $300 in free credits to run, test, and deploy workloads.
-
In the Google Cloud console, on the project selector page, select or create a Google Cloud project.
Roles required to select or create a project
- Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
-
Create a project: To create a project, you need the Project Creator
(
roles/resourcemanager.projectCreator
), which contains theresourcemanager.projects.create
permission. Learn how to grant roles.
-
Enable the Cloud Data Fusion API.
Roles required to enable APIs
To enable APIs, you need the Service Usage Admin IAM role (
roles/serviceusage.serviceUsageAdmin
), which contains theserviceusage.services.enable
permission. Learn how to grant roles. -
In the Google Cloud console, on the project selector page, select or create a Google Cloud project.
Roles required to select or create a project
- Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
-
Create a project: To create a project, you need the Project Creator
(
roles/resourcemanager.projectCreator
), which contains theresourcemanager.projects.create
permission. Learn how to grant roles.
-
Enable the Cloud Data Fusion API.
Roles required to enable APIs
To enable APIs, you need the Service Usage Admin IAM role (
roles/serviceusage.serviceUsageAdmin
), which contains theserviceusage.services.enable
permission. Learn how to grant roles. - Clique em Criar uma instância.
- Introduza um Nome da instância.
- Introduza uma Descrição para a sua instância.
- Introduza a região na qual criar a instância.
- Escolha a versão do Cloud Data Fusion a usar.
- Escolha a edição do Cloud Data Fusion.
- Para as versões 6.2.3 e posteriores do Cloud Data Fusion, no campo Autorização, escolha a conta de serviço do Dataproc a usar para executar o seu pipeline do Cloud Data Fusion no Dataproc. O valor predefinido, conta do Compute Engine, está pré-selecionado.
- Clique em Criar. O processo de criação da instância demora até 30 minutos a ser concluído. Enquanto o Cloud Data Fusion cria a sua instância, é apresentado um indicador de progresso junto ao nome da instância na página Instâncias. Após a conclusão, transforma-se numa marca de verificação verde e indica que pode começar a usar a instância.
Na Google Cloud consola, pode fazer o seguinte:
- Crie um Google Cloud projeto da consola
- Crie e elimine instâncias do Cloud Data Fusion
- Veja os detalhes da instância do Cloud Data Fusion
Na interface Web do Cloud Data Fusion, pode usar várias páginas, como o Studio ou o Wrangler, para usar a funcionalidade do Cloud Data Fusion.
- Na Google Cloud consola, abra a página Instâncias.
- Na coluna Ações da instância, clique no link Ver instância.
- Na interface Web do Cloud Data Fusion, use o painel de navegação do lado esquerdo para navegar para a página de que precisa.
- Na interface Web do Cloud Data Fusion, clique em Hub.
- No painel do lado esquerdo, clique em Pipelines.
- Clique no pipeline Início rápido do Cloud Data Fusion.
- Clique em Criar.
- No painel de configuração do início rápido do Cloud Data Fusion, clique em Concluir.
Clique em Personalizar pipeline.
É apresentada uma representação visual do seu pipeline na página Studio, que é uma interface gráfica para desenvolver pipelines de integração de dados. Os plug-ins de pipeline disponíveis são apresentados à esquerda e o seu pipeline é apresentado na área de tela principal. Pode explorar o seu pipeline mantendo o ponteiro sobre cada nó do pipeline e clicando em Propriedades. O menu de propriedades de cada nó permite-lhe ver os objetos e as operações associados ao nó.
No menu do canto superior direito, clique em Implementar. Este passo envia o pipeline para o Cloud Data Fusion. Vai executar o pipeline na secção seguinte deste início rápido.
- Ver a estrutura e a configuração do pipeline.
- Executar o pipeline manualmente ou configurar um horário ou um acionador.
- Veja um resumo das execuções históricas do pipeline, incluindo os tempos de execução, os registos e as métricas.
- Aprovisiona um cluster do Dataproc efémero
- Executa o pipeline no cluster através do Apache Spark
- Elimina o cluster
- Aceda à interface Web do BigQuery.
Para ver uma amostra dos resultados, aceda ao conjunto de dados
DataFusionQuickstart
no seu projeto, clique na tabelatop_rated_inexpensive
e, de seguida, execute uma consulta simples. Por exemplo:SELECT * FROM PROJECT_ID.GCPQuickStart.top_rated_inexpensive LIMIT 10
Substitua PROJECT_ID pelo ID do seu projeto.
- Elimine o conjunto de dados do BigQuery no qual a sua pipeline escreveu neste início rápido.
Opcional: elimine o projeto.
- In the Google Cloud console, go to the Manage resources page.
- In the project list, select the project that you want to delete, and then click Delete.
- In the dialog, type the project ID, and then click Shut down to delete the project.
Crie uma instância do Cloud Data Fusion
Navegue na interface Web do Cloud Data Fusion
Quando usa o Cloud Data Fusion, usa a Google Cloud consola e a interface Web do Cloud Data Fusion separada.
Para navegar na interface do Cloud Data Fusion, siga estes passos:
Implemente uma pipeline de amostra
Os pipelines de exemplo estão disponíveis através do Hub do Cloud Data Fusion, que lhe permite partilhar pipelines, plug-ins e soluções reutilizáveis do Cloud Data Fusion.
Veja o seu pipeline
O pipeline implementado é apresentado na vista de detalhes do pipeline, onde pode fazer o seguinte:
Execute o seu pipeline
Na vista de detalhes do pipeline, clique em Executar para executar o pipeline.
Quando executa um pipeline, o Cloud Data Fusion faz o seguinte:
Veja os resultados
Após alguns minutos, o pipeline termina. O estado do pipeline muda para Concluído e é apresentado o número de registos processados por cada nó.
Limpar
Para evitar incorrer em cobranças na sua Google Cloud conta pelos recursos usados nesta página, siga estes passos.