Data Engineering

Build scalable batch and stream data pipelines with Spark, Airflow, dbt, and Kafka.

Updated Aug 27, 2026
One-click install
npx skills add https://github.com/qenex-ai/devops-plugin --skill data-engineering-qenex-ai
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: Data Engineering
Source: https://github.com/qenex-ai/devops-plugin/tree/main/skills/data-engineering
Command: npx skills add https://github.com/qenex-ai/devops-plugin --skill data-engineering-qenex-ai

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve?

This Skill helps teams design and implement scalable data pipelines, ETL processes, and data infrastructure, reducing manual coding and operational overhead across data platforms.

Core Features & Use Cases

  • Batch processing: Build and orchestrate batch ETL pipelines using Spark, SQL, and dbt.
  • Stream processing: Enable real-time data streams with Kafka, Flink, or Spark Streaming.
  • Data quality & governance: Implement validation, lineage, and quality checks for data assets.
  • Use Case: Create a daily ingestion workflow to move raw events into a curated data warehouse and apply quality checks with a dbt model.

Quick Start

Create a simple batch pipeline: ingest raw data, apply transformations with Spark, and load results into a target data warehouse.

Frequently Asked Questions about Data Engineering

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

FAQPage Schema
How do I build scalable data pipelines for batch and stream processing?▼

To build scalable data pipelines, this skill helps teams design and implement ETL workflows using Apache Spark, Airflow, and Kafka for both batch processing and real-time streaming analytics. It reduces manual coding and operational overhead.

How do I orchestrate a daily ETL workflow with dbt and Airflow?▼

To orchestrate a daily ETL workflow with dbt and Airflow, you can ingest raw events, apply transformations using Spark or SQL, and load results into a curated data warehouse while applying data quality checks via a dbt model.

What is the best way to implement data quality and lineage checks in an ELT pipeline?▼

Implementing data quality and lineage checks in an ELT pipeline involves applying validation rules and governance checks directly within your dbt models to ensure curated data warehouse assets maintain high quality and reliability.

Can I use Apache Spark Streaming with Kafka for real-time data analytics?▼

Yes, you can use Apache Spark Streaming or Flink with Kafka to enable real-time data streams. This allows teams to process continuous data flows and build streaming analytics pipelines for immediate insights.

How do I ingest raw data into a data lake using Apache Spark?▼

To ingest raw data into a data lake using Apache Spark, you can build a batch pipeline that extracts raw events, applies necessary transformations, and loads the curated results into a target data warehouse or cloud storage.

What are the limitations of batch processing versus stream processing for data infrastructure?▼

Batch processing handles scheduled daily workflows using Spark and SQL, whereas stream processing handles real-time continuous data via Kafka and Flink. Batch is not suitable for immediate analytics, while streaming requires more complex infrastructure.