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

我编写了一个处理xlsx到csv的nifi定制处理器,并在我的代码中从xlsx生成了一个像这样的字符串csv,但是我不知道如何将其作为csv发送,而其他处理器(如inferavroschema)  来自csv的用户可以将输入流识别为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);
yl987987 回答:如何在apache nifi writer中设置内容类型csv?

nifi中内容类型的属性名称为mime.type

因此,您必须将其值设置为csv

flowFile = session.putAttribute(flowFile,"mime.type" "csv");
本文链接:https://www.f2er.com/3169611.html

大家都在问