我的python脚本中的代码：if flowFile is not None:2017-07-16 08:17:34,417 ERROR [Timer-Driven Process Thread-9]: AttributeError: 'java.sql.Tim
浏览 7提问于2017-07-16得票数 0
我已经生成了带有date属性的flowfile，然后我想对我的date进行一些更改：import org.apache.commons.io.IOUtilsimport org.apache.nifi.processor.io.StreamCallback
def date=flowfile.getAttributeflowfile = session.putAttribute(
浏览 6提问于2017-08-10得票数 3
回答已采纳
我在获得executeScript nifi进程的javascript脚本时遇到了问题，希望能在这方面提供帮助。目标是传递一个包含json对象的流文件。尝试测试脚本，得到以下错误： 7da1d74d109b]ExecuteScript[id=bd6842e9-e3a4-4d88-a59d-7
浏览 0提问于2018-08-13得票数 1
回答已采纳
在ProcessorLog处理器中使用ExecuteScript的最佳方法是什么？如果在处理过程中遇到错误，我计划在groovy ExecuteScript中添加一些日志记录。但是，添加日志的尝试没有成功。可能忽略了一些明显的东西。;
if(!-6] o.a.nifi.processors.script.ExecuteScript
org.apache.<e
浏览 0提问于2016-04-08得票数 0
回答已采纳
如何在NiFi ValidateRecord processor / JsonRecordSetWriter中将时间戳序列化为Json字段。在我的NiFi流中，我有一个ValidateRecord处理器，它使用CSVReader进行读取，使用JsonRecordSetWriter作为编写器。当有像2016-10-08 07:51:00.000这样的字段值的记录通过时，我在NiFi日志中得到一个异常：
2018-10-18 17:05:59,1
浏览 143提问于2018-10-19得票数 1
回答已采纳
Nifi 1.5.0我正在尝试在ExecuteScript处理器中执行这个Python脚本：from org.apache.commons.io import IOUtilsfrom java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallbackroot, encoding='utf8', method=&#
浏览 4提问于2020-05-22得票数 0
我有我的ExecuteScript处理器，如果文件最初是utf-16的话，我会尝试转换到utf-8的任何文件。迄今为止：if not flowFileList.isEmpty():如果这是个愚蠢的问题，请随便说。谢谢
NiFi ExecuteSc
浏览 0提问于2018-12-10得票数 0
回答已采纳
为什么有些NiFi处理器不允许动态属性？我在我的一个工作流中使用了FetchFile processor，我需要在整个流程中传递一些数据，以便能够在最后一步中使用它。但是，FetchFile通过不允许使用动态属性打破了这一点。我想知道有没有别的办法？为什么NiFi不允许在某些处理器上使用动态属性？我的流程是这样的
ExecuteScript -> EvaluateJSon -
浏览 3提问于2016-07-17得票数 2
回答已采纳
我有一个传入的json数据，我使用ExecuteScript和Python代码来提取这个json数据的键和值，然后将它们放入属性中。org.apache.commons.io import IOUtilsfrom org.apache.nifi.processor.io), 'content': str(content)})
session.transfer(viewFlowF
浏览 2提问于2017-10-18得票数 0
回答已采纳
1回答
我在一个容器中运行NiFi。如何最好地在这个容器中安装python模块？我需要安装熊猫。我登录到容器并使用pip安装了pandas。但奇怪的是，这只安装了熊猫和numpy。并且它还没有安装任何其他依赖项！ 当我运行ExecuteScript processor时，我得到了错误，它会抱怨缺少依赖项。 为什么它的表现如此不同！
浏览 15提问于2020-04-25得票数 0
回答已采纳
1回答
在CPython中，我将使用datetime：today=datetime.date.today() print "weekend" print "weekday"
但是，由于我使用的是NiFi，所以我不得不使用Jython。如果我在NiFi中尝试上面的代码，就会得到以下<e
浏览 0提问于2018-12-10得票数 2
1回答
我正在尝试使用NiFi查询API，这些参数来自数据库，因此我需要使用属性作为URL的一部分。import jsonfrom urllib import urlopenfrom java.nio.charset import StandardCharsets
from org
浏览 15提问于2022-01-11得票数 0
Processors I'm referring to 处理器"InvokeHTTP“是否可能从前一个处理器(在本例中为SELECT_FROM_SNOWFLAKE)获取信息"id”？Where i want to change 我希望“远程URL”是这样的： http://${hostname()}:8080/nifi-api/processors/${previousProcessorId
浏览 40提问于2019-12-17得票数 1
回答已采纳
我是NiFi的新手。我正在尝试使用ExecuteScript处理器执行Python脚本。当我尝试一个没有导入命令的简单脚本时，它运行良好，并在nifi.StdOut中显示了输出。它显示了以下错误：
我尝试在属性中提供模块目录中pkgs的路径。但它不锻炼。任何帮助都将不胜感激！
浏览 2提问于2019-04-11得票数 3
回答已采纳
我对使用NiFi相当陌生。我们试图验证一个xmlfile，但我们需要使用不同的xsd，这取决于文件中传递的一些值。对名称进行提取和路由不是问题，我们将所需的文件路径存储在一个属性(xsdFile)中。
但是，当试图在XMLValidation处理器中使用该属性时，它会更改路径并给出一个错误。当我从属性复制路径并将其复制到模式时，它可以工作，因此路径本身没有错。属性在流文件中
浏览 0提问于2019-09-03得票数 1
回答已采纳
我想将我的Nifi管道(主要是PUTSQL-处理器)从我的开发实例转移到我的Apache Nifi的生产实例中，最好是使用Python来实现可重用性。
代
浏览 1提问于2021-03-24得票数 0
回答已采纳
因此使用了ExecuteScript并试图导入某些模块。我是这样进口的：虽然我安装了sftp，但是当我在Executescript中导入它时，它说“未能处理会话。没有一个模块名为sftp在第1行”。/usr/bin/sftp
在进口paramiko的时候，也得到了同样的错误。
浏览 6提问于2016-11-21得票数 11
回答已采纳
我在nifi处理器(executeScript处理器)中有代码逻辑，这将减少日志文件(在我的日志文件中，我有相同的文本，因此我想删除重复的，并尝试按名称和文件大小来选择它们)，但有时(并不总是)出现负索引错误，，我应该在代码中更改什么来使它工作？import org.apache.nifi.processor.FlowFileFilter;import groovy.js
浏览 3提问于2017-12-29得票数 1
我可以通过GET请求在/nifi-api/processors/proc_id上成功地检索处理器的当前状态。当我试图将一个新的状态写回Nifi时，在PUT on /processors/{id}/run-status上发生了问题-我收到了以下错误：
b'Node [....] is unable to fulfill(尽管说它是一个可选属性)，但是处理器没有客户机ID。pro
浏览 4提问于2021-04-21得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
智聆口语评测
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号