Open Data Lakehouse Platform and ACID Storage Architect

    1

    Architects data lakehouses: open Delta Lake storage, ACID transactions, time-travel auditing, and unified BI/ML queries.

    $9

    Secure checkout via Stripe

    30-day refund guarantee

    Converts to your local currency at checkout

    Security scanned

    Works with the AI tools you already use

    Claude CodeClaude CodeCursorCursorCodex CLICodex CLIMuseMuseOpenClawOpenClaw+21 more

    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

    CriterionWhy it matters hereWeightSource 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.40Elena Rostova (Head of Financial Crime Intelligence)
    ACID Transactional Integrity & Time-TravelRegulators mandate point-in-time auditing of customer risk scores at exact trade time.0.30David O'Reilly (Chief Data Platform Architect)
    BI & ML Unified Engine ConcurrencySingle storage layer must serve 400 SQL analysts and 45 ML researchers concurrently.0.15Corporate 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.15Corporate FinOps Steering Committee

    Comparison

    Data Architecture StrategyETL Synchronization LagStorage RedundancyPoint-in-Time Audit SafetyEvaluation
    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 HourHigh 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.
    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.
    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

    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

    ClaimClassificationSourceFreshness
    18 petabytes across 32 regional banking partnersprovidedEnterprise data estate intakeCurrent
    Incident LKH-4919 $8.4M AML penalty and 14h lagprovidedRegulatory enforcement consent decreeHistorical
    Sub-5-second executive BI query latency targetprovidedExecutive Business Intelligence SLACurrent
    Open Lakehouse with Delta Lake selecteddecidedDavid O'Reilly & Elena Rostova2026-09-15
    Mandatory ACID open table format invariantdecidedArchitectural invariant INV-LKH-022026-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

    1. Platform Engineering deploys the AWS Glue catalog and centralized Delta Lake storage buckets.
    2. Analytics team configures the Trino vectorized query engine with auto-scaling Kubernetes worker pods.
    3. 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]ProbeEvidenceResultLimits of the claim
    FIT-1: Dual WriterSeed 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.passConfirms Delta transaction log commit protocols; does not evaluate direct manual file deletions via S3 raw CLI.
    FIT-2: Undefined GrainSeed 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.passConfirms automated DDL catalog admission checks; does not evaluate temporary memory tables in Spark shells.
    FIT-3: Silent Schema DriftSeed 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.passConfirms 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

    ClaimClassificationSourceFreshness
    Rejection of uncoordinated concurrent commitsderivedFIT-1 probe result2026-09-15
    Rejection of tables lacking declared grainderivedFIT-2 probe result2026-09-15
    Rejection of unauthorized schema driftderivedFIT-3 probe result2026-09-15

    Verification

    No validator was supplied, so no command was run.

    Open Decisions

    None.

    Next steps

    1. Architecture Guild incorporates lakehouse fitness probes into automated data engineering CI checks.
    2. Platform team configures CloudWatch alarms monitoring Delta Lake compaction job durations and S3 API throttles.
    3. 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

    Generated

    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

    Design transactional table layers for Delta Lake and IcebergDefine retention policies for time travel and legal erasureEstablish concurrency and conflict resolution for multi-engine writesPlan maintenance jobs for compaction and snapshot expiryArchitect schema and partition evolution for object-backed tables

    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

    1. Check the subject is transactional tables over object storage.
    2. Establish which lakehouse guarantees you actually need.
    3. Fix the table format and who may write.
    4. Design the maintenance jobs as part of the architecture.
    5. State the time-travel and retention policy together.
    6. 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.

    ~30 seconds
    1. 1

      Download the ZIP

      Free skills download straight away. Paid skills unlock right after purchase.

    2. 2

      Unzip into your skills folder

      Every agent reads skills from one folder on your machine. Drop the unzipped folder in there.

    3. 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

    Listed12 days ago

    What's inside

    Frequently Asked Questions