我編寫(xiě)了一個(gè) nifi 自定義處理器來(lái)處理 xlsx 到 csv ,在我的代碼中,我從 xlsx 生成一個(gè)像這樣的字符串 csv ,但我不知道如何將其作為 csv 發(fā)送,而其他處理器(例如來(lái)自 csv 的 inferavroschema )可以識(shí)別輸入流為 csv。final AtomicReference<String> value = new AtomicReference<>();String csvToString= "name,age,infojavo,23,wasapepe,34,lima"value.set(csvToString);在我的代碼中,我以這種方式發(fā)送它,但是當(dāng)我看到數(shù)據(jù)來(lái)源時(shí),它顯示為內(nèi)容類(lèi)型文本: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貢獻(xiàn)1798條經(jīng)驗(yàn) 獲得超3個(gè)贊
nifi 中內(nèi)容類(lèi)型的屬性名稱(chēng)命名為mime.type
因此,您必須將其值設(shè)置為csv
。
flowFile = session.putAttribute(flowFile, "mime.type" "csv");
添加回答
舉報(bào)
0/150
提交
取消