Tool for Creating and Deploying Configurable Enrichment Pipelines

A non-transitory computer-readable medium having instructions stored thereon that are executable to cause a computing system to:

• receive, from a data source, a stream of messages;
• input each of at least a plurality of the messages in the stream into an enrichment pipeline comprising at least a first enricher and a second enricher, wherein (1) the first enricher is configured to receive a message, produce a first enrichment for the message, append the first enrichment to the message, and output a first updated version of the message containing at least the first enrichment, and (2) the second enricher is configured to receive the first updated version of the message containing at least the first enrichment, produce a second enrichment for the message, append the second enrichment to the message, and output a second updated version of the message containing at least the first and second enrichment;
• as a result of inputting the stream of messages into the enrichment pipeline, produce an enriched stream of messages in which each of at least a plurality of the messages in the enriched stream includes a respective first and second enrichment;
• and
• output the enriched stream of messages to a data sink.

A computer-implemented method, the method comprising:

• receiving, from a data source, a stream of messages;
• inputting each of at least a plurality of the messages in the stream into an enrichment pipeline comprising at least a first enricher and a second enricher, wherein (1) the first enricher is configured to receive a message, produce a first enrichment for the message, append the first enrichment to the message, and output a first updated version of the message containing at least the first enrichment, and (2) the second enricher is configured to receive the first updated version of the message containing at least the first enrichment, produce a second enrichment for the message, append the second enrichment to the message, and output a second updated version of the message containing at least the first and second enrichment;
• as a result of inputting the stream of messages into the enrichment pipeline, producing an enriched stream of messages in which each of at least a plurality of the messages in the enriched stream includes a respective first and second enrichment;
• and
• outputting the enriched stream of messages to a data sink.