在RouteOnAttribute中使用Equals
是指在数据流处理中，使用Equals操作符来进行条件判断和路由操作。具体来说，RouteOnAttribute是一种数据流处理器，它可以根据输入数据的某个属性值进行条件判断，并将数据路由到不同的输出流中。
使用Equals操作符可以比较输入数据的某个属性值与指定的值是否相等。如果相等，则将数据路由到满足条件的输出流中；如果不相等，则将数据路由到其他输出流中。这样可以根据不同的属性值来对数据进行分类和处理。
RouteOnAttribute的优势在于它可以根据属性值进行灵活的条件判断和路由操作，使得数据处理更加精确和高效。它可以用于各种场景，例如数据过滤、数据分流、数据分类等。
腾讯云提供了一系列与数据流处理相关的产品和服务，其中包括腾讯云流计算（Tencent Cloud StreamCompute）。腾讯云流计算是一种基于Apache Flink的流式计算引擎，可以实现实时数据处理和分析。在使用RouteOnAttribute时，可以结合腾讯云流计算来进行数据流处理和路由操作。
更多关于腾讯云流计算的信息和产品介绍，可以参考以下链接：
请注意，以上答案仅供参考，具体的技术实现和产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我需要使用Nifi动态更新RouteonAttribute处理器属性的帮助。
例如，如果我发送Sensor_value:50，RouteonAttribute必须自动设置如下属性
${Sensor_value:equals(50)}
你们能帮我吗？
谢谢你们
浏览 0提问于2020-01-30得票数 0
在RouteOnAttribute中，如果merchant包含“//”，我想发送给"unmatched“：”这段代码可以工作吗? Equals可以不查看整个字符串而只查看其中的一部分吗？“ ${merchant:equals('://'):not()} Json主体 "operation": {
"type": "A",
"cardNumber": "123323131223212",
"tranAmount": 450000
浏览 34提问于2021-01-27得票数 0
我有一个来自这样的InvokeHTTP的json：
{
"id": "1234567890",
"status": "completed",
"others": "abc",
"field": "1"
}
我想使用处理器(也许是RouteOnAttribute??)这将检查响应的状态是否完成，如果不匹配，则返回到invokeHttp再次检查状态。
我尝试过这样的方法：EvaluateJsonPath(从json提取id )、-> Invo
浏览 1提问于2021-07-20得票数 2
回答已采纳
我从FTP接收tar文件，并在提取它之后将其保存到HDFS。我现在的管道是这样的。
ListFTP -> FetchFTP -> UnpackContent -> PutHDFS
这个tar包含10个文件，因此对于一个tar文件，会生成10个流文件。我的要求是在HDFS中存储3个特定文件之后触发另一个作业。我应该使用哪个处理器，或者使用Nifi是否有其他方法来解决这个问题？
浏览 0提问于2018-07-20得票数 0
2回答
我试图在更新属性处理器中编写EL。以下是我的要求：
用户输入:存储在属性中的IP地址：target.host.name.linux
我在nifi.properties中定义了另一组属性如下：
trigger.target.system.linux.name=10.44.245.33
trigger.target.system.linux.password=Passw0rd
我正在尝试将用户输入的值与属性文件中的属性值进行比较。如果它们匹配，我将在真实情况下将变量赋值在trigger.target.system.linux.password上面，否则就会发布“no”
下面是一些我试过但徒劳无功的
浏览 1提问于2018-05-09得票数 0
回答已采纳
请帮帮我！ 我有一些文件的名称由"yymmdd“格式的日期组成，例如： TRB_ASE_D190125.txt TRB_TIT_D190125.txt 我只需要获取名称与当前日期匹配的文件。例如，如果日期是"190125"，则两个后续文件将匹配该标准。 我正在使用ListFile处理器获取文件，并使用"now“函数将此正则表达式放入文件过滤器中，但它不起作用： ^TRB_A-Z+_D${now():format('yymmdd')}.TXT 提前感谢！
浏览 24提问于2019-03-22得票数 1
我正在处理一个NiFi工作流。JSON正在进入工作流，我正在使用EvaluateJsonPath和RouteOnAttribute流程。在EvaluateJsonPath中，我将Null值表示设置为空字符串。
[
{
'a':null,
'b':null
},
{
'a':'1',
'b':'2'
}
]
我使用一个JsonSplitter来拆分这个数组，以便单独处理JSON数组中的每个元素。
在第一个EvaluateJsonPath中，我执行以下操作
浏览 6提问于2021-07-15得票数 0
我想每天从SFTP位置动态读取文件，例如，基于文件名中的日期。我正在使用ListSFTP的文件过滤器正则表达式来只匹配那些具有今天日期的文件， 例如，今天的文件是data_04142021.csv，明天就是data_04152021.csv 我可以使用哪个文件过滤器regex来做这件事？ 我已经尝试了^data_${now():format('MMddyyyy')}.*，但是没有成功。 任何帮助都将不胜感激。
浏览 25提问于2021-04-15得票数 1
回答已采纳
我想使用routeonContent，并根据方法名将我的响应放在不同的目录中，我有'$message.body‘属性和使用表达式(在routeonContent中) ${message.body:contains('<person>')}。但是它对我不起作用，你有更好的主意我该怎么做吗？
浏览 1提问于2017-09-25得票数 0
我试着读一个这样的日志文件：
199.72.81.55 - - [01/Jul/1995:00:00:01 -0400] "GET /history/apollo/ HTTP/1.0" 200 6245
unicomp6.unicomp.net - - [01/Jul/1995:00:00:06 -0400] "GET /shuttle/countdown/ HTTP/1.0" 200 3985
199.120.110.21 - - [01/Jul/1995:00:00:09 -0400] "GET /shuttle/missions/sts-73/mi
浏览 0提问于2018-04-12得票数 2
我有两个不同的应用程序，名为A1和A2。每个应用程序都有自己的Kakfa服务器。来自这两个KAKFA服务器(代理)的消息发送到NiFi。
每个Kakfa都有不同的主题名称，基于这个，我可以区分来自Kakfa的消息。但是，除了卡夫卡的主题名称之外，在NiFi中还有其他方法来区分来自两个不同Kakfa的消息吗？他们是否有NiFi处理器来检查主题名，然后决定下一条路线？
非常感谢。你好啊，叶什维德
浏览 0提问于2018-12-17得票数 2
回答已采纳
我正在使用下面的Nifi处理器
HandleHttpRequest -> RouteOnAttribute -> HandleHttpResponse
My RouteOnAttribute property is test and value is ${http.headers.type:contains('test')}
我已经在这个url 中附加了nifi模板。
下面是我发送给nifi服务器的示例客户端请求，我得到的响应代码与我在HandleHttpResponse的http状态代码中提到的相同，这意味着我正确地配置了处理器
import reque
浏览 8提问于2020-11-13得票数 1
2回答
Nifi中的条件路由
、、、
我正在从GetFile处理器获取一些数据，目前分别使用PutmongoRecord和PublishAMQP处理器将其发送给mongoDB和rabbitMQ。
我想把这个设置为条件，比如从一个值为"mongo“的文件中读取一个属性，那么我应该只能将它推到mongoDB而不是rabbitMQ。
我读过关于RouteOnAttribute处理器的文章，但不确定它在我的情况下将如何工作。请帮帮忙。
浏览 1提问于2019-07-17得票数 0
回答已采纳
我目前正在使用Nifi来读取tealium事件流并加载到HDFS中。需要帮助过滤数据时，源错过发送数据的属性。
{“帐户”：“NewTV”，“twitter:description”：“发现您最喜欢的NewTV显示和主机何时显示。"，“"og:url":"www.newtv.com/show/program-guide"}}，：post_time”：“2019-10-09 11:27:46"，”用户代理“：”Mozilla/5.0“(Windows 10.0；Win64；( x64) AppleWebKit/537.36 (event_id，类似
浏览 1提问于2019-10-15得票数 1
回答已采纳
我试图在listenHTTP处理器中使用更通用的basepath --它们是否可以指定此way服务接受所有传入端口9090的调用，或者指定一个更通用的basepath，在这种情况下，如何在routeonAttribute上使用这个basepath？
浏览 1提问于2016-11-28得票数 2
回答已采纳
在我们的nifi开发环境中，我们有一些日志记录选项，用于在需要时捕获调试信息，我们通常希望将其关闭，但如果我们需要调试某些东西，这些选项将保持打开状态。
我正在寻找一种打开和关闭调试的好方法。我们可以很容易地禁用处理器，但随后文件会在它们后面的队列中堆积。
最干净的方法是关闭处理器和它前面的队列，这样除非我们想要调试，否则什么都不会被路由？
理想情况下，如果可以管理这样的选项，我更喜欢一种方法来打开和关闭分布在我们的流中的几个不同的日志记录处理器。
浏览 10提问于2021-06-02得票数 0
回答已采纳
我有一个产生json数据的源，每个文件只包含一个记录，如下文件1所示：-
{"X":"12","Y":"23","r":"3","V":"0"}
文件2：-
{"r":"32","Y":"24","x":"3","V":"12"}
文件3：-
{"v":"1","r":"23"
浏览 3提问于2019-09-23得票数 0
我在不同的位置有3个文件，我使用3个列表文件处理器，然后是fetch文件处理器。现在，我想将这些文件路由到它们各自的目的地，这对于所有3个文件都是不同的。需要一些帮助才能做到这一点。
谢谢
浏览 0提问于2018-05-10得票数 3
是否可以根据返回单个行结果的SQL查询的结果来路由流文件？例如，如果结果为“1”，则流文件将被处理；否则，它将被忽略。
解决方案
下面的方法对我最有效。
使用ExecuteSQL处理器来运行筛选SQL查询。编写该查询的目的是以Shu建议的方式生成单个记录(match)或空记录集(no )。
将ExecuteSQL连接到处理器，以便使用路由属性值${executesql.row.count:replaceNull(0):gt(0)}的下列值筛选出不匹配的流文件
注意到，在应用ExecuteSQL之后，流文件的原始内容将丢失。在我的例子中，这不是一个问题，因为我在处理流文件内容之前
浏览 1提问于2018-09-25得票数 3
我有一个ExtractText处理器，在这里我添加了3个表达式: balance、card和name。为了提取这些值，我使用正则表达式。因此，作为名称，我有一个解析的部分：(.*?)，\d+，\d+(?:.\d+)？我有两个PutKafka处理器，一个接受有效条目(匹配)，一个接受无效条目(不匹配)。到现在为止还好。
我想在匹配上添加一个特定的测试，对名称表达式使用RouteOnAttribute处理器。我看到的错误是：'name‘根据$(name:equals("CODE-01")}验证无效，因为找不到表达式。我想我有个表情。我显然没有！:)我在哪里拐错了弯？
浏览 0提问于2018-02-08得票数 0
回答已采纳
2回答
目前，我正在从Nifi中的FTP获取文件，但是在获取文件之前，我必须检查一些条件。情况是这样的。
列出FTP ->检查条件->提取FTP
在Check条件部分，我从DB中获取一些值并与文件名进行比较。因此，我是否可以使用update属性从DB中获取一些记录并使其像这样呢？
列出FTP ->更新属性(来自DB) ->路由上的属性->获取FTP
浏览 1提问于2018-08-21得票数 2
回答已采纳
我有一个python脚本，它接受命令行参数来解密文件。要执行的python命令如下所示：
python decrypt.py -f "file_to_decrypt.enc" -k "private_key_file.txt"
我试图使用GetFile处理器在NiFi中拾取这些文件，因为我可以在日志中看到文件名，因此它负责挑选这些文件。
另一方面，我有一个ExecuteProcess进程设置来运行上面提到的python脚本。但是，我需要将文件名传递到ExecuteProcess中，这样才能使Python工作。因此，我的问题是，如何将文件从GetFile进程传输到
浏览 3提问于2017-01-31得票数 3
回答已采纳
我使用下面的表达式来计算值：${alert:gt(${Lower}):or(${alert:lt(${UPPER})})}，它返回True或False值。 根据要求，我必须发送一个真正的条件只邮件通知。有人能告诉我从上面的计算中只发送真实条件的合适条件吗？ ?
浏览 28提问于2020-10-09得票数 1
回答已采纳
我有一个JSON记录流，我用指令成功地将它转换成CSV记录。但是现在我想将这个CSV记录合并到一个CSV文件中。以下是流量：
在步骤5中，我将面对大约9K的csv记录，如何使用MergeRecord处理器将其合并为一个csv文件？
我的csv头：
field1,field2,field3,field4,field5,field6,field7,field8,field9,field10,field11
其中一些字段可能为null，并在记录中有所变化。
浏览 4提问于2018-05-30得票数 3
我已经在nifi数据流中创建了一个RouteOnAttribute处理器，我希望它只选择要解析的特定文件。在属性中，我使用以下表达式创建了一个属性"filetofetch“
${filename:contains('INCOMING.D151221')
我需要获取文件名INCOMING.D< YYYYMMDD>，所以今天的文件名为21 MARTS 2017
INCOMING.D20170321
我试过用这样的东西来命名
${filename:contains('INCOMING.D'+ ${now():format('yyyymmd
浏览 1提问于2017-03-21得票数 3
回答已采纳
正在尝试使用NiFi在属性上进行路由。我正在尝试获取一个json文件，其中两个json记录包含以下属性(此文件中还有其他具有不同属性的json文档)： {
"ts" : "2020-010-07T12:00:00.448392Z",
"uid" : "CHh3F30dkfueLhnxSk",
"id.orig_h" : "10.10.10.10",
"id.orig_p" : 19726,
"id.resp_h" : "172.10.10
浏览 18提问于2020-08-23得票数 1
我有数据需要比较月份的数据，如果是前一个月，那么它应该插入，否则不。
示例：
23.12.2016 12:02:23,Koji,24
22.01.2016 01:21:22,Mahi,24
现在我需要得到第一列数据(23.12.2016 12:02:23)，然后得到月份(12)。
和当月前比较起来.
If current month is 'JAN_2017',then get before of 'JAN_2017' it should be 'Dec_2016'
第一排，
将这一“2016年12月”与数据月份“Dec_2016”(2016年1
浏览 1提问于2017-01-27得票数 0
回答已采纳
我试图解压缩一个文件(其中包含两个文件格式，一个PDF和另一个txt)。我能够解压缩它，现在需要将它分开，并将它保存在两个不同的队列中，一个将容纳txt，另一个将执行PDF。如果有人能帮我找到这条路。
浏览 9提问于2022-04-19得票数 0
回答已采纳
使用apache nifi，我想获得所有的输入twitter文件，这些文件具有输入json的"tech“的哈希标签。
{
"created_at": "Sun Mar 25 18:00:43 +0000 2018",
"id": 977968537028481025,
"id_str": "977968537028481025",
"text": "@bby__nim You know like datttt",
"entities": {
浏览 0提问于2018-03-25得票数 0
使用ConsumeIMAP从收件箱中读取电子邮件，并尝试选择仅在上午8点从“xyz@yahoo.com - send”到“abc@gmail.com”的主题中只选择要下载的电子邮件。
如果可以在任何组件中设置，请让我知道。我试着使用EvaluateJsonPath，ExtractEmailHeaders和RouteonAttribute，但是还没有成功。
浏览 11提问于2017-08-28得票数 3
回答已采纳
我是nifi的新手，我正在尝试从中获取数据。我需要从2021/01/01 /01调出数据直到今天。我有一个这样做的工作流程，但问题是，我使用替换文本处理器作为发送json的方法，以便为gg api发送json。
我想要创建一个循环，在相同的文本中更改相同的日期。
例如：
这是我要发的短信
{
"query": "SELECT search_term_view.ad_group, search_term_view.resource_name, search_term_view.search_term, search_term_view.status, segmen
浏览 12提问于2022-02-16得票数 0
在使用NiFi表达式语言时，我刚刚收到一个关于意外标记的错误。
'prod' validated against ${hostname:contains("prod")} is invalid because
Unexpected token ':' at line 1, column 10. Query: ${hostname:contains(prod)}
在这种情况下，问题出现在RouteOnAttribute处理器中。
我的问题是:导致这个错误的典型原因是什么？
浏览 0提问于2019-11-19得票数 2
我有一个NiFi流，它需要将数据发布到其他服务器，在发布之前，它需要从我的内部服务器或Nifi分布式缓存中获取一个值。 并在发布数据之前将该值添加到Http报头中，当获得特定错误代码401时，该值也被更新。 下面是我正在尝试的流程，所有的绿色处理器都是我能做的，但是我只能获取值并添加到invoke http头中。我可以让我们实现这一目标的其他过程是什么。 ?
浏览 100提问于2020-01-22得票数 0
1回答
目标
Nifi ListenHTTP/HandleHTTPRequest处理器不支持Basic，因此正如建议的那样--您可以使用ListenHTTP/HandleHTTPRequest处理器和RouteOnAttribute来验证用户名和密码。在我的例子中，Nifi接受普通的HTTP请求，因为Nifi隐藏在Api网关SSL终端下。如果准确地说，Nifi会获得，这是因为等于base64(username + ':' + password)
问题
如果Nifi以纯文本形式获得授权HTTP头，则将凭据存储在Nifi侧作为敏感参数是否有意义？
如果是，如何根据预期的对安全地验证HTTP
浏览 5提问于2020-07-03得票数 0
2回答
我使用NiFi从Oracle数据库中获取数据，并将其中的一些数据放入Kafka (使用PutKafka处理器)。示例:如果属性"id“包含"aaabb”
这在Apache NiFi中是可能的吗？我该怎么做呢？
浏览 2提问于2016-05-04得票数 5
回答已采纳
希望你们都过得很好。 我正在乞求我的Nifi学习，我想复制一个我在其他平台上运行的过程。 我的目标是读取CSV并逐行处理，以插入到sql服务器表中。 到目前为止，我可以通过以下方式做到这一点： GetFile -> SplitRecord -> ConvertRecord (to json) -> ConvertJSONtoSQL -> UpdateAttribute (date conversion) -> PutSQL。 但是如果记录已经存在于destiny表中，则需要进行验证。有人能帮我吗？我已经找过了，但我找不到。 如果你们有一个更好的、完全不同的解决方
浏览 28提问于2020-12-21得票数 0
如何安排NiFi processor仅在收到当天的第一个流文件时运行。 处理器可以忽略所有后续的流文件。
浏览 9提问于2020-01-30得票数 0
我正在尝试使用一些提取的值来执行一些SQL。在某些情况下，我会得到数据，而在另一些情况下，我会得到null。对于null情况，我希望路由它们，因此查看了在将它们从Avro转换为JSON之后使用RouteOnContent。 然而，我不知道应该检查什么“财产”。RouteOnContent处理程序要求您输入要检查的属性名称和值，在本例中，我没有任何属性，因为整个数据都是{} 我应该如何评估以获得一个值来检查{}是否相应地进行路由？我甚至可以使用Avro来代替吗？ 流程： ?
浏览 122提问于2021-08-30得票数 0
我有一个已连接的SFTP服务器，并且我正在尝试根据类型路由文件：.csv、.tsv和.xlsx。现在，我只是通过命令行上传测试文件。
我的流程是：
GetSFTP (with correct hostname, etc.) ->
RouteOnAttribute ->
LogAttribute (will dump elsewhere soon, this is just for testing)
我的问题是，我在RouteOnAttribute中错误地创建了一个属性：
我假设这实际上不会在.csv上出现，因为从技术上讲，它不是文件名的一部分，这是正确的吗？在文件类型上路
浏览 2提问于2018-12-06得票数 0
NiFi中的RouteOnAttribute中有两个条件。如果两个条件都满足，则ExecuteSQL处理器应该运行，否则MonitorActivity处理器应该运行。如果其中一个条件失败，则应运行MonitorActivity。如何同时检查这两个条件？当我尝试Route to 'matched' if all match时，它无论如何都会路由到unmatched。
浏览 2提问于2021-04-20得票数 0
在NiFi中，存在来自MQTT (ConsumeMQTT)的数据流并将其发布到HDFS (PutHDFS)。在将消耗的数据推入HDFS路径之前，我需要引入60分钟的延迟。发现ControlRate和MergeContent处理器是可能的解决方案，但不确定。
引入时滞的理想解决方案是什么？
示例:在上午9:00消耗的流文件应该在上午10:00发布到中
浏览 21提问于2020-05-18得票数 8
回答已采纳
1回答
当涉及到NiFi时，我完全是一个菜鸟-所以请随时强调任何愚蠢/无知。
我正在使用NiFi阅读卡夫卡主题中的消息。
每条消息都包含JSON，该JSON包含一个名为Function的字段，然后是一大堆基于函数的不同字段。例如，如果Function ="Login"，您可以期待用户名和密码字段，但如果Function = "Pay"，您可以期待"From“、"To”和"Amount“字段。
我需要以不同的方式处理每种类型的函数。因此，基本上，我希望从Kafka读取消息，确定函数，然后根据函数将消息路由到适当的规则集。
这听起来应该很简单--但有
浏览 0提问于2020-06-03得票数 0
PDF文件流到routeOnAttribute，它过滤文件的大小。所以现在我有大于文件大小和小于文件大小。随着更大的文件大小进入S3桶，而不是流到成功。所以，我想要的是从队列中删除/删除流文件，因为我们没有对流文件做任何事情。
有人能指导我使用哪种处理器吗？
浏览 7提问于2022-05-18得票数 0
我如何在nifi中验证一个像这样的RouteOnAttribute：${param1} > ${param2}，这些参数是unix格式的日期。我目前遇到的错误是正常的(它是无效的，因为找到了几个表达式，但只有1个表达式是预期的)。基本上，我需要的是，如果一个参数大于另一个参数，则工作流转到一边，否则转到另一边。
浏览 18提问于2019-06-10得票数 0
回答已采纳
1回答
我使用EvaluateJsonPath从JSON中提取一个特定的值。我正在使用折叠的JSONPath表达式：
$.data[?(@.containerType == 'SOURCE' && @.path == 'SOURCE_KYLO_DATALAKE')].id
这是我在JSONPath上调用的JSON文档：
{"data":[{"id":"dc18bf87-c5a6-4600-9584-e79fb988b1d0","path":["@Rakesh.Prasad@diag
浏览 3提问于2018-09-24得票数 2
回答已采纳
我希望使用存储在流文件内容中的整数值来进行路由。
该值来自流中前面的一个select count(*) from <table>。此值作为流文件的内容存储。接下来，如果value > some_integer我想以一种方式路由，如果不是，则路由到不同的路径。
有一种方法可以做到这一点:首先收集这个值作为流文件的属性，然后使用RouteOnAttribute处理器。但是，我是否可以使用RouteOnContent或RouteText来做同样的事情呢？这样我的处理器就少了两个。
谢谢
浏览 6提问于2022-08-29得票数 0
回答已采纳
我有一个NiFi process RouteOnAttribute，在其中我有一个用户定义的表达式来匹配属性。 我已经将其设置为在不匹配时自动终止FlowFile。它工作得很好。 我想发送一条消息，当不匹配时显示在NiFi图形用户界面进程的公告指示器上。有什么方法可以配置它吗？(项目使用的底层代码是Java)
浏览 30提问于2021-01-21得票数 0
我试图在Nifi中使用EvaluateJsonPath处理器，并且在jayway jsonpath语法上遇到了问题。我的对象如下所示：
{"text":"my stuff", "tags":["abc", "xyz", "beq"]}
我希望根据标签路由消息--我希望所有包含"xyz“的内容都以一种方式路由，而不包含它的所有内容都以另一种方式路由。使用，我一直在测试并尝试根据包含字符串匹配数组的json对象来筛选语法。我可以根据显式索引进行匹配(因此$.[?(@.tags[1] =~ /xy
浏览 2提问于2016-01-19得票数 3
回答已采纳
尝试用用户输入在NiFi中找出一些东西。
这是我的要求:我需要接受属性中的用户输入，并根据输入值执行一个RouteOnAttribute。用户输入包含多个选项(总共6个)。有没有一种方法可以将用户选项输入到一个属性中作为下拉选择机制？
我不想为单独的输入选项使用单独的属性。除此之外，我想不出UpdateAttribute处理器中的任何东西。
是否有其他此类处理器可用于此要求？到目前为止，我还没有找到任何(对NiFi来说很陌生)。
有什么想法吗？
浏览 0提问于2018-05-01得票数 0
回答已采纳
4回答
由于仍未解决，所以我有一个EvaluateJsonPath处理器，它有时输出带有空字符串的属性。
有一种直接删除流文件属性的方法吗？
我尝试使用UpdateAttributes处理器，但它只能根据属性的名称进行删除(我需要匹配属性值)。
浏览 4提问于2018-02-03得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
