如何将验证错误信息从Nifi的ValidateResult处理器获取到属性中
在Nifi中，ValidateResult处理器用于验证流程中的数据，并根据验证结果将错误信息发送到属性中。下面是将验证错误信息从Nifi的ValidateResult处理器获取到属性中的步骤：
- 将ValidateResult处理器添加到Nifi流程中。
- 在ValidateResult处理器的属性配置中，设置合适的验证规则和属性名称。例如，可以选择验证规则为"表达式语言"，将错误信息保存到名为"error.message"的属性中。
- 连接ValidateResult处理器的输入和输出连接器，确保数据流能够流经处理器。
- 在流程中的其他处理器中，可以通过使用UpdateAttribute处理器来访问ValidateResult处理器中的属性，从而获取验证错误信息。
- 添加一个UpdateAttribute处理器到流程中，配置属性名称为"error.message"，将其值设置为"${error.message}"。
- 在UpdateAttribute处理器的输出连接器中，可以将错误信息传递给其他处理器进行后续处理，或者将其记录到日志中等。
推荐的腾讯云相关产品：Nifi是一个开源的数据流处理工具，并不是腾讯云的产品，因此在腾讯云上没有专门与之对应的产品。但腾讯云提供了其他数据流处理和云计算相关的产品，如云原生容器服务 TKE（https://cloud.tencent.com/product/tke）、云函数 SCF（https://cloud.tencent.com/product/scf）、云数据库 CDB（https://cloud.tencent.com/product/cdb）等，这些产品可以帮助开发者进行数据流处理、云计算等方面的工作。
希望以上信息能对您有所帮助。
相关·内容
我正在尝试通过Avroschemaregistry验证一个使用ValidateRecord处理器的json。我需要将验证错误消息存储到sql表中，所以我尝试捕获属性中的错误消息，但无法捕获属性中的错误消息，您知道该如何做吗
浏览 45提问于2020-10-12得票数 0
我想编写nifi处理器，它可以从hdfs目录中读取xml文件，然后将其数据提取到流文件属性中，如果有两个nifi处理器可以获取该文件并读取数据或写入其中的情况，那么如何实现文件锁定，以便一次只有一个处理器可以使用它你能给我提供任何可以帮助我的文章、代码示例或相关资料吗？我还没有写任何自定义处理器。
浏览 5提问于2017-09-30得票数 1
2回答
我有JSON对象通过MQTT从两个不同的输入进入Nifi --例如，假设一个来自顶部传感器，另一个来自底层传感器。每个传感器都有自己的MQTT主题，因此我使用两个不同的ConsumeMQTT处理器将这些数据摄取到我的Nifi流中。处理器将Top_Data或Bottom_Data的值存储在一个名为sensorData的属性中。我如
浏览 3提问于2019-03-08得票数 0
回答已采纳
我有一个RedPanda消息队列，NIFI从该队列中提取JSON数据。然后，使用JOLTTransform将JSON数据简化为我想要的字段。 "foo": "bar",}
我希望使用像ParseSyslog或ExtractGrok这样的处理器来解析消息字段的内容到目前
浏览 11提问于2022-11-18得票数 0
回答已采纳
是否可以使用NiFi进行两步API调用？我希望如何进行第一个调用( POST)以检索身份验证令牌，第二个调用将使用该令牌来执行GET并检索所请求的数据？我知道我可以使用InvokeHTTP处理器来进行GET或POST调用，如下所示，但是正在努力解决如何将第一个调用的输出用作第二个调用的属性的问题。我的想法是让evaluateJSON处理器从第一个调用中提取令牌，但是如何将<
浏览 138提问于2021-04-16得票数 0
回答已采纳
这是必要的，因为我的脚本是用来消耗前一个处理器的输出的。此外，我喜欢将数据保存在"NiFi管理“之下的想法。
如何
浏览 0提问于2018-03-24得票数 12
回答已采纳
我想在nifi中添加3个分机(nifi加密md5-na-1.0-unpacked，nifi-getOperator-nar-1.0-SNAPSHOT.nar-unpacked，nifi-splitAttributeValue-nar-1.0.nar-unpacked) )
我在目录/opt/nifi/nifi-1.9.2/work/nar/ extensions /中添加了扩展文件夹
浏览 5提问于2021-07-21得票数 0
回答已采纳
1回答
我想制造新的处理器，这将是GetFile和EvaluateXpath的重聚，我感兴趣的有几个主题：
我如何缩小我的纳尔文件，因为它已经超过20‘t，而我的nifi不能运行它？我想从文件夹中获取文件，读取它的数据，并将它作为一个属性放在新的流文件中，然后将config xml回滚到它原来的文件夹中，我如何将我的</em
浏览 5提问于2017-10-02得票数 0
没有多少是免费的。在自由选择中，他们似乎对ArangoDB没有任何了解或支持。如果有人已经处理过将其数据迁移到ArangoDB并自动完成此过程的问题，我很想知道您是如何做到这一点的。下面我列出了几种ETL工具的选择。这些选择实际上是我从2016年星火欧洲演讲中得到的。Open Studio* Microsoft SSIS* CloverETL* Pen
浏览 0提问于2018-03-22得票数 1
回答已采纳
我正在绘制一个NiFi管道，用于将文件从远程文件系统转移到上的存储桶中。目标是根据文件的名称将文件移动到特定文件夹(如果不存在文件就自动创建)。输入路径(例如桶名/subdir)作为处理器的“桶”属性返回错误。提前感谢
浏览 2提问于2020-07-17得票数 1
回答已采纳
1回答
我正试图在Nifi上创建一个基本的流程。
虽然很简单。但是，当我试图读取python上的数据时，我面临着一些问题。import sysfile.to_csv(sys.stdout,index=False)
浏览 1提问于2020-10-13得票数 0
我是通过Apache临时使用OkHttp的。我试图确定在重定向时如何处理授权和其他敏感标头。NiFi的InvokeHTTP处理器在重定向方面与OkHttp进行的唯一交互是，它读取处理器属性并在OkHttpClientBuilder对象上设置选项：
// Set whether to followokHttpClientBuilder.followRedirects(context.getProperty(PROP_FOLLOW_REDIRECTS).
浏览 0提问于2018-09-11得票数 3
回答已采纳
我是kylo平台的我的工具。我需要Oracle数据库，而不是kylo平台上的hive数据库。
浏览 4提问于2017-11-16得票数 0
回答已采纳
我们有一个使用ssl配置的Teiid12.3服务器正在运行。但是我们无法连接Apache NIfi中的Teiid服务器。我们尝试了以下方法来包括信任-
创建StandardSSLConte
浏览 5提问于2020-04-28得票数 0
在列出数据库中的表之后，我正在执行一系列查询，基本上是通过添加一些smarts来执行数据库转储。
查询集中的记录号(行总数已经是一个属性从
浏览 1提问于2018-01-08得票数 0
回答已采纳
我正在处理包含地理坐标点的json对象。我想在本地的postgis服务器上运行这些点，以评估多边形匹配中的点。我希望通过预先存在的处理器来完成这一任务--我正在成功地将lat/lon坐标提取到带有"EvaluateJsonPath“处理器的属性中，并使用"ExecuteSQL”成功地向本地postgis数据存储发出查询这给我留下了avro，然后我可以用"Con
浏览 2提问于2016-04-11得票数 4
回答已采纳
我们已经开始在很多数据管道作业中使用NiFi。在Nifi中具有挑战性的事情之一是对流的变化进行回归测试。
处理NiFi流的单元测试和功能测试的常见方法是什么？有什么框架吗？
浏览 0提问于2019-07-16得票数 6
但令我惊讶的是，没有必要说明如何解释.parquet，也没有必要说明如何将其列与DB表的列进行映射。它仍然没有像我想的那样工作，它需要流文件内容已经作为记录到达？事实是，我也不能更好地解释自己，因为我真的不明白在Nifi中什么是记录，或者记录与.parquet的读数有什么关系。 要么是缺少处理器，要么是配置错误。然而，它只能与ListHDFS或ListFile一起使用，这不允许我从Azure data Lake Storage获取数据
浏览 28提问于2021-05-08得票数 0
回答已采纳
我们希望使用NiFi连接ADLS (使用PutHDFS和FetchHDFS)，而不必安装HDInsight。随后，我们希望使用Azure DataBricks来运行Spark作业，并希望可以使用NiFi的ExecuteSparkInteractive处理器来完成这项工作。从我能找到的所有例子中，似乎总是需要HDP或HDInsight。提前谢谢。
浏览 0提问于2018-09-10得票数 2
我需要执行这样的操作: sed '1d‘simple.tsv > noHeader.tsvsed '1d‘myFlowFile > myFlowFile
编辑
浏览 2提问于2017-02-24得票数 6
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
