I am trying to access a .py file present in one of the docker container and I am using execute stream command processor for it. However, I am receiving "Permission Denied" error on the .py file.  Even though, the file has all the rights given but still facing this issue. Any feedback will be appreciate. Thanks.      ... View more

Hi all. I have two avro-binary types of flow files and their content is: Flow file one: [ { "DepartmentID" : "Undefined", "Name" : "Non Billable", } ]   Flow file two:[ { "DepartmentID" : "Null", "Name" : "Tax", } ] I am using UpdateRecord processor to add a key:value (tenantId) in the same file for which I am using below avro schema: { "name": "nifi", "type": "record", "fields": [ { "name": "TenantId", "type": ["null","string"] }, { "name": "DepartmentId", "type": ["null","string"] }, { "name": "Name", "type": ["null","string"] } ] } I am using literal value replacement value strategy and getting TenantId from previous processors. So far, this is a success and tenantId is appended. However, as a result, the DepartmentId changes to null for BOTH the files. Where I can ensure that the DepartmentId's values are not changed because based on these values, I have to route the "undefined" file for further processing.  Any help would be appreciated. Thanks.  ... View more

Hi, I have a python code which is trying to authenticates to my NIFI server and start a processor inside it. Please see code below: from flask import Flask import nipyapi import requests   app = Flask(__name__) @app.route('/') def home():     nifi_url = "https://mynifiinstance:port/nifi-api/access"     processor_id = <processorID>     nifi_general = "https://mynifiinstance/nifi-api"     start_processor_url = f"{nifi_general}/processors/{processor_id}/run-status"       headers = {'Content-Type': 'application/x-www-form-urlencoded'}     username = "username"     password = "password"     data = { "username": username,             "password": password         }         response = requests.post(url=nifi_url, data=data,verify=False, headers=headers)       if response.status_code == 200:         # if successfully authenticated, then start the processor         start_processor = requests.put(url=start_processor_url, headers=headers)         print(start_processor.status_code)         if start_processor.status_code == 200:             return("Processor started successfully.")         else:             return(f"Starting processor failed. Status code: {start_processor.status_code}")     else:         return(f"Failed to start processor. Status code: {response.status_code}")     if __name__ == '__main__':     app.run()   However, I am unable to authenticate with the given username and password. Note: that I have not made any changes in the nifi.properties file. Does it have to be changed? Looking fwd to your responses. ... View more