bronze-extraction-pipeline

Build resumable Bronze extraction pipelines from relational sources using snapshot hashing.

Updated Apr 10, 2026
One-click install
npx skills add https://github.com/Wkayaobama/wkayaobama-skills --skill bronze-extraction-pipeline
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: bronze-extraction-pipeline
Source: https://github.com/Wkayaobama/wkayaobama-skills/tree/main/skills/workflowps
Command: npx skills add https://github.com/Wkayaobama/wkayaobama-skills --skill bronze-extraction-pipeline

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve?

Creating reliable, resumable data extraction pipelines from legacy relational systems is hard because the source often lacks CDC, stable change feeds, or trustworthy timestamps.

Core Features & Use Cases

  • Entity Contract first: Define canonical entities (name, PK, updated column, expected output columns) and an explicit FK graph before writing any SQL or stages.
  • Snapshot + delta via content hashing: Detect new/modified/deleted rows by hashing row content between the current snapshot and the prior approved baseline.
  • Layered quality gates: Enforce structural hard-fail checks (PK, uniqueness, schema coverage, empty-string FK risks) and run scored format/semantic validation plus human approval before loading.
  • Stage orchestration with resume sentinels: Use numeric stage IDs and per-stage sentinel files so failed runs resume from the exact stage without redoing side effects.
  • Filesystem-namespaced audit trail: Produce immutable raw/clean extracts, delta manifests, validation artifacts, review packages, and approved outputs per {entity}/{run_id}.

Quick Start

Use the bronze-extraction-pipeline skill when you are designing a Bronze/medallion extraction workflow that must be reproducible, resumable, and delta-aware from a relational source system.

Frequently Asked Questions about bronze-extraction-pipeline

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

FAQPage Schema
How do I extract data incrementally from SQL Server when CDC is unavailable?

To extract data incrementally from SQL Server without CDC, use deterministic snapshot hashing to detect new, modified, or deleted rows by comparing current row snapshots against a prior approved baseline.

What is an idempotent bronze extraction pipeline?

An idempotent bronze extraction pipeline uses stage sentinel files and approval checkpoints to guarantee resumability, ensuring failed runs resume from the exact stage without redoing side effects.

How do I build a resumable staging layer for legacy CRM data?

Build a resumable staging layer for legacy CRM data by defining entity contracts and using numeric stage IDs with per-stage sentinel files, allowing failed pipeline runs to resume directly at the point of failure.

What quality gates should I apply before loading data into a bronze pipeline?

Before loading data into a bronze pipeline, apply structural hard-fail quality gates for primary keys, uniqueness, and schema coverage, then run scored format and semantic validation plus human approval checkpoints.

How do I track an auditable delta detection process for relational sources?

Track an auditable delta detection process for relational sources by generating filesystem-namespaced audit trails that store immutable raw extracts, delta manifests, validation artifacts, and approved outputs per entity and run ID.