为了账号安全,请及时绑定邮箱和手机立即绑定

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

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

子衿沉夜 2024-01-28 16:12:36
我编写了一个 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");


查看完整回答
反对 回复 2024-01-28
  • 1 回答
  • 0 关注
  • 84 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信