SFTP Egress Connector

In this use case scenario, requirement is to poll the files from a local directory and send all the JSON files in the local directory to a SFTP server. For statistics and monitoring purposes it’s required to extract out the client ID’s from the input file and create a log specifying the extracted client ID value and sending file name name should be prefixed by the extracted client ID value.

In order to implement above use case you must first select the SFTP Connector and Local File Connector dependencies from the connector list when you are creating an empty Ultra project. If you have already created a project, you can add these dependencies via Component Registry. From Tools menu, select Ultra Studio → Component Registry and from the Connectors list and Processors list, select above dependencies

To implement above use case, first let’s create our integration flow named “integrate-to-send-via-sftp” and first add the File Listener IngressConnector and configure input file receiving path and file name patterns to fetch input JSON files from the local directory.

Next processing element should be the JSON Path Extractor to extract out the Client ID from the received JSON message. JSON path of the client id should be configured as the JSON path parameter of this processing element. This processing element will extract out the parameter from the JSON message and save it as a variable with the name given in it’s Variable Name parameter.

After that, Logger processing element should be added to log the input file name and the respective client ID based on the value stored in the variable by the JSON path extractor.

Finally SFTP EgressConnector element should be added to the integration flow to send the file to the SFTP server as per the requirement use case. SFTP EgressConnector can be configured by filling the Basic properties as below,

After filling out the required parameters, this configuration can be saved by clicking the Save button at the bottom of each element.

With all above elements, complete integration flow would be like this,

File Name parameter is configured with "@{message.var.CLIENT_ID}_@{message.header.ultra.file.name}" to modify the file name by attaching the client ID as the suffix for the original file name. Framework will replaced the "@{message.var.CLIENT_ID}" from the value of the variable with name CLIENT_ID and "@{message.header.ultra.file.name}" will be replaced by the value of the transport header with name "ultra.file.name" which is the original file name received via File IngressConnector.

Now if you run the flow, and put an JSON file to with name ends with "_Adroitlogic.json", to the configured local folder that file should be send to the configured SFTP server and file name should be prefixed with the Client ID of the input message