senior-data-engineer

Automate end-to-end data engineering workflows with Python and Airflow.

4|Updated Feb 22, 2026
One-click install
npx skills add https://github.com/GeneralReasoning/env-skillsbench --skill senior-data-engineer-generalreasoning
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: senior-data-engineer
Source: https://github.com/GeneralReasoning/env-skillsbench/tree/main/flink-query/environment/skills/senior-data-engineer
Command: npx skills add https://github.com/GeneralReasoning/env-skillsbench --skill senior-data-engineer-generalreasoning

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes scripts (resource) and references (resource) and assets (resource) components.

What problem does it solve?

The Senior Data Engineer skill helps organizations design, implement, and operate production-grade data pipelines spanning batch and streaming workloads, with built-in data quality, governance, and observability.

Core Features & Use Cases

  • Batch and real-time pipeline design and orchestration using Airflow, Spark, Kafka, Flink, and dbt.
  • Data quality, governance, streaming quality monitoring, and DataOps across end-to-end data flows.
  • Enterprise-ready performance optimization, cost analysis, and operational runbooks for data platforms.

Quick Start

Create a starter pipeline by defining a YAML config and running the included tools to generate an Airflow DAG and perform validations.

Frequently Asked Questions about senior-data-engineer

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

FAQPage Schema
How do I design and orchestrate batch ETL pipelines using Airflow and Spark?

Batch ETL pipeline design uses Airflow for orchestration and Spark for distributed processing. You define YAML configurations to generate DAGs, automate execution, and apply data quality validation across scalable workflows.

What is the best way to monitor streaming data quality in real-time analytics pipelines?

Streaming data quality monitoring validates live records within Kafka and Flink architectures. It applies DataOps controls to detect anomalies, enforce governance, and maintain reliable real-time analytics across pipelines.

Can I use dbt for data transformations within cross-cloud data engineering workflows?

Yes, dbt executes data transformations within cross-cloud compatible workflows. It integrates with pipeline orchestration to enforce governance, validate quality, and model data across batch and streaming platforms.

Does this approach support production-grade data governance and observability for healthcare and finance?

Yes, production-grade data governance and observability support healthcare and finance contexts. It implements robust monitoring, DataOps patterns, and quality controls to satisfy strict enterprise compliance requirements.

How do I generate an Airflow DAG from a YAML config for a starter data pipeline?

You generate an Airflow DAG by defining a YAML configuration and running included Python-based scripts. This scaffolds starter pipelines, creates orchestration logic automatically, and performs initial data validations.

When do I need streaming architectures instead of batch ETL for data pipelines?

You need streaming architectures instead of batch ETL when workloads demand real-time analytics and immediate data availability. Streaming handles continuous data flows, whereas batch processes discrete scheduled intervals.