apache-nifi

0熱度

1回答

我是新來的apache NIFI。我有點想知道保存按鈕在哪裏。我從YouTube上看到的教程中嘗試了一個示例。我想保存我創建的所有處理器以供將來參考。我沒有看到任何保存按鈕。以後可以保存我的作品嗎？或者在另一臺機器上打開。？請幫忙。

0熱度

1回答

在我的項目，我使用Nifi閱讀從Tomcat日誌文件，並在火花的應用處理這些數據，之後，在DB插入的過程數據。但我的問題是，在應用服務器層面，我有2個不同的盒子4 Tomcat集羣（4個不同的日誌文件），我有標示出哪些數據是從哪個集羣的火花水平。在目前的設置我在Nifi 2 tailFile處理器，其指向單個外港，在每盒但不能夠識別哪些數據是從哪個羣集在火花水平。是否有tailFile處理器的

0熱度

1回答

NIFI：使用RouteOnContent來過濾響應？

我想使用routeonContent並根據它們組成的方法名稱將我的響應放在deifferenct目錄中，我具有屬性'$ message.body'並使用expression（in routeonContent）${message.body:contains('<person>')}。但它對我不起作用你有什麼更好的想法我該怎麼做？如果你想航線基於屬性值

1熱度

2回答

我應該使用哪個JSONPath表達式來拆分我的JSON字符串？

我想以下面的JSON文件拆分成2個FlowFiles申請SplitJson（根據hits）： {"took":0,"timed_out":false,"_shards": {"total":5,"successful":5,"failed":0}, "hits":{"total":2,"max_score":0.0, "hits": [

0熱度

1回答

提取值

我已經逃脫JSON數據流（即從ConvertAvroToJSON處理器驅動器）這樣的： {"data": "{\"created_at\":\"Sun Sep 24 11:10:52 +0000 2017\"}"} 和我只需要「JSON」值，這樣[unescapeJson後] ： {"created_at":"Sun Sep 24 11:10:52 +0000 2017"} 我想JoltT

0熱度

1回答

分享Nifi控制器服務

如何在過程組之間共享控制器服務。我建立了一個DBCPConnectionPool並在一個進程組中使用它。我需要在另一個進程組中。或者簡而言之，我希望在根目錄下有一個DBCPConnectionPool，並在進程組中使用它。

0熱度

2回答

在Java中使用Rest API上傳apache NiFi中的模板

我正在嘗試創建一個REST API調用，以將模板導入到我的NiFi UI後，其實例化相同。下面是從我試圖從 <?xml version="1.0" ?> <template encoding-version="1.1"> <description></description> <groupId>bd5dba8b-015d-1000-1fd5-450ede38b7a5</gr

0熱度

1回答

NIFI站點到站點通信

我有2臺機器：安裝第一機nifi和站點到站點屬性： # Site to Site properties nifi.remote.input.host= nifi.remote.input.secure=false nifi.remote.input.socket.port=8055 第二機器運行火花碼，連接到如下nifi。我可以在第二種情況下訪問網絡nifi。 val conf =

0熱度

1回答

顛簸參考第一元件

我一直在尋找在這幾個星期（在背景中）和難倒關於如何JSON數據近似CSV轉換成使用NiFi JoltTransformJson處理器加標籤的集合。我的意思是將輸入中數組的第一行的數據用作輸出中的JSON對象名稱。作爲一個例子，我有這樣的輸入數據： [ [ "Company", "Retail Cost", "Percentage" ],

0熱度

1回答

文件未發現異常

我想flowfile其中是XML組件和更新tagvalue之一，我做這裏面的自定義nifi處理器的代碼，我有這樣的代碼： flowFile = session.putAttribute(flowFile,"filename",file.getName() + ".xml"); InputSource inputSource = new InputSource((InputStrea