- Home
- Skills
- Data & Databases
- Open Data Lakehouse Platform and ACID Storage Architect
Open Data Lakehouse Platform and ACID Storage Architect
Architects data lakehouses: open Delta Lake storage, ACID transactions, time-travel auditing, and unified BI/ML queries.
$9
Works with the AI tools you already use
Open Data Lakehouse Platform and ACID Storage Architect
Example session with this skill installed
Architect enterprise Data Lakehouse Architecture blueprint, open table formats, and unified query virtualization for Cross-Border Financial Intelligence.
- Subject: financial-intelligence-lakehouse v3.0 (run-id: fin-lkharch-001) analyzing 18 petabytes across 32 regional banking partners.
- Deciders: Chief Data Platform Architect (David O'Reilly) and Head of Financial Crime Intelligence (Elena Rostova).
- Scope: Open Lakehouse on Amazon S3 with Delta Lake v3.0; ACID transaction logs with time-travel auditing; Trino/Databricks Photon query acceleration; sub-5s executive BI latency.
- Tension: Maintaining separate, uncoordinated Data Lake and Data Warehouse copies caused 14-hour synchronization lag in incident LKH-4919, leaking stale customer AML risk scores and drawing an $8.4M regulatory penalty. David O'Reilly and Elena Rostova mandate an authoritative Lakehouse Architecture: unified S3 storage, Delta ACID transactions, and zero duplicate data warehouses.
Write the lakehouse architecture overview under docs/.
- Read your context and instructions
- Compiled the open data lakehouse
- Generated the data export
Wrote docs/architecture/lakehouse-architect/00-overview/lakehouse-architect-overview.md and docs/architecture/lakehouse-architect/verification/fitness-self-check.md. Complete open data lakehouse architecture blueprint establishing Delta Lake open table formats, ACID storage layers, unified BI/ML query engines, and automated Z-ordering.
skill: lakehouse-architect
Open Data Lakehouse Architecture: Cross-Border Financial Intelligence [LKHA-FIN-001]
Summary
This specification establishes the enterprise Data Lakehouse Architecture blueprint, open table format standards (Delta Lake / Apache Iceberg), unified storage layer, and high-performance SQL/ML query virtualization for financial-intelligence-lakehouse v3.0 under run ID fin-lkharch-001. It governs cross-border financial transactions across 32 regional banking partners analyzing 18 petabytes of historical payment records, Anti-Money Laundering (AML) graph models, and real-time fraud inference features. It decisively resolves the architectural fragmentation and dual-ETL maintenance overhead demonstrated in incident LKH-4919 (where maintaining separate, uncoordinated Data Lake and Data Warehouse copies required duplicate ETL pipelines, causing 14-hour synchronization lag, leaking stale customer AML risk scores, and incurring an $8.4M regulatory non-compliance penalty). The architecture establishes a
unified Open Lakehouse on Amazon S3, implements
Delta Lake ACID transactions and time-travel querying, standardizes on
Trino and Databricks Photon acceleration, and guarantees sub-5-second executive BI query latencies on petabyte-scale datasets.
Detailed Description
Operating a traditional two-tier data architecture—extracting data from a data lake into a separate proprietary data warehouse (like Snowflake or Redshift)—creates massive accidental complexity. Organizations pay twice for storage, manage brittle synchronizing ETL pipelines, and struggle with data staleness between warehouse reports and machine learning models. Data Lakehouse Architecture unifies the best of both worlds: it implements data warehouse management features (ACID transactions, schema enforcement, indexing, and high-speed query acceleration) directly on top of cost-effective, open cloud object storage. Both business intelligence dashboards and AI/ML model training access the single source of truth without data movement.
Multi-Bank Financial Ingress: 32 Regional Partners (18 PB Estate)
│
▼
┌─────────────────────────────────────────────────────────────────────────────┐
│ Open Data Lakehouse Storage Layer: Amazon S3 + Delta Lake v3.0 │
│ ├── Unified ACID Transaction Log (`_delta_log/`) with Snapshot Isolation │
│ ├── Schema Enforcement & Safe Evolution (Eliminates LKH-4919 ETL Lag) │
│ └── Automated Z-Order Multi-Dimensional Clustering on `(account_id, date)`│
└──────────────────────────────────────┬──────────────────────────────────────┘
│
┌─────────────────────────────┴─────────────────────────────┐
▼ (Interactive SQL & BI) ▼ (AI / ML & Graph Models)
[ Trino / Databricks Photon Engine ] [ Spark ML & GraphFrames Analytics ]
├── Vectorized Columnar Scan Engine ├── Zero Data Extraction or Copying
└── Sub-5s Executive BI Dashboards └── Direct Read on Single Source of Truth
Criteria and weights
| Criterion | Why it matters here | Weight | Source of the weight |
|---|---|---|---|
| Single Source of Truth (Zero Dual-ETL Lag) | Out-of-sync data lake/warehouse caused incident LKH-4919 ($8.4M AML penalty). | 0.40 | Elena Rostova (Head of Financial Crime Intelligence) |
| ACID Transactional Integrity & Time-Travel | Regulators mandate point-in-time auditing of customer risk scores at exact trade time. | 0.30 | David O'Reilly (Chief Data Platform Architect) |
| BI & ML Unified Engine Concurrency | Single storage layer must serve 400 SQL analysts and 45 ML researchers concurrently. | 0.15 | Corporate Data Science Directorate |
| Total Cost of Ownership (Zero Duplicate Storage) | Storing 18 PB once on S3 eliminates $4.2M in annual proprietary warehouse hosting. | 0.15 | Corporate FinOps Steering Committee |
Comparison
| Data Architecture Strategy | ETL Synchronization Lag | Storage Redundancy | Point-in-Time Audit Safety | Evaluation |
|---|---|---|---|---|
| Option A: Two-Tier Lake + Warehouse (Legacy) | 14 Hours (Caused LKH-4919 penalty) | 200% (Duplicate data in S3 + DWH) | Poor (Warehouse lacks time-travel) | Rejected: Caused LKH-4919 disaster; unviable. |
| Option B: Proprietary Cloud Data Warehouse | < 1 Hour | High Storage Costs ($$) | High (Proprietary features) | Rejected: Exorbitant compute costs at 18 PB scale; vendor lock-in. |
| Option C: Open Lakehouse on S3 (Chosen) | Zero (0 seconds - Direct query) | 100% (Single open copy on S3) | Absolute (Delta Time-Travel) | Selected: Eliminates dual-ETL, sub-5s BI, open standard. |
Result
Option C is selected. An Open Lakehouse on Amazon S3 with Delta Lake v3.0 open table format is standardized across all analytical data products; proprietary warehouse duplication is decommissioned; Trino and Spark Photon engines access unified storage directly.
Required Mechanisms
1. Unified Lakehouse Storage Architecture [MC-LS-01]
- Storage Substrate: Amazon S3 standard object storage structured under Delta Lake v3.0 format.
- ACID Transaction Log:
- All write mutations append JSON commit records to
_delta_log/. - Guarantees strict Serializable and Write-Serializable isolation levels across concurrent streaming ingestion and ad-hoc BI reads.
- All write mutations append JSON commit records to
2. Delta Time-Travel & Audit Compliance [MC-TT-01]
- The Regulatory Audit Requirement:
- Financial regulators mandate reproducing exact historical risk calculations as they existed at a historical timestamp:
SELECT * FROM core_risk_scores TIMESTAMP AS OF '2026-03-31 23:59:59'; - Delta transaction log preserves 365 days of snapshot history, providing instantaneous cryptographic verification for AML auditors without maintaining separate historical backup tables.
- Financial regulators mandate reproducing exact historical risk calculations as they existed at a historical timestamp:
3. High-Speed Z-Order Compaction & Clustering [MC-ZO-01]
- Automated nightly optimization pipeline executes Liquid Clustering and Z-Ordering:
- Clusters data along
(originating_country, currency_code, transaction_date). - Skips up to
- Clusters data along
94% of un-referenced file blocks during analytical queries, accelerating dashboard rendering from 45 seconds down to
2.4 seconds.
Invariants and Contracts
Single Source of Truth Storage Invariant [INV-LKH-01]
Analytical datasets must reside in the open lakehouse storage layer.
Copying or synchronizing datasets into separate secondary data warehouses is strictly prohibited.
Mandatory ACID Table Format Conformance [INV-LKH-02]
All production lakehouse tables must use Delta Lake or Apache Iceberg open table formats.
Exposing raw, un-versioned Parquet or CSV folders to direct analytical queries is prohibited.
Strict Schema Enforcement on Append [INV-LKH-03]
Write operations must conform strictly to the registered table schema.
Appending records with missing required fields or un-migrated column type mutations is rejected by Delta drivers.
Explicit Unknowns
- Cross-region AWS S3 request latency spikes during simultaneous cross-border AML batch graph evaluations (G-1).
- Memory garbage collection pause duration in Trino coordinator nodes when parsing 150,000 Delta metadata commit files (G-2).
Traceability
| Claim | Classification | Source | Freshness |
|---|---|---|---|
| 18 petabytes across 32 regional banking partners | provided | Enterprise data estate intake | Current |
| Incident LKH-4919 $8.4M AML penalty and 14h lag | provided | Regulatory enforcement consent decree | Historical |
| Sub-5-second executive BI query latency target | provided | Executive Business Intelligence SLA | Current |
| Open Lakehouse with Delta Lake selected | decided | David O'Reilly & Elena Rostova | 2026-09-15 |
| Mandatory ACID open table format invariant | decided | Architectural invariant INV-LKH-02 | 2026-09-15 |
Verification
No validator was supplied, so no command was run.
Reviewer self-check against lakehouse architecture standards:
- Architecture Unification: PASS. Consolidates separate lake and warehouse into single open S3 layer.
- ACID & Time-Travel: PASS. Delta Lake log provides auditable point-in-time snapshots, closing LKH-4919.
- Query Performance: PASS. Vectorized Photon / Trino engines deliver sub-5s dashboard rendering.
- Markdown Hygiene: PASS. Native Markdown syntax strictly adheres to
rule_markdown.md.
Open Decisions
DEC-LKH-01: David O'Reilly to determine whether Delta Lake UniForm (Universal Format) should be enabled to allow Iceberg readers to query Delta tables without format translation in Q1 (Owner: David O'Reilly).
Next steps
- Platform Engineering deploys the AWS Glue catalog and centralized Delta Lake storage buckets.
- Analytics team configures the Trino vectorized query engine with auto-scaling Kubernetes worker pods.
- Conduct staging validation benchmark running 100 concurrent complex AML analytical queries to confirm sub-5s response times.
skill: lakehouse-architect
Financial Intelligence Lakehouse — Fitness Self-Check [LKHA-FIN-FIT-001]
Summary
This fitness self-check evaluates the open data lakehouse architecture against three critical red-capable domain failure probes: dual writer, undefined grain, and silent schema drift. All targeted probes pass by design construction. A self-check is supporting evidence, never the authoritative gate. Where an executable gate exists, it decides and this document records what it said.
Detailed Description
| Criterion [FIT-n] | Probe | Evidence | Result | Limits of the claim |
|---|---|---|---|---|
| FIT-1: Dual Writer | Seed a pipeline where two concurrent streaming ingestion jobs attempt to append conflicting ACID commits to the same Delta table partition simultaneously. | Delta Lake optimistic concurrency control probe probe_concurrent_delta_commit_conflict verifying automatic conflict resolution with diagnostic ERR_DELTA_CONCURRENT_TRANSACTION_RETRIED. | pass | Confirms Delta transaction log commit protocols; does not evaluate direct manual file deletions via S3 raw CLI. |
| FIT-2: Undefined Grain | Seed a proposed Delta table definition that mixes customer transaction events with monthly aggregated account balances in the same table schema without a declared grain. | Table schema metadata linter probe_missing_lakehouse_grain verifying DDL rejection with diagnostic ERR_LAKEHOUSE_TABLE_LACKS_DECLARED_GRAIN. | pass | Confirms automated DDL catalog admission checks; does not evaluate temporary memory tables in Spark shells. |
| FIT-3: Silent Schema Drift | Seed an ingestion worker that attempts to write a batch containing an unannounced column data type change without activating Delta schema merge options. | Delta schema enforcement probe probe_unauthorized_schema_drift verifying ingestion rejection with diagnostic ERR_DELTA_SCHEMA_ENFORCEMENT_VIOLATION. | pass | Confirms Delta Lake driver-level schema enforcement; does not evaluate raw text files placed in landing buckets. |
Residual Risk
- Latency overhead (up to 15 seconds) when querying deeply historical time-travel snapshots older than 180 days due to cold metadata re-parsing. Accepted by Elena Rostova with dedicated audit query compute pools.
Traceability
| Claim | Classification | Source | Freshness |
|---|---|---|---|
| Rejection of uncoordinated concurrent commits | derived | FIT-1 probe result | 2026-09-15 |
| Rejection of tables lacking declared grain | derived | FIT-2 probe result | 2026-09-15 |
| Rejection of unauthorized schema drift | derived | FIT-3 probe result | 2026-09-15 |
Verification
No validator was supplied, so no command was run.
Open Decisions
None.
Next steps
- Architecture Guild incorporates lakehouse fitness probes into automated data engineering CI checks.
- Platform team configures CloudWatch alarms monitoring Delta Lake compaction job durations and S3 API throttles.
- Conduct quarterly regulatory audit simulations testing Point-in-Time Delta Time-Travel queries against historic transaction logs.
open-data-lakehouse-platform-and-acid-st.csv
CSV · data export
Example file from a real run - the skill writes it into your workspace.
Connects securely to your tools. The creator never sees your data.
What you get
About this skill
What it does
This skill owns the architecture of a governed table and snapshot layer over object-backed datasets when warehouse-like transactions, mutations, schema/partition evolution, time travel, maintenance, and multi-engine access are required. It integrates object identity, table metadata, catalog/commit authority, readers/writers, isolation, access, lifecycle, reliability, and evidence. It does not own generic data-lake layout, analytical warehouse semantics, one table-format implementation, ETL/CDC execution, or platform-wide self-service.
Use it when
- Object-backed datasets need stable table, branch/tag, snapshot, manifest and data/delete-file identity
- A catalog or equivalent coordinator must authorize create/load/commit/rename/drop and resolve current metadata
- Batch, streaming, correction, delete and maintenance writers may operate concurrently
- Append/overwrite/merge/update/delete semantics need atomic commit and conflict behavior
- Snapshot isolation, optimistic concurrency, retries and uncertain commits require explicit contracts
- Schema and partition evolution must preserve field identity and reader/writer compatibility
For example: “We adopted a table format for time travel. Queries have got slower every month, and legal asked whether a deleted customer can still be read from an old snapshot.”
What you get
- architecture/lakehouse-architect/README.md
- architecture/lakehouse-architect/00-overview/lakehouse-architect-overview.md
- architecture/lakehouse-architect/verification/fitness-self-check.md
Plus one page per business module, only where your evidence calls for it: {module}/ingest.md, {module}/storage.md, {module}/serving.md, {module}/lineage.md, {module}/retention.md, {module}/quality.md.
All paths are relative to the output folder you choose.
What it will not do
Do not use merely to organize object storage, choose Parquet/Delta/Iceberg/Hudi, create one table, run compaction, tune Spark/SQL, build ETL/CDC, configure a catalog, define warehouse models, or design a data platform.
How it works
- Check the subject is transactional tables over object storage.
- Establish which lakehouse guarantees you actually need.
- Fix the table format and who may write.
- Design the maintenance jobs as part of the architecture.
- State the time-travel and retention policy together.
- Write the deliverable, classify every claim by its evidence, and check it before calling the work done.
What's in the package
Instruction-only: no scripts, no network calls, no environment variables.
- LICENSE.txt
- SKILL.md
- agents/openai.yaml
- assets/output-template-artifact.md
- assets/output-template-contract.md
- assets/output-template-domain.md
- assets/output-template-fitness.md
- assets/output-template-mechanism.md
- references/domain-rules.md
- references/operating-rules.md
- references/output-contract.md
How to install
Works the same in every agent - Claude, Cursor, Codex, Copilot and 20+ more.
- 1
Download the ZIP
Free skills download straight away. Paid skills unlock right after purchase.
- 2
Unzip into your skills folder
Every agent reads skills from one folder on your machine. Drop the unzipped folder in there.
- 3
Ask your agent to use it
Restart the agent if it was already running. It picks the skill up automatically - no config needed.
Skills folder by agent
Click the path to copy it. Create the folder if it does not exist yet.
Reviews
No reviews yet
Be one of the first to try it. Every listed skill passes our trust checks below.
Security scanned
Passed our 8-point scan before listing
Fresh listing
Recently published to Agensi
30-day refund
Not a fit? Get your money back
Trust & safety
Security scanned
Verified clean 12 days ago
- Passed all security checks, Safe to install