data model: split ingestion policy script (tag parsing) form ingestion operation (writing to data stream)