Member since
β05-29-2018
7
Posts
0
Kudos Received
1
Solution
My Accepted Solutions
Title | Views | Posted |
---|---|---|
5392 | β12-02-2020 12:26 AM |
β12-02-2020
12:26 AM
@stevenmatisonthe solution that i find is to get the Oauth2 token from slaesforec by using command Curl. like is explained in this page : https://www.jitendrazaa.com/blog/salesforce/using-curl-with-salesforce-rest-api/ So i create a ExecuteProces NiFi Procesor. And as parameter i put : the file C:/loginInfo.txt contains : grant_type=password& client_id= 3MVG9iTxZANhwsdsdsdsdspr0LstjR3sRat & client_secret=21961212323233121943 & username=jitendra.zaa@demo.com & password=myPWDAndSecurityToken and the i get a response with the authentication token π (you can use the cmd command Curl -x post -d @LoginInfo.txt Https://test.salesforce.com/.... to test the connection between the local machine and salesforce )
... View more
β12-01-2020
08:40 AM
Hi @stevenmatison , by using Curl command with my local machine , the authentication on salesforce is working and i get a token: And i already try the SOAP connection to Salesforce and it is working also. But with Oauth2.0 is not π So the problem is on NiFi InvokeHTTP Processor
... View more
β12-01-2020
06:59 AM
Thank you @stevenmatison for the quick answer. The connection between my local machine (where NiFi is installed and executed) and salesforce server is working well, because i already tried with postman and it is working. also, I increased the timeout as shown in the image below : and also activate the logging to debug level : But still have no output inthe Bulltin board of NiFi. I let it run for 2minutes and had this log lines from the app.log file : i an wondering if there a parameter to add for the InvokeHttp processor like "authorization:OAuth2" or other ? Thank you
... View more
β12-01-2020
02:20 AM
Hello everyone,
I am trying to authenticate with InvokeHttp NiFi Processor to Salesforce by using Bulk API v2 and with OAuth 2.0 :
The InvokeHttp Processor is configured as follow :
The Remote URL is made by using this syntax:
https://< mydomain >.salesforce.com/services/oauth2/token?grant_type=password&client_id=<client_id>&client_secret=<client_secret>&username=<username>&password=<password + key>
As we are using the HTTPS protocol, we add a βSSL Context Serviceβ by setting a new βSSL Context Controller Serviceβ:
And the Post request is already tested and worked with Postman tool, by responding with an authentication token.
The blocking point for this use case is that, with InvokeHTTP NIFI Processor we have not been able to get a response from the Bulk API ( the first image show that we never receive any response from Salesforce )
If you have any suggestion, it's will be helpful.
Thank you in advance
KSAD
... View more
Labels:
- Labels:
-
Apache MiNiFi
-
Apache NiFi
-
NiFi Registry
β07-12-2018
01:24 PM
Thank you @Sandeep Nemuri, it's helped me. i found an other explanation which details the probem : https://community.hortonworks.com/questions/178176/hive-creation-of-temp-tables-in-default-database-d.html " The problem seems to be around the default temporary
table (at least, it is failing here before anything else). The query you
make with the "VALUES" part work like this : - it creates a temporary hive table with the line to be inserted - it then queries that temporary table for inserting the data into the target table From the output I see, the temporary table is created [default/values__tmp__table__3]. But the user does not have "select" permission on it.
I guess that a workaround would be to grant "SELECT" on the
database "default" but this could bring some security issues for you
(since the user will have read permission on all the tables inside
"default"). "
... View more
β07-05-2018
08:10 AM
Hello @Sandeep Nemuri If i understood corectly it is a problem about user access rights to the database. I will contact the administrator of nifi. I will try that , thank you π
... View more
β07-04-2018
04:11 PM
hello everyone,
I created a data flow with NIFI, in which I put: SelectHiveQL ===> ConvertAvroToJSON ====> SplitJson ====> EvaluateJsonPath ===> ReplaceText ===> PutHiveQL.
All the processors work well except the last "PutHiveQL" which shows me the following error.
thank you in advance for your help
... View more
Labels:
- Labels:
-
Apache NiFi