CODEWITHSUNDEEP
apache-nifi
Debasish
Debasish

Reputation: 1

Is there an in built processor in Apache NiFi which can create a Password enabled SSH connection?

I have an HDInsight Cluster setup on Azure Cloud. Also have installed Apache NiFi on a separate VM. Please Note I have SCP & SSH access enabled from VM to my cluster. I am trying to setup some processors as per my requirement, first one in the list is an "ExecuteProcess" processor. What I am trying to achieve through that is to establish an SSH connection with my HDInsight Cluster and once that's successful pass that result (connection established = 'Y') through a FlowFile to my second processor which is a "GetFile" processor that will basically read a JSON file from a particular path in that HDInsight cluster.

I have added "ExecuteProcess" processor and in the Configure option -> Properties section, have set the below:

Command : ssh [email protected] command arguments: [email protected] Batch Duration : No Value Set Redirect Error System : True Working Directory : No Value Set Argument Delimiter : No Value Set

Command : ssh [email protected] command arguments: [email protected] Batch Duration : No Value Set Redirect Error System : True Working Directory : No Value Set Argument Delimiter : No Value Set

Please Note [email protected] is the server hostname for my HDInsight Cluster to which I am trying to establish connectivity from my VM (Server DNS Name : dep-hadoop.eastus.cloudapp.azure.com)

I am trying to setup some processors as per my requirement, first one in the list is an "ExecuteProcess" processor. What I am trying to achieve through that is to establish an SSH connection with my HDInsight Cluster and once that's successful pass that result (connection established = 'Y') through a FlowFile to my second processor which is a "GetFile" processor that will basically read a JSON file from a particular path in that HDInsight cluster.

Upvotes: 0

Views: 1323

Answers (1)

Óscar Andreu
Óscar Andreu

Reputation: 1700

I am afraid that this doesn't work this way, you are not going to be able to pass an ssh connection as a flow file, nut you can try a workaround: in the execute processor, instead of make only an ssh connection, copy also the file to a local folder, then you can use the GetFile processor.

Upvotes: 0

Related Questions