我編寫了一個 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
提交
取消