I'd suggest using a service like Segment or MetaRouter.io to collect the event data, then use Airflow to prep it.