Skip to main content
T-SDPDF-AOfficial Google Curriculum

Serverless Data Processing with Dataflow

3 daysILTAdvancedLoading...

Overview

This training is intended for big data practitioners who want to further their understanding of Dataflow in order to advance their data processing applications. Beginning with foundations, this training explains how Apache Beam and Dataflow work together to meet your data processing needs without the risk of vendor lock-in. The section on developing pipelines covers how you convert your business logic into data processing applications that can run on Dataflow. This training culminates with a focus on operations, which reviews the most important lessons for operating a data application on Dataflow, including monitoring, troubleshooting, testing, and reliability.

What You'll Learn

  • Demonstrate how Apache Beam and Dataflow work together to fulfill your organization's data processing needs
  • Summarize the benefits of the Beam Portability Framework and enable it for your Dataflow pipelines
  • Enable Shuffle and Streaming Engine, for batch and streaming pipelines respectively, for maximum performance
  • Enable Flexible Resource Scheduling for more cost-efficient performance
  • Select the right combination of IAM permissions for your Dataflow job
  • Implement best practices for a secure data processing environment
  • Select and tune the I/O of your choice for your Dataflow pipeline
  • Use schemas to simplify your Beam code and improve the performance of your pipeline
  • Develop a Beam pipeline using SQL and DataFrames
  • Perform monitoring, troubleshooting, testing and CI/CD on Dataflow pipelines

Who Should Attend

Data Engineer. Data Analysts and Data Scientists aspiring to develop Data Engineering skills.

Prerequisites

Completed "Building Batch Data Pipelines". Completed "Building Resilient Streaming Analytics Systems".

Products Covered

DataflowCloud Operations

Course Modules

1

Introduction

Topics

  • Course Introduction
  • Beam and Dataflow Refresher

Learning Outcomes

  • Introduce the course objectives
  • Demonstrate how Apache Beam and Dataflow work together to fulfill your organization's data processing needs
2

Beam Portability

Topics

  • Beam Portability
  • Runner v2
  • Container Environments
  • Cross-Language Transforms

Learning Outcomes

  • Summarize the benefits of the Beam Portability Framework
  • Customize the data processing environment of your pipeline using custom containers
  • Review use cases for cross-language transformations
  • Enable the Portability framework for your Dataflow pipelines

Activities

Quiz
3

Separating Compute and Storage with Dataflow

Topics

  • Dataflow Shuffle Service
  • Dataflow Streaming Engine
  • Flexible Resource Scheduling

Learning Outcomes

  • Enable Shuffle and Streaming Engine, for batch and streaming pipelines respectively, for maximum performance
  • Enable Flexible Resource Scheduling for more cost-efficient performance

Activities

Quiz
4

IAM, Quotas, and Permissions

Topics

  • IAM
  • Quota

Learning Outcomes

  • Select the right combination of IAM permissions for your Dataflow job
  • Determine your capacity needs by inspecting the relevant quotas for your Dataflow jobs

Activities

Quiz
5

Security

Topics

  • Data Locality
  • Shared VPC
  • Private IPs
  • CMEK

Learning Outcomes

  • Select your zonal data processing strategy using Dataflow, depending on your data locality needs
  • Implement best practices for a secure data processing environment

Activities

Hands-on lab and quiz
6

Beam Concepts Review

Topics

  • Beam Basics
  • Utility Transforms
  • DoFn Lifecycle

Learning Outcomes

  • Review main Apache Beam concepts (Pipeline, PCollections, PTransforms, Runner, reading/writing, Utility PTransforms, side inputs), bundles and DoFn Lifecycle

Activities

Hands-on lab and quiz
7

Windows, Watermarks, Triggers

Topics

  • Windows
  • Watermarks
  • Triggers

Learning Outcomes

  • Implement logic to handle your late data
  • Review different types of triggers
  • Review core streaming concepts (unbounded PCollections, windows)

Activities

Hands-on lab and quiz
8

Sources and Sinks

Topics

  • Sources and Sinks
  • Text IO and File IO
  • BigQuery IO
  • PubSub IO
  • Kafka IO
  • Bigtable IO
  • Avro IO
  • Splittable DoFn

