Pulls events from the firehose and inserts them into our database