Watch a directory for logs and send each line to a Fusion pipeline as a PipelineDocument using grok for parsing. - View it on GitHub