ETRM Data Engineering & Analytics
One place to learn the entire data engineering and analytics stack behind a modern ETRM platform. Twelve sequenced courses and 240 chapters take you from the core data model to a fully automated, straight-through pipeline, and an end-to-end capstone project in which you build a working ETRM data platform yourself.
The whole ETRM data platform, taught as one journey
Most training teaches the pieces of an ETRM data platform in isolation: a course on data modeling here, a course on streaming there, with no thread connecting them. Real platforms are not built that way. A position number depends on the trade model, the reference data, the curves, and the P&L logic all being right and all fitting together, and a straight-through pipeline depends on every one of those pieces being wired into a single flow. This portal is built around that reality: twelve courses that deliberately build on each other, in sequence, toward one working system.
You begin with the foundations, the canonical data model and the governed reference data every calculation trusts. You move through how a trade is represented and lives its lifecycle, including the FpML standard the industry uses to exchange trades. You build the valuation inputs, curves and market data, and turn trades and curves into positions, P&L with attribution, and the credit and limit controls that keep a desk safe. You then learn the platform that holds it all, a governed lakehouse, an event-sourced core, and add the real-time and analytics layers, streaming risk and live dashboards. Finally, you assemble everything into Straight-Through Processing, the capstone course where the platform becomes one automated flow from trade capture to settlement.
The result is not a collection of certificates but a capability. By the end you can build, and have built, the data engineering behind a modern trading platform, and you have an end-to-end project to prove it.
Twelve courses, in the order they build
Each course is a standalone 20-chapter program and a step in a deliberate sequence. Straight-Through Processing comes last because it assembles everything before it.
Data Modeling for ETRM Systems
The relational and dimensional foundations: entities, keys, normalization, and the canonical trade model every ETRM system rests on.
Open course →Reference & Master Data Management
The golden source of instruments, counterparties, calendars, and hierarchies that every downstream calculation trusts.
Open course →Trade Lifecycle & Instrument Modeling
How a deal moves from capture to settlement as data: events, states, amendments, and the instrument structures behind each trade.
Open course →FpML & Trade Representation
The industry XML standard for representing derivatives, and how to parse, validate, and map it into your own model.
Open course →Market Data, Curves & Time-Series
Forward curves, volatility surfaces, and the time-series engineering that feeds every valuation and risk number.
Open course →Position & P&L Data Models
Turning trades and curves into positions, exposures, and profit and loss, with attribution that reconciles to the cent.
Open course →Counterparty, Credit & Limit Modeling
Modeling credit exposure, collateral, and the limit framework that stops a desk before it breaks.
Open course →Data Lake, Warehouse & Lakehouse
The platform architecture beneath ETRM analytics: lake, warehouse, and lakehouse patterns, and when each is right.
Open course →Event Sourcing & Audit Trail Design
Recording every change as an immutable event, so state can be rebuilt, audited, and replayed with confidence.
Open course →Streaming & Real-Time Risk
Processing trades and market data in motion to drive live position, exposure, and alerting.
Open course →Real-Time Dashboards & Analytics
Turning position, P&L, and exposure data into live, trustworthy views that traders and risk actually use.
Open course →Straight-Through Processing (Capstone)
The capstone: wiring every prior module into one automated, controlled, exception-managed flow from trade capture to settlement.
Open course →From a trade to a settled, reconciled number
To see why the sequence is what it is, follow a single trade through the platform the bundle teaches you to build. A trade is captured and immediately enriched with governed reference data, the counterparty, the instrument, the calendar, so that it means the same thing everywhere. If it arrived as an FpML message, it is validated and mapped into the canonical model. Its lifecycle begins: it is confirmed, perhaps amended, and every change is recorded as an immutable event, so the full history is always reconstructable.
To value the trade, the platform strikes it against curves built from market data and stored bitemporally, so the valuation is reproducible as of any moment. The valued trade rolls up into a position, and the change in that position's mark-to-market becomes P&L, decomposed by attribution into price, time, and new-trade effects that reconcile exactly to the blotter. Before the trade was ever accepted, a credit and limit check ran against the counterparty's exposure; after it, the same checks monitor for breaches as the market moves.
All of this lands on a governed lakehouse, bronze to silver to gold, and is driven in real time by streaming, so live positions and limit alerts reach a dashboard within seconds. And the whole flow, capture, enrich, represent, value, position, control, settle, is wired together as straight-through processing, automated end to end, with exceptions peeling off to a repair queue and reconciliation at every handoff. The animations below show the pieces that make this work.
The data model above is the core the whole platform rests on: trades referencing instruments, counterparties, and books, generating cash flows, valued against curves. Every downstream number is a query over this structure, which is why the bundle starts here.
Straight-through processing, above, is the flow the bundle builds toward: a trade moving automatically from capture to settlement, with exceptions handled and every handoff reconciled. It is the capstone course precisely because it connects everything else.
Lakehouse, event sourcing, and streaming
Beneath the flow sits an architecture the bundle teaches in detail. Data lands and is refined through a medallion lakehouse: bronze for raw feeds exactly as they arrive, silver for conformed canonical data, gold for the business-ready marts that positions, P&L, and dashboards consume, with catalog, lineage, quality, and access control governing every layer.
Underneath the state sits an event-sourced core. Rather than overwriting rows, every change is recorded as an immutable event in an append-only log, and current state, positions, P&L, the audit view, is a projection derived by replaying those events. This is what gives the platform a perfect audit trail and the ability to reconstruct any state as of any past moment, which regulated trading demands.
And to make the desk's view live rather than end-of-day, trade and market-data streams are joined in a stateful streaming layer that maintains live positions and fires limit and risk alerts within seconds, with exactly-once guarantees so nothing is double-counted. These three, lakehouse, event sourcing, and streaming, are the architectural spine the whole bundle assembles.
The data engineering patterns that hold it together
The bundle is opinionated about a small set of engineering patterns that recur across every course, because they are what make a trading data platform trustworthy rather than merely functional. The first is a single canonical data model. Trades reference instruments, counterparties, and books through stable surrogate keys and generate cash flows, and every downstream calculation, position, P&L, exposure, is a query over that structure rather than a bespoke integration. When twelve modules agree on one model, they compose; when they each invent their own, every seam becomes a reconciliation break.
The second pattern is bitemporality. Reference data, curves, and trade state all change over time, and the platform must distinguish when something was true in the world from when the system learned it. Every important fact carries both a valid-time axis and a transaction-time axis, so the platform can answer both what is true now and what we believed last Tuesday. This is what makes revaluation reproducible and audit possible, and it appears in the modeling, reference-data, curves, and event-sourcing courses alike.
The third is event orientation. Rather than overwriting rows, the platform records changes as immutable events in an append-only log and derives current state as a projection. This gives a perfect audit trail, point-in-time reconstruction, and safe reprocessing, and it is the backbone the streaming and straight-through-processing courses build on. Closely related is idempotency: because events may be replayed after a failure, every operation is designed so that applying it twice has the same effect as applying it once, which is what lets the capstone reprocess a trade without double-settling it.
The fourth is the medallion lakehouse. Raw feeds land in a bronze layer exactly as they arrive, are conformed into canonical models in a silver layer, and are served as business-ready marts in a gold layer, with schema enforcement quarantining bad data and open table formats bringing transactions and time travel to cheap storage. Governance, catalog, lineage, quality, and access control, spans every layer. The fifth is reconciliation as a first-class output: at every handoff, and between every fast incremental view and its slow authoritative recomputation, the platform checks that the numbers agree and raises a break the moment they do not. Together these five patterns are the difference between a demo and a platform, and the bundle teaches each one not as theory but as something you build.
The data-engineering problems that are specific to trading
Generic data engineering skills transfer only partway into ETRM, because trading imposes constraints that ordinary analytics pipelines never face, and the bundle is built around exactly those constraints. The first is reproducibility under scrutiny. A retail-analytics dashboard that is approximately right is fine; a P&L number that cannot be reproduced exactly, as of the moment it was struck, is a control failure and potentially a regulatory one. This is why bitemporality runs through the whole program: the platform must always be able to answer not just what a number is, but what it was, and what inputs produced it, at any past moment.
The second is that the data is adversarially temporal. Trades are amended and corrected, sometimes with backdated effect; reference data changes and those changes have effective dates that may precede the moment they were entered; market data is revised after the fact. A naive pipeline that overwrites as it goes destroys the history these corrections depend on and produces numbers that cannot be explained. The event-oriented, append-only patterns the bundle teaches exist precisely because trading data refuses to sit still, and because the questions asked of it, who changed this, when, and what did we believe then, demand that nothing is ever silently overwritten.
The third is that latency and correctness are both non-negotiable and in tension. A desk needs its risk live, within seconds of a trade or a market move, but it also needs those live numbers to agree with the official books struck in batch. Meeting one requirement by sacrificing the other is a failure either way, which is why the streaming course spends so long on event time, watermarks, exactly-once processing, and reconciliation against batch truth. The fourth is that the cost of a wrong number is asymmetric and large. A mispriced curve, a double-counted trade, a stale limit, any of these can drive a real trading loss or a breach, so validation gates, reconciliation, and integrity checks are not quality-of-life features but core requirements, present in every course rather than bolted on at the end.
These four properties, reproducibility, adversarial temporality, live-yet-consistent, and asymmetric cost of error, are what separate ETRM data engineering from the general discipline, and they are the reason a dedicated program exists. The bundle does not teach generic pipelines and hope they transfer; it teaches the patterns that these specific constraints force, using the actual entities, calculations, and controls of a trading platform.
What "the canonical model" actually looks like
It is easy to talk about a canonical data model in the abstract, so it is worth being concrete about what the bundle has you build. The core is a small set of related tables where the constraints, not the comments, are what keep the data honest. A trade carries a surrogate key and a business reference, points at exactly one instrument, counterparty, and book, and cannot exist if any of those do not, because referential integrity forbids it. Quantities and prices use explicit precision, because rounding error in a trading system is a real financial risk. A cash flow can never outlive its trade. These are not stylistic choices; they are how invalid states are made unrepresentable.
CREATE TABLE trade (
trade_id bigint PRIMARY KEY, -- surrogate key
external_ref text NOT NULL UNIQUE, -- business identifier
instrument_id bigint NOT NULL REFERENCES instrument(instrument_id),
counterparty_id bigint NOT NULL REFERENCES counterparty(counterparty_id),
book_id bigint NOT NULL REFERENCES book(book_id),
trade_date date NOT NULL,
quantity numeric(20,6) NOT NULL, -- precision matters
price numeric(20,8) NOT NULL,
buy_sell char(1) NOT NULL CHECK (buy_sell IN ('B','S'))
);
-- Position is derived, never stored: a query over trades.
CREATE VIEW position AS
SELECT book_id, instrument_id,
SUM(CASE WHEN buy_sell='B' THEN quantity ELSE -quantity END) AS net_qty
FROM trade
GROUP BY book_id, instrument_id;From this seed, everything grows. Reference data attaches to the instrument and counterparty entities and is served through a validated golden source. The lifecycle course turns the trade into a stream of immutable events, so the row above becomes a projection of its own history. Curves, stored bitemporally, feed the revaluation that turns positions into P&L. The lakehouse lands this same model in its silver layer; the streaming course maintains that position view live; and the straight-through-processing capstone flows real trades through all of it. Each course adds a layer, but they all speak this one model, which is exactly why they compose into a working platform instead of a pile of disconnected parts. The child pages go down to this level of detail for every course, with the data models and code you can read and learn from directly.
The twelve courses at a glance
Each course is a full 20-chapter program with its own data models, code, diagrams, and project. Here is the thread that runs through them.
1. Data Modeling for ETRM Systems. The relational and dimensional foundations, entities, keys, normalization, temporal and bitemporal modeling, and the canonical trade model every later course extends, delivered as runnable schema.
2. Reference and Master Data Management. The governed golden source of instruments, counterparties, calendars, and hierarchies, with survivorship, versioning, and a validation gate that keeps bad static data out of trading.
3. Trade Lifecycle and Instrument Modeling. The trade as an ordered sequence of immutable events over an enforced state machine, from capture through amendment, novation, and termination, with a fully queryable history.
4. FpML and Trade Representation. Parsing, validating, and mapping the industry XML standard for derivatives into the canonical model, with a reversible round-trip and a resilient ingestion pipeline.
5. Market Data, Curves and Time-Series. Bootstrapping forward curves, modeling volatility and seasonality, and storing everything bitemporally so every valuation is reproducible point-in-time.
6. Position and P&L Data Models. Aggregating trades into positions, revaluing against curves, and producing P&L with attribution that decomposes every daily move and reconciles to the blotter.
7. Counterparty, Credit and Limit Modeling. Modeling exposure and collateral and building a real-time limit framework that enforces pre-deal and post-deal checks with audited breaches and overrides.
8. Data Lake, Warehouse and Lakehouse. The platform architecture beneath it all, the medallion lakehouse, open table formats, partitioning and performance, and the governance that keeps it from becoming a swamp.
9. Event Sourcing and Audit Trail Design. Recording every change as an immutable event, building projections and snapshots, and reconstructing any state as of any past moment for perfect auditability.
10. Streaming and Real-Time Risk. Processing trades and market data in motion, event-time windowing and late data, and maintaining live positions and alerts with exactly-once guarantees.
11. Real-Time Dashboards and Analytics. The serving layer, semantic models, and live push that turn the data into trustworthy sub-second views, with drill-down, alerting, and reconciliation to the books.
12. Straight-Through Processing (Capstone). Wiring all eleven prior modules into one automated, controlled, exception-managed flow from capture to settlement, the synthesis of the entire program.
The Capstone: a working ETRM data platform, end to end
The bundle culminates in a single end-to-end project that is, in effect, a thirteenth module built on top of the twelve. You assemble everything, the data model, reference data, trade lifecycle, FpML ingestion, curves, position and P&L, credit and limits, the lakehouse, event sourcing, streaming, and dashboards, into one working ETRM data platform, and then run it as a straight-through pipeline from trade capture to settlement.
Model & reference
Stand up the core schema and a governed reference-data service (courses 1-2).
Capture & represent
Ingest FpML trades into the lifecycle model with full history (courses 3-4).
Value
Build curves and revalue positions into a reconciling P&L mart (courses 5-6).
Control
Enforce credit and limit checks over the exposures (course 7).
Platform
Land it all on a medallion lakehouse with an event-sourced core (courses 8-9).
Real-time
Drive live positions and alerts, and surface them on a dashboard (courses 10-11).
Automate
Wire the whole thing into one straight-through flow with exception handling (course 12).
What the capstone produces
- A runnable data platform repository with schema, pipelines, and services
- An end-to-end STP run from trade capture to settlement on sample data
- A reconciliation and exception report proving straight-through integrity
- An architecture and data-model portfolio piece you can show an employer
A portfolio piece, not a certificate
The capstone is, in effect, a thirteenth module built on top of the twelve. It is the difference between having watched twelve courses and having built a working ETRM data platform you can show an employer or apply at work. Each course's own project is a rehearsal; the capstone is the performance.
Every module justified by a project
Learning sticks when it is applied. Every one of the twelve courses ends with a project that puts that module to work, so you finish each course with something built, and the bundle with a complete platform.
Design a normalized ETRM core schema (trades, instruments, counterparties, books) with keys, constraints, and a dimensional mart on top, delivered as runnable DDL and an ER diagram.
Build a reference-data service with a golden-record model, survivorship rules, versioned history, and a validation gate that rejects bad static data before it reaches trading.
Model the full trade lifecycle as an explicit state machine with event transitions, then implement capture, amend, novate, and terminate against your core schema with a queryable history.
Parse real-shaped FpML trade messages, validate against schema, and map them into your canonical trade model with a reversible round-trip and a validation report.
Build a curve-construction pipeline: ingest quotes, bootstrap a forward curve, store it bitemporally, and expose point-in-time curve retrieval for revaluation.
Compute positions from the trade store, revalue against curves, and produce a P&L attribution mart that decomposes daily change and reconciles to the trade blotter.
Build a limit-checking service: model exposures and limits, compute utilization in real time, and enforce pre-deal and post-deal limit checks with breach alerts.
Design a medallion lakehouse for ETRM: bronze ingestion, silver conformed models, and gold marts, with schema enforcement and a governance layer.
Implement an event-sourced trade store: append-only events, projections for read models, and a full audit trail that can rebuild any state as of any time.
Build a streaming pipeline that maintains live positions and fires limit and risk alerts within seconds of a trade or market move, with exactly-once guarantees.
Build a live position and exposure dashboard backed by a serving layer, with drill-down, alerting, and sub-second refresh that reconciles to the P&L mart.
Assemble the full STP pipeline end to end, integrating all eleven prior modules into one automated flow from capture through settlement, with exception handling, reconciliation, and observability.
Everything you need, in every format
The full bundle is self-paced with lifetime access. Each course comes with written handbooks, presentation decks, video explainers, and hands-on labs and a project, so you can read, watch, and build in whatever way fits you.
Self-paced
Work through all 12 courses and 240 chapters at your own pace, with lifetime access to updates.
PDF handbooks
A written handbook per course, with the data models, code, and diagrams to keep as reference.
Slide decks
Presentation decks for every course, ready for self-study or to teach a team.
Video explainers
Concise videos that walk through the harder concepts and architectures visually.
Labs & projects
Hands-on labs and a graded project per course, plus the end-to-end capstone project.
Read it, see it, build it
Every course follows the same rhythm, so that once you find your footing in the first one, the rest feel familiar. Each opens with the problem it solves and why it sits where it does in the sequence, then works through its twenty chapters in order, each chapter building on the last. The concepts are explained in prose you can actually learn from, not bullet-point summaries, and the harder ideas are shown as animated diagrams, a data model, a pipeline, a flow, so you can see the shape of the thing before you build it. Crucially, each course goes down to the code and data-model level: real schema, real parsing and mapping logic, real streaming topologies, so the page itself teaches rather than just pointing at a lab.
Then you build. Every course carries a project scoped to put that module to work, design the schema, stand up the reference service, model the lifecycle, ingest the FpML, construct the curve, compute the P&L, enforce the limits, and so on, so you finish each course with something concrete rather than a passive sense of having watched it. The written handbook, slide deck, and video explainers give you the same material in the format that suits how you learn, and the labs give you a place to apply it. Because the bundle is self-paced with lifetime access, you can move as fast or as carefully as you need, and return to any course as a reference later.
The twelve projects are deliberately cumulative: the schema you design in the first course is the schema the later courses extend, the events you model in the lifecycle course are the events the streaming course consumes, and so on. By the time you reach the capstone, you are not starting from scratch, you are assembling work you have already done into one end-to-end platform. That cumulative design is what makes the final capstone achievable rather than overwhelming, and what makes the whole bundle feel like building one system rather than taking twelve separate courses.
Bring the whole platform to your team
The bundle is built for teams standing up or modernizing an ETRM data capability. Delivered as private corporate training, it is mapped to your stack, your data, and your use cases, with optional on-prem or cloud labs, so your engineers learn on the platform they actually work on. A whole team can move through the sequence together and build the capstone against your own architecture.
Mapped to your stack
Tailored to your databases, streaming platform, lakehouse, and ETRM systems, so the learning transfers directly.
Team cohorts
Move a whole team through the 12-course sequence together, with shared projects and a common vocabulary.
Capstone on your data
Build the end-to-end capstone against your own architecture, turning the training into a real internal asset.
Concrete capabilities, not just topics covered
The point of the bundle is what you can do at the end of it, so it is worth being specific. You will be able to design a normalized ETRM core schema and the dimensional marts on top of it, and defend every key, constraint, and temporal choice. You will be able to stand up a governed reference-data service with survivorship and a validation gate, and explain why bad static data is the root of most trading incidents and how yours stops it. You will be able to model a trade's full lifecycle as events over an enforced state machine, and reconstruct any trade's state as of any past date.
You will be able to ingest real-shaped FpML, validate it, and map it losslessly into your model. You will be able to build a bitemporal curve service and prove that a past revaluation reproduces exactly against the as-of curve. You will be able to compute positions and a P&L that decomposes into price, time, and new-trade effects and reconciles to the blotter, and to build a real-time limit-checking service that blocks a breaching trade before it is done. You will be able to design a medallion lakehouse with schema enforcement and governance, implement an event-sourced core with projections and snapshots, and run a streaming pipeline that maintains live positions and alerts with exactly-once guarantees.
And you will be able to put a trustworthy live dashboard on top of all of it, and then, in the capstone, wire the whole thing into a straight-through pipeline from capture to settlement with exception handling and reconciliation at every step. That last capability is the one that matters most, because it is the one that proves the rest fit together. It is the difference between knowing the pieces and being able to build the platform.
Built for people who want to build the platform
This bundle is for data engineers, analytics engineers, quantitative developers, ETRM implementers, and trading-technology teams who want to build the data platform behind commodity and energy trading, not merely operate one. It suits an individual engineer assembling a serious portfolio, a specialist moving from generic data engineering into the trading domain, and a whole team standing up or modernizing an ETRM data capability together. No deep trading background is assumed; the courses build the domain context as they go, though comfort with SQL and a programming language will let you get the most from the labs and code.
The recommended way through is the order the courses are numbered, because each one leans on the ones before it. The foundations, modeling and reference data, come first because everything references them. Representation and lifecycle come next, then valuation and the numbers that flow from it, then the platform and real-time layers, and finally the straight-through-processing capstone that only makes sense once the rest exists. That said, an experienced engineer can treat any single course as a standalone 20-chapter program on its subject, dipping in for the specific depth they need, because each course is complete in itself even as it fits the whole.
However you approach it, the destination is the same: a complete, defensible command of ETRM data engineering across all 240 chapters, twelve applied projects, and one end-to-end capstone that stands as a working platform you built yourself. That is what the sequence is designed to deliver, and why it is worth doing in order.
Frequently asked questions
What is the ETRM Data Engineering and Analytics bundle?
A one-stop learning portal of 12 sequenced courses and 240 chapters that build, end to end, the data engineering and analytics capability behind a modern ETRM platform, from the core data model through reference data, the trade lifecycle, FpML, curves, position and P&L, credit and limits, the lakehouse, event sourcing, streaming, dashboards, and finally straight-through processing.
How is it sequenced?
The courses build on each other in order. You start with data modeling and reference data, move through the trade lifecycle and representation, then valuation, position, P&L, and risk, then the platform, real-time, and analytics layers, and finish with Straight-Through Processing, the capstone that assembles everything into one automated flow.
Why is Straight-Through Processing last?
STP wires every prior module into a single automated pipeline from capture to settlement. You cannot build it until you have built the model, the reference data, the lifecycle, valuation, position and P&L, credit and limits, the platform, event sourcing, streaming, and dashboards that it connects. It is deliberately the final, integrative course.
How many chapters are there in total?
240: twelve courses of exactly twenty sequential chapters each, numbered 1 to 240 across the bundle.
Is there a project?
Yes, thirteen in effect. Each of the twelve courses has its own applied project, and the bundle culminates in an end-to-end capstone project, a real thirteenth module, in which you assemble all twelve into one working ETRM data platform and run it as a straight-through pipeline.
What formats is the bundle available in?
Fully self-paced with lifetime access: PDF handbooks, slide decks, video explainers, and hands-on labs and a graded project per course, plus the end-to-end capstone. It is also available as guided cohorts and as private corporate training.
Who is it for?
Data engineers, analytics engineers, ETRM implementers, quantitative developers, and trading-technology teams who want to build, not just use, the data platform behind commodity and energy trading. It suits both individuals building a portfolio and teams standing up a capability.
Can we run it as corporate training?
Yes. The whole bundle, or any subset of courses, can be delivered privately, mapped to your stack, your data, and your use cases, with optional on-prem or cloud labs. Use the contact form to scope a corporate engagement.
Do I need prior ETRM experience?
No deep trading background is required, though basic SQL and programming familiarity helps. The bundle builds trading-domain context as it goes and focuses on the data engineering and analytics craft.
What will I have at the end?
A complete, defensible understanding of ETRM data engineering across all 240 chapters, twelve applied projects, and one end-to-end capstone, a working ETRM data platform, that stands as a portfolio piece.
Build the data platform behind trading
Subscribe to the full 12-course bundle and finish with a working ETRM data platform of your own.