Member since
02-01-2022
285
Posts
103
Kudos Received
60
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 1181 | 05-15-2025 05:45 AM | |
| 5120 | 06-12-2024 06:43 AM | |
| 8116 | 04-12-2024 06:05 AM | |
| 5995 | 12-07-2023 04:50 AM | |
| 3298 | 12-05-2023 06:22 AM |
02-09-2023
05:34 AM
@Techie123 You are going to need to provide credentials for the nifi calls against any s3 bucket with access controls. I would recommend working in lower nifi dev environments and use a public S3 buckets to get comfortable. This will test basics of your flow without access issues. This will also remove confusion around nifi flow functionality vs AWS access issues and help you learn when/where to use the different ways (key, or a controler service w/ credentials) to provide access from nifi to s3.
... View more
02-07-2023
05:02 AM
@Abdulrahmants if you need to talk to someone about getting those added, please reach out in direct message. Another approach could be to create an API input endpoint on nifi (handleHttpRequest/handleHttpResponse), and make a scripted (python,java,etc) process to send the file to the nifi endpoint.
... View more
02-06-2023
07:25 AM
1 Kudo
I believe this is a job for MiNiFi https://nifi.apache.org/minifi/index.html Basically, you create a small minifi flow to run on the server/network with privelaged access, and this flow will send its results to NiFi.
... View more
02-02-2023
06:40 AM
@samrathal Per the docs you need to provide the ID: Request consumes: */* Name Location Type Description id path string The connection id. flowfile-uuid path string The flowfile uuid. clusterNodeId query string The id of the node where the content exists if clustered. You should be getting that ID from the previous get call (Gets a FlowFile from a Connection) within the response is an object: FlowFileEntity Inside is the "clusterNodeId" corresponding to which node that flowfile exists on. { "flowFile": { "uri": "value", "uuid": "value", "filename": "value", "position": 0, "size": 0, "queuedDuration": 0, "lineageDuration": 0, "penaltyExpiresIn": 0, "clusterNodeId": "value", "clusterNodeAddress": "value", "attributes": { "name": "value" }, "contentClaimSection": "value", "contentClaimContainer": "value", "contentClaimIdentifier": "value", "contentClaimOffset": 0, "contentClaimFileSize": "value", "contentClaimFileSizeBytes": 0, "penalized": true } } Those details are exposed in the nifi api doc, just be sure to click into the entity.
... View more
01-23-2023
06:52 AM
@phaelax ExecuteScript ExecuteProcess ExecuteStreamCommand etc are some of the hardest configs in nifi. It is very hard to give guidance without exact templates, configs, scripts, etc. That said, i would recommend ExecuteScript and python over bash. If that is interesting to. you, you should spend some time consuming the 3 part series on ExecuteScript by @MattWho . I believe the first part explains how to get flowfile attributes (filename) or flowfile content from previous processor flowfile (getFile) into the script. https://community.hortonworks.com/articles/75032/executescript-cookbook-part-1.html https://community.hortonworks.com/articles/75545/executescript-cookbook-part-2.html https://community.hortonworks.com/articles/77739/executescript-cookbook-part-3.html
... View more
01-23-2023
06:22 AM
Very good article, this will definitely help me in the future!
... View more
12-21-2022
05:55 AM
@zIfo based on what i see, you need to completely fill out the keystore and truststore using cacerts. Make sure nifi user has permissions to read file. If your https end point is not a public cert it will not work with cacerts, you will need to make your own keystore and truststore which contains your specific certs. Here is a post with more details: https://community.cloudera.com/t5/Support-Questions/Configure-StandardSSLContextService-for-Elasticsearch/td-p/302719 And another one that goes into much greater detail: https://community.cloudera.com/t5/Support-Questions/RESOLVED-NIFI-LISTENHTTP-SSL/td-p/146985
... View more
12-16-2022
05:19 AM
The hive libraries are quite large and are not included in the base binary distribution. You can add them manually, or use github to clone and build the full project. Reference: https://github.com/apache/nifi/blob/rel/nifi-1.19.0/nifi-assembly/pom.xml#L1054
... View more
12-16-2022
04:43 AM
Ahh my confusion, it is hard to assume without a lot more detail. Reference: https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html#gt ${fileSize:gt( 1024 )} You need to use the expression "gt( some value )" against a parameter or variable. In the case above, "file size greater than 1024".
... View more
12-15-2022
06:31 AM
@wallacei There are roles attached to the main control plane and roles attached to specific environment. Work with you environmentAdmin to make sure you have all the correct roles at the control plane level and then deeper at the environment level if necessary. Below is the EnvironmentAdmin [
{
"crn": "crn:altus:iam:us-west-1:altus:policy:EnvironmentAdminPolicy",
"policyStatements": [
{
"rights": [
"environments/getFreeipaOperationStatus",
"environments/repairFreeIPA",
"environments/upgradeFreeIPA",
"environments/createDatahub",
"datahub/read",
"datahub/write",
"datalake/read",
"datalake/write",
"environments/read",
"environments/write"
],
"resources": [
"*"
]
}
]
}
] You may need more specific roles to access additional services around the environment.
... View more