Implement filebeat with ingest pipelies

You might also want to look at this...

Probably the way I would do this to ingest into a logs data stream then add the pipeline