ocel-etl

ETL engine for OCEL 2.0 process mining, built on the ocel crate.

Connectors extract source data into a StagingLog — a loose working representation that tolerates out-of-order ingestion, dangling references, and growing schemas — and convert it into a validated ocel::Ocel through the single into_ocel() gate.

use ocel_etl::{StagingEvent, StagingLog};

let mut staging = StagingLog::new();
// events may arrive before the objects they reference (pagination order)
staging.add_event(StagingEvent { /* ... */ });
staging.upsert_object("task-1", "task");

let log = staging.into_ocel()?;       // the validation gate
ocel::io::sqlite::write_path(&log, "out.sqlite")?;

License

MIT