Sources and ingestion
Collect data from databases, APIs, events or files according to availability, volume and delay tolerance. Use batch, incremental or change data capture (CDC) when viable. Record origins, extraction time, checkpoints and failures for safe recovery.

