Monday, 12 November 2018

Beginner's Guide to Ultra Pipelines in Snaplogic


Ultra pipelines are those pipelines which can continuously consume documents from external sources. This is similar to a web service exposed on any platform that can continuously access messages and process them



A typical Ultra Pipelines deployment architecture would look like as in the below diagram

1. Application2. Load Balancer3. Feed Master4. Execution node

Example Pipeline


Here I am demonstrating a simple pipeline that accept that is exposed as a REST POST service that is continuously accepting documents from a consumer application and invoking a REST service at the back end.

Lets look at the expressions in AccessRequestData snap to access data sent in the request




Accessing data for records sent as POST - $content.<field Name>




Accessing data for records sent as GET - $query.queryParam[0]   (Because query params are represented as an array in the request)




This is enough for the ulttra pipeline to work. Now, navigate to the Manager and click on create Task. 



Once you create the ultra task, Snaplogic will provide a URL which is the endpoint for your Ultra task. Use postman or any other tool to verify your service