我编写了一个 nifi 自定义处理器来处理 xlsx 到 csv ,在我的代码中,我从 xlsx 生成一个像这样的字符串 csv ,但我不知道如何将其作为 csv 发送,而其他处理器(例如来自 csv 的 inferavroschema )可以识别输入流为 csv。final AtomicReference<String> value = new AtomicReference<>();String csvToString= "name,age,infojavo,23,wasapepe,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);
1 回答
呼如林
TA贡献1798条经验 获得超3个赞
nifi 中内容类型的属性名称命名为mime.type
因此,您必须将其值设置为csv
。
flowFile = session.putAttribute(flowFile, "mime.type" "csv");
添加回答
举报
0/150
提交
取消