Learning Outcomes

  • Write the I/O of your choice for your Dataflow pipeline
  • Tune your source/sink transformation for maximum performance
  • Create custom sources and sinks using SDF

Activities

Quiz
9

Schemas

Topics

  • Beam Schemas
  • Code Examples

Learning Outcomes

  • Introduce schemas, which give developers a way to express structured data in their Beam pipelines
  • Use schemas to simplify your Beam code and improve the performance of your pipeline

Activities

Hands-on lab and quiz
10

State and Timers

Topics

  • State API
  • Timer API
  • Summary

Learning Outcomes

  • Identify use cases for state and timer API implementations
  • Select the right type of state and timers for your pipeline

Activities

Quiz
11

Best Practices

Topics

  • Schemas
  • Handling unprocessable Data
  • Error Handling
  • AutoValue Code Generator
  • JSON Data Handling
  • Utilize DoFn Lifecycle
  • Pipeline Optimizations

Learning Outcomes

  • Implement best practices for Dataflow pipelines

Activities

Hands-on lab and quiz
12

Dataflow SQL and DataFrames

Topics

  • Dataflow and Beam SQL
  • Windowing in SQL
  • Beam DataFrames

Learning Outcomes

  • Develop a Beam pipeline using SQL and DataFrames

Activities

Hands-on lab and quiz
13

Beam Notebooks

Topics

  • Beam Notebooks

Learning Outcomes

  • Prototype your pipeline in Python using Beam notebooks
  • Launch a job to Dataflow from a notebook

Activities

Quiz
14

Monitoring

Topics

  • Job List
  • Job Info
  • Job Graph
  • Job Metrics
  • Metrics Explorer

Learning Outcomes

  • Navigate the Dataflow Job Details UI
  • Interpret Job Metrics charts to diagnose pipeline regressions
  • Set alerts on Dataflow jobs using Cloud Monitoring

Activities

Quiz
15

Logging and Error Reporting

Topics

  • Logging
  • Error Reporting

Learning Outcomes

  • Use the Dataflow logs and diagnostics widgets to troubleshoot pipeline issues

Activities

Quiz
16

Troubleshooting and Debug

Topics

  • Troubleshooting Workflow
  • Types of Troubles

Learning Outcomes

  • Use a structured approach to debug your Dataflow pipelines
  • Examine common causes for pipeline failures

Activities

Hands-on lab and quiz
17

Performance

Topics

  • Pipeline Design
  • Data Shape
  • Source, Sinks, and External Systems
  • Shuffle and Streaming Engine

Learning Outcomes

  • Understand performance considerations for pipelines
  • Consider how the shape of your data can affect pipeline performance

Activities

Quiz
18

Testing and CI/CD

Topics

  • Testing and CI/CD Overview
  • Unit Testing
  • Integration Testing
  • Artifact Building
  • Deployment

Learning Outcomes

  • Testing approaches for your Dataflow pipeline
  • Review frameworks and features available to streamline your CI/CD workflow for Dataflow pipelines

Activities

Hands-on labs and quiz
19

Reliability

Topics

  • Introduction to Reliability
  • Monitoring
  • Geolocation
  • Disaster Recovery
  • High Availability

Learning Outcomes

  • Implement reliability best practices for your Dataflow pipelines

Activities

Quiz
20

Flex Templates

Topics

  • Classic Templates
  • Flex Templates
  • Using Flex Templates
  • Google-provided Templates

Learning Outcomes

  • Using flex templates to standardize and reuse Dataflow pipeline code

Activities

Hands-on labs and quiz
21

Summary

Topics

  • Summary

Learning Outcomes

  • Quick recap of training topics

Get This Training

No public classes currently scheduled. Express interest below or request private training.

Request Private Session

Course Details

Course Code
T-SDPDF-A
Duration
3 days
Format
ILT
Level
Advanced
Modules
21
Activities
21
Price
Loading...
View Official Google Datasheet →

Questions About This Course?

Contact us for custom scheduling, group discounts, or curriculum customization.

Contact Us
Starting fromLoading...