GCP Data Engineer study plan
GCP Data Engineer · Give each week a clear focus.
8 weeks · About 7 hours per week
Design data processing systems
Sketch the end-to-end architecture of three reference pipelines (batch ELT, streaming event ingestion, hybrid CDC) and label every GCP service on each hop
Compare BigQuery, Cloud SQL, Spanner, Bigtable, Firestore, and Cloud Storage on access pattern, scale, and consistency, and produce a written selection rule for each
Choose a file format and partitioning/clustering strategy for two sample datasets and justify the choice against query cost and scan volume
List the IAM roles, service accounts, and network controls (private IP, VPC Service Controls, CMEK) each reference architecture needs
Your checkpoint
A 3-page architecture decision record covering all three reference pipelines with service choices, data formats, and IAM/network assumptions for each
Design data processing systems & Ingest and process the data
Map each of the three reference architectures to a concrete migration or build sequence, ordering the steps by dependency
Design the schema, partitioning, clustering, and expiration policy for a BigQuery warehouse layer (raw, staging, curated)
Identify where data quality checks and idempotency belong in each pipeline, and specify the checkpoints
Write out the cost model for one pipeline: storage, shuffle/compute, and query scan, with the two biggest cost levers
Your checkpoint
A warehouse and pipeline design document with schema DDL sketches, partitioning/clustering decisions, and a cost estimate table for one pipeline
Ingest and process the data
Build a batch pipeline that lands files from Cloud Storage into BigQuery and schedule it, then re-run it to prove idempotency
Build a streaming pipeline that ingests from Pub/Sub, applies windowing and late-data handling, and writes to BigQuery
Implement a CDC path using Datastream or a change-stream pattern and explain how deletes and updates are propagated downstream
Compare Dataflow, Dataproc, Cloud Data Fusion, and Dataproc Serverless for two given workloads and pick one for each with reasons
Add error handling and a dead-letter path to at least one pipeline
Your checkpoint
A working repo with one batch and one streaming pipeline (Terraform or scripts included) plus a short runbook of the exact commands to redeploy it
Ingest and process the data & Store the data
Tune one Dataflow job using autoscaling, worker type, and shuffle settings, and record the before/after metrics
Define the storage layout for a lakehouse-style zone: bucket structure, lifecycle rules, and format choices
Explain and configure retention, time travel, and failover behavior for one BigQuery dataset and one Cloud SQL or Spanner instance
Document how to move data between storage tiers and services (Storage to BigQuery, Bigtable to BigQuery, BigQuery to Cloud Storage export)
Your checkpoint
A tuning and storage-layout report showing the Dataflow before/after metrics and the lifecycle, retention, and export settings you configured
Store the data
Pick a storage service for four given workload profiles (high-throughput key lookups, relational OLTP, analytical scans, document/mobile sync) with a written rationale for each
Configure a Bigtable or Spanner schema (row key or interleaving) for a high-write workload and explain the hotspot or distribution reasoning
Implement external tables or a federated query against Cloud Storage and Cloud SQL and note the performance limits you observe
Define a backup, restore, and disaster-recovery plan for two different storage services
Your checkpoint
A storage selection matrix for the four workload profiles plus a tested backup/restore procedure for one service, with the commands used
Prepare and use data for analysis
Build a curated BigQuery layer using views, materialized views, and scheduled queries, and measure the scan cost before and after
Implement data quality and cleansing rules (deduplication, null handling, type casting, PII masking with DLP or SQL) on a sample dataset
Create a reporting asset in Looker Studio or a Looker-style semantic model that answers three defined business questions
Use BigQuery ML or a notebook-based workflow to train and evaluate one simple model on the curated data
Your checkpoint
A small analytics deliverable: curated tables, a masking rule applied to at least one PII column, and a dashboard or report answering three stated questions
Maintain and automate data workloads
Orchestrate two of your week 3 pipelines with Cloud Composer or Cloud Workflows, including retries and failure alerts
Instrument one pipeline with Cloud Monitoring dashboards and log-based alerts for latency, error rate, and data freshness
Automate deployment of the pipeline infrastructure with Terraform or an equivalent IaC setup and prove it recreates the environment from scratch
Write an SLA/SLO definition and an on-call runbook for one pipeline, covering common failure modes and rollback
Your checkpoint
An IaC bundle plus a monitoring dashboard and alert policy that you can screenshot, along with the runbook that names the exact recovery steps
Design data processing systems & Ingest and process the data & Store the data & Prepare and use data for analysis & Maintain and automate data workloads
Take two full-length timed practice exams and log every missed question by domain
Re-derive the selection rules for compute, storage, and ingestion services from memory, then correct them against your notes
Revisit the two weakest domains and rewrite the decision records from weeks 1 and 5 with the corrections
List every service you still cannot place confidently and close those gaps with focused reading
Your checkpoint
A scored practice-exam log by domain plus a one-page final cheat sheet of service-selection rules and anti-patterns, with any remaining gaps flagged
Milestones
Week 2: Can sketch a full batch and a full streaming architecture from memory, naming the service at every hop and justifying each choice in one sentence
Week 4: Two pipelines run end-to-end and are idempotent on re-run; Dataflow tuning produces a recorded, explainable metric improvement
Week 6: Score at least 70% on a 30-question mixed practice set covering domains 1-4, with storage and ingestion misses below 20%
Week 8: Score at least 80% on a full-length timed practice exam, with no domain below 70%