Data integration pipeline