apache-nifi

0熱度

1回答

如何在Apache NiFi中添加自定義屬性，並在不中斷的情況下快速讀取它們nifi

就像我在custom-properties文件中添加了一些屬性。現在我想讀取這些自定義屬性，而不需要停止Apache NiFi。內容custom.properties sourcepath=/home/ist/s destination=/home/ist/d 我想不上下NiFi讀取這些屬性執行像GET，PUT動作。

0熱度

1回答

如何在啓動NiFi之前以編程方式指定NiFi屬性

我們正在多個容器上啓動NiFi，並且我們正在使用腳本來爲我們完成此操作。每個設備都有一個單獨的IP地址，它需要成爲nifi.remote.input.host的一部分。除了在nifi.properties文件中輸入它之外，是否沒有其他方式指定此屬性？有一個腳本，我將運行將產生多個容器。這些容器運行一個啓動腳本，然後啓動NiFi。如果有上述方法來更改屬性，那麼所有啓動腳本需要執行的操作是從ifco

0熱度

1回答

將屬性寫入Apache NiFi中的文件

嗨，我正在使用GetSNMP處理器來連接無線電。根據NiFi文檔，這些信息被寫入流文件屬性而不是流文件內容。所以，我使用了AttributesToJSON處理器。之後，我使用PutFile處理器將這些屬性寫入文件。生成文件，但沒有寫入屬性。每個文件中只寫入「{}」。使用LogAttribute處理器，我可以看到日誌文件中的所有屬性，但我希望它們在單獨的文件中。請指導。感謝，

-2熱度

1回答

Apache Nifi中的「CaptureChangeMySQL」處理器是否連接到Oracle數據庫

我想在Apache Nifi中使用CaptureChangeMySQL處理器在Apache NiFi中設置CDC（更改數據捕獲）模板，並且出現以下錯誤： CaptureChangeMySQL：無法處理會話由於org.apache.nifi.processor.exception.ProcessException：無法二進制日誌客戶端連接到任何指定的主機的原因是：BinaryLogClient無法

0熱度

1回答

如何Nifi ExecuteScript返回屬性沒有前綴「u」代碼python？

我有一個JSON數據傳入和我用ExecuteScript與的Python代碼提取該JSON數據的鍵和值，然後把它們放進屬性。在這裏我的代碼： import json import java.io from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.a

1熱度

2回答

如何在不停止的情況下更新apache nifi處理器的配置？

早上好，我使用的是Apache Nifi，不知有沒有人知道有什麼方法可以改變處理器的設置而不必停下來。或者一些可行的替代方法來防止信息的丟失。所述處理器運行時由於

0熱度

1回答

Nifi：無法識別groovy xmlSlurper結構

[輸入圖像說明] [1]我有nifi 1.3.0。是否有可能在nifi中實現的groovy版本無法識別lambda表達式？這裏是我的代碼，我該如何改變它才能在nifi處理器中工作？是否有可能處理器不能正常工作，因爲我不使用session.tranfer我的意思是不產生任何flowfile？ def static addDays(def date) { SimpleDateFormat

1熱度

1回答

Nifi在注入數據時崩潰

我使用ListenHTTP作爲Nifi進程的輸入點。 import requests import csv import pandas as pd import json import time url = 'http://localhost:8085/contentListener' df = pd.read_csv('demo_dataset.csv') for i in

0熱度

1回答

Nifi：nifi中的線程

我想知道線程在nifi中的工作方式我的意思是一個處理器有一個線程或者它們在一個主線程中？也許是我想從處理器獲得一個文件，然後我想更新我怎麼能防止幾個處理器獲取文件數據，以一定的時間除了使用保留文件=假動作？是否有可能在內部使用Thread.sleep執行腳本處理器代碼？ Groovy有可能製作相同的邏輯嗎？我試圖用Java文件鎖，但它似乎沒有工作好，這裏是我的代碼， File file

0熱度

1回答

Nifi：將屬性處理器路由到錯誤的處理器

我正在測試NIFI中的流程，該流程使用REST API檢查計數器的特定值。我能夠從REST響應中提取正確的值。但是，當我檢查「屬性處理器上的路由」中的條件時，預期匹配條件的結果將路由到不匹配的處理器。附件爲： Flow和configuration 我已經檢查了我的迴應是「1」。但它的路由到不匹配的分支。我使用的NIFI表達式語言有什麼問題嗎？