AI Prompts / Data Engineering
Production data-platform prompts for pipelines, warehouses, quality, and on-call. Written for staff-level review, not toy ETL examples.
32 listings
Data Engineering
Audit a change-data-capture pipeline for gaps, duplicates, reordering, and recovery risks.
Plan a backward-compatible schema change across producers, pipelines, and consumers.
Design a safe, restartable backfill without overwhelming production systems.
Size a streaming platform for peak traffic, ordering, lag, and failure recovery.
Determine whether a streaming system delivers real end-to-end exactly-once outcomes.
Diagnose stragglers, spills, OOMs, and expensive shuffles in large Spark jobs.
Fix small-file amplification while preserving ingestion latency and safe concurrency.
Diagnose why a warehouse query suddenly got slower or more expensive, with likely causes, checks to run, and practical remediations.
Design auditable reconciliation controls for revenue, payments, or ledger pipelines.
Turn vague data reliability expectations into measurable SLOs and error budgets.
Find sensitive-data exposure and design least-privilege controls across a data platform.
Build and test recovery plans for regional outages, corruption, and credential compromise.
Review an Airflow DAG for idempotency, scheduler pressure, backfills, and safe recovery.
Prove a dbt incremental model handles updates, late data, deletes, and full refreshes.
Detect point-in-time leakage and training-serving skew in feature pipelines.
Design globally resilient event ingestion with clear consistency and failover semantics.
Plan a low-risk warehouse migration with measurable parity and rollback gates.
Turn legal, business, and cost constraints into enforceable lifecycle policies.
Build a layered test suite that catches transformation, contract, and replay defects before production.
Create a low-ambiguity runbook for diagnosing and restoring critical data pipelines.
Find expensive queries and recommend practical warehouse cost reductions.
Run a structured root-cause analysis for broken pipelines or bad dashboards.
Design event topics, keys, and schemas for reliable streaming pipelines.
Document end-to-end lineage from source systems to dashboards or ML features.
Choose an incremental load pattern—merge, append, or CDC—and spell out keys, late data handling, and warehouse-safe implementation steps.
Draft a producer–consumer data contract covering schema, freshness, ownership, and failure expectations for a shared dataset.
Write efficient PySpark transformations with partitioning and performance notes.
Design a star or snowflake schema with fact grain, measures, dimensions, and SCD recommendations for a defined analytics process.
Scaffold a clean Airflow DAG with retries, sensors, and clear task boundaries.
Define practical data quality checks and thresholds for a critical table.
Design a reliable batch or streaming data pipeline from source to warehouse.
Generate production-ready dbt models with tests, docs, and naming conventions.