WxStreamSets
WxStreamSets is a webMethods Integration Server package designed to simplify the integration with StreamSets.
Pre-requisites
- webMethods Integration Server
- StreamSets
Features
- Ready to use flow-services to call StreamSets APIs.
- Start StreamSets Job synchronously.
Installation
- Download the latest release of WxStreamSets.zip from Releases section.
- Copy WxStreamSets.zip to /${SAG_HOME}/IntegrationServer/instances/${INSTANCE}/replicate/inbound directory.
- Login to Integration Server Admin Console http://${HOST_NAME}:${PORT}.
- Go to Packages > Management in the left side menu and click Install Inbound Releases.
- Choose WxStreamSets.zip from dropdown and click Install.
Generate StreamSets API Credentials
- Login to StreamSets Control Hub.
- Expand Manage option in the left-hand side naviagtion and choose API Credentials.
- Click on Add button.
- Provide the Name for credentials and click Save & Generate.
- Copy the Credential ID and Token.
Usage
Following APIs in terms of flow-services are supported:
- wx.streamsets.v1.jobRunner.services.startJobById - To start a specific job.
- wx.streamsets.v1.jobRunner.services.getJobCurrentStatusById - To get the status of a specific job.
- wx.streamsets.v1.jobRunner.services.stopJobById - To…