如何在apache nifi writer中设置内容类型csv？

Question

我编写了一个 nifi 自定义处理器来处理 xlsx 到 csv ，在我的代码中，我从 xlsx 生成一个像这样的字符串 csv ，但我不知道如何将其作为 csv 发送，而其他处理器（例如来自 csv 的 inferavroschema ）可以识别输入流为 csv。

final AtomicReference<String> value = new AtomicReference<>();

String csvToString= "

name,age,info

javo,23,wasa

pepe,34,lima"

value.set(csvToString);

在我的代码中，我以这种方式发送它，但是当我看到数据来源时，它显示为内容类型文本：

String results = value.get();

       if(results != null && !results.isEmpty()){

           flowFile = session.putAttribute(flowFile, "csv", results);

       }

       flowFile = session.write(flowFile, new OutputStreamCallback() {

           @Override

           public void process(OutputStream out) throws IOException {

               out.write(value.get().getBytes());

           }

       });

       session.transfer(flowFile, SUCCESS);

Answer 1

nifi 中内容类型的属性名称命名为mime.type因此，您必须将其值设置为csv。flowFile&nbsp;=&nbsp;session.putAttribute(flowFile,&nbsp;"mime.type"&nbsp;"csv");