Hello,   how do I properly use the nifi-api to create flowfile from a file? I tried to do what is described here: https://nifi.apache.org/docs/nifi-docs/rest-api/index.html under 'Data transfer'   I've tried to use a simple curl command to transfer a file as flowfile to an input port as follows: curl -X POST -F 'file=@Documents/Nifi_Docs/example.txt' http://10.0.1.111:8080/nifi-api/data-transfer/input-ports/dac743ae-0189-1000-c6a6-efd211a162d1/transactions/1010/flow-files   As response I get a 415 error Unsupported Media Type. What is the supported media type then? Anyone tried this before? What is the transaction id good for? I just put 1010 as a random number.   I also tried sending from postman ... View more

Hi, I am trying ro read from a json file and create flowfiles with the kews as attributes and one flowfile per value in the list.   The json file looks something like this: { "key1": null, "key2": null, "list": ["foo", "bar"], "key3": 1 }   This is my execute script:     import json import java.io from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.apache.nifi.processor.io import StreamCallback from org.apache.nifi.processor.io import InputStreamCallback flowFile = session.get() if (flowFile != None): stream_content = session.read(flowFile) text_content = IOUtils.toString(stream_content, StandardCharsets.UTF_8) json_data = json.loads(text_content) for i in json_data["list"]: flowFile2 = session.create() flowFile2 = session.putAttribute(flowFile2, "key3", str(json_data["key3"])) flowFile2 = session.putAttribute(flowFile2, "key1", json_data["key1"]) flowFile2 = session.putAttribute(flowFile2, "list_value", i) session.transfer(flowFile2, REL_SUCCESS) session.remove(flowFile)     Now I keep getting an error that I need to close the process session first because my original flowfile is still in use. How can I iterate over the list to create multiple flowfiles properly? I couldn't find any similar case or example of this sort. Thanks for tips and help.   Edit: So I changed my code to create a dictionnary in order to use a new variable name for each flowfile created, but now I keep getting a key error when I want to transfer them to the success relationship.   import json import java.io from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.apache.nifi.processor.io import StreamCallback from org.apache.nifi.processor.io import InputStreamCallback flowFile = session.get() if (flowFile != None): stream_content = session.read(flowFile) text_content = IOUtils.toString(stream_content, StandardCharsets.UTF_8) json_data = json.loads(text_content) d = {} for x in range(len(json_data["list"])): d["flowfile{0}".format(x)] = json_data['list'][x] for file in d: file = session.create() file = session.putAttribute(file, "key3", str(json_data["key3"])) file = session.putAttribute(file, "key2", json_data["key2"]) file = session.putAttribute(file, "list_value", d[file]) session.transfer(file, REL_SUCCESS) session.remove(flowFile)   ... View more

Hello friends,   I wrote a custom processor and now wanted to add a custom controller. The problem is, that the properties I wrote for the controller do not appear when I create the service. I followed the structure of this controller: https://github.com/Automna/NiFi/blob/master/nifi-rel-nifi-1.1.2/nifi-nar-bundles/nifi-standard-services/nifi-dbcp-service-bundle/nifi-dbcp-service/src/main/java/org/apache/nifi/dbcp/DBCPConnectionPool.java     Here is what I did so far: public class MyNewControllerService extends AbstractControllerService implements MyControllerService { public static final PropertyDescriptor USERNAME = new PropertyDescriptor.Builder() .name("Username") .expressionLanguageSupported(ExpressionLanguageScope.NONE) .displayName("Set username") .required(true) .defaultValue("User") .description("Username to login to graph service") .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); public static final PropertyDescriptor PASSWORD = new PropertyDescriptor.Builder(). name("Password") .expressionLanguageSupported(ExpressionLanguageScope.NONE) .displayName("Set password") .required(true) .defaultValue("password") .description("Password to login to graph service") .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); public static final PropertyDescriptor URL = new PropertyDescriptor.Builder(). name("ApiUrl") .expressionLanguageSupported(ExpressionLanguageScope.NONE) .displayName("Set url") .required(true) .defaultValue("url") .description("Full url to api") .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); private static final List<PropertyDescriptor> properties; static { final List<PropertyDescriptor> props = new ArrayList<>(); props.add(USERNAME); props.add(PASSWORD); props.add(URL); properties = Collections.unmodifiableList(props); } OkHttpClient client = new OkHttpClient(); private static ObjectMapper mapper = new ObjectMapper(); @Override protected List<PropertyDescriptor> getSupportedPropertyDescriptors() { return properties; } @OnEnabled public void onConfigured(final ConfigurationContext context) throws InitializationException { final String user = context.getProperty(USERNAME).getValue(); final String password = context.getProperty(PASSWORD).getValue(); final String url = context.getProperty(URL).getValue(); What is missing that I only get a blank properties page? ... View more