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

I am trying to make a conenction to my Sql Server using "zxJDBC". Below is my code in ExecuteScript processor: from com.ziclix.python.sql import zxJDBC d, u, p, v = "jdbc:sqlserver://<servername>;Database=<databasename>;encrypt=true;trustServerCertificate=true;user=<username>;password=<password>;integratedSecurity=true", None, None, " com.microsoft.sqlserver.jdbc.SQLServerDriver" db = zxJDBC.connect(d, u, p, v) c = db.cursor() However, I am getting an error " zxjdbc.database error driver com.microsoft.sqlserver.jdbc.SQLServerDriver not found"  My limted research in internet found out that it is dependent on some jar files how how can we add jar files classpath in nifi processors.  Please guide in making this Sql server connection successful. Thanks.  ... View more