gcp-dataflow

Build and troubleshoot Apache Beam pipelines for Google Cloud Dataflow.

Updated Jun 10, 2026
One-click install
npx skills add https://github.com/AubreyHan/SKILL_Repo --skill gcp-dataflow-aubreyhan
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: gcp-dataflow
Source: https://github.com/AubreyHan/SKILL_Repo/tree/main/gcp-dataflow
Command: npx skills add https://github.com/AubreyHan/SKILL_Repo --skill gcp-dataflow-aubreyhan

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve?

This Skill helps you build, package, launch, and troubleshoot Apache Beam pipelines on Google Cloud Dataflow without guessing at deployment details or runtime settings.

Core Features & Use Cases

  • Project Setup Guidance: Choose Beam versions, language-specific project structure, and consistent dependency versions across Java and Python pipelines.
  • Flex Template Packaging: Build reproducible Dataflow Flex Templates, with Cloud Build preferred for image creation and single-image support for Python dependencies.
  • Operations and RCA: Diagnose slow or failing jobs using Dataflow messages, Monitoring metrics, and Cloud Logging.
  • Example Use Case: A team migrating a Python streaming pipeline to Dataflow can use this Skill to standardize the Docker image, launch parameters, and troubleshooting workflow.

Quick Start

Ask for help creating or debugging a Google Cloud Dataflow Apache Beam pipeline, and include the language, whether you need a Flex Template, and any job or performance details you already have.

Frequently Asked Questions about gcp-dataflow

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I build a reproducible Dataflow Flex Template with Cloud Build?

To build a Dataflow Flex Template, use Cloud Build for Docker image creation and configure single-image dependency support for Python. This standardizes packaging and ensures consistent DataflowRunner launches across deployments.

Why is my Apache Beam pipeline failing on Google Cloud Dataflow?

Diagnose failing Dataflow pipelines by analyzing Dataflow messages, Monitoring metrics, and Cloud Logging. This root-cause analysis workflow identifies runtime option misconfigurations or version alignment issues across Java and Python.

How do I set up a new Apache Beam project for Google Cloud Dataflow?

Set up a Dataflow project by selecting consistent Apache Beam versions and structuring language-specific dependencies. This ensures version alignment and proper configuration for Java and Python workflows.

Do I need specific Apache Beam versions for Python and Java Dataflow pipelines?

Yes, version alignment is required for Dataflow pipelines. You must choose consistent Beam versions and manage language-specific project structures to ensure dependencies match across Java and Python workflows.

What is the best way to diagnose slow performance in Dataflow streaming jobs?

Diagnose slow Dataflow jobs using metrics-and-logs based root-cause analysis. Evaluate Dataflow messages and Monitoring metrics to identify bottlenecks in streaming pipeline performance.

Can I package all Python dependencies into a single Dataflow Flex Template image?

Yes, Dataflow Flex Templates support single-image dependency packaging for Python pipelines. Using Cloud Build for image creation ensures all required dependencies are standardized within the Docker container.