report_date" : "20210625",}] 如果一些UMT值在()中，我应该忽略它(键+值)，它可以是(none)，(direct)，(not provided)，(not set) 我试着用QueryRecord SELECT metric_value
浏览 45提问于2021-07-13得票数 0
我想在Nifi中获得excel文件的特定部分。我的Nifi模板像那样；
我应该在第2步和第是否有获得特定行和列的解决方案？注意:如果有一个选择削减ConvertExcelToCSVProcessor，它将对我工作。
浏览 5提问于2021-05-04得票数 1
如何保证NiFi QueryDataBaseTable处理器每次获取增量表时的数据序列。该表有一个名为"SEQNUM“的增量字段。并在QueryDataBaseTable处理器中通过"SEQNUM“设置”最大值列“。有什么方法可以通过获取delta表来排序吗？
浏览 0提问于2018-12-18得票数 0
回答已采纳
1回答
我试图对数据进行加密，以便只加密某些列。示例：{col1，col2，col3，col4} => {col1，加密(Col2)，col3，encrypted(col4)}
如果我的加密过程可以通过使用udf来完成，我如何在NiFi中注册和/或使用在Hive中，可以首先注册udf，例如:使用jar‘hdfs/path/to/jar/abc.jar’将临时函数udf_name创建为'abc.efg.udf_cl
浏览 0提问于2018-11-05得票数 1
回答已采纳
使用Apache，我需要过滤出具有一组特殊字符的NiFi中的记录。name,age,cityFFF,45,London然后，第二个记录必须从csv中取出，并放入另一个csv中此外，即使"FFF“是在城市或年龄列，整个记录必须删除。
请建议我所需要的处理器来实现这一点。此外，如果你能列出需要改变的配置，那将是非常有
浏览 13提问于2019-10-25得票数 0
回答已采纳
在NiFi数据流中，如果我想根据特定字段的值将单个流文件分割成两组，那么在性能方面，以下列方式使用QueryRecord或PartitionRecord是否更快？QueryRecord:PartitionRecord
在UpdateRecord中，以RecordPath在UpdateRecord中，<
浏览 0提问于2018-08-23得票数 1
使用ExecuteSQL处理器来运行筛选SQL查询。编写该查询的目的是以Shu建议的方式生成单个记录(match)或空记录集(no )。将ExecuteSQL连接到处理器，以便使用路由属性值${executesql.row.count:replaceNull(0):gt(0)}的下列值筛选出不匹配的流文件
注意到，在应用ExecuteSQL在我的例子中，这不是一个问题，因为我在处理流文件内容之前进行了过滤，我的SQL查询完全基于流文件属性，而不是它的内容。虽然在
浏览 1提问于2018-09-25得票数 3
当我希望将JsonMessages合并在一起(使用MergeContent)转换为JsonArray时，是否有一个处理器/流我没有考虑？我想尝试从多个文件构建JsonArrays，然后传递给QueryRecord来运行SQL。很好的机会，我错过了一个开场白/明显的方法去做那。任何帮助都将不胜感激。我可以使用groovy执行脚本，但如果可能的话，我希望避免使用自定义代码。谢谢!
-> MergeContent -> ConvertToJsonArray -&
浏览 3提问于2017-10-27得票数 6
回答已采纳
使用ExecuteSQL/ExecuteSQLRecord处理器，您可以指定“输出批大小”，这将导致多个流文件。每个流文件都包含executesql.row.count。做AttributesToJSON (drop content) => MergeContent (defragment) => QueryRecord (counting) => EvaluateJSONPath理想情况下，我希望以某种方式在MergeContent上/之后添加属性。问题是，MergeContent正
浏览 1提问于2020-07-12得票数 0
尝试合并两个传入的csv格式的流文件，并根据一些公共的头值准备一个组合的csv输出和来自两者的数据。需要基于"creation_Date“和"Hour_of_Day”连接行，并将两个流文件合并，并计算出"source_count“和"hive_count"之间的差异。是否有一种方法可以使用MergeContent连接并对输出文件运行查询以进行差异生成？
任何帮助都将不胜感激。
浏览 1提问于2018-08-23得票数 0
我想将6个CSV文件合并到1个ListHDFS >> FechHDFS >> UpdateAttribute >> MergeContent >> QueryRecord >> .ListHDFS >> FechHDFS >> UpdateAttribute作为要合并的文件数重复(6次)
因为我应该为每个文件提供fragment.index参数和一个别名(稍后用于QueryRecord中的联接查
浏览 10提问于2022-02-13得票数 0
回答已采纳
我目前正在使用Apache Nifi将数据推送到Elasticsearch中。数据被发送到单个索引，但我希望根据client_id字段的内容将数据动态路由到不同的索引。我有一个QueryRecord处理器在发送到Elasticsearch或丢弃之前做一些过滤。使用JsonTreeReader和JsonRecordWriter设置QueryProcessor
如何在PutElasticSearchRecord中设置索引设置以使用字段client_id的内
浏览 7提问于2021-10-01得票数 0
2回答
在nifi中，如果我从单个主题监听Kafka，并且基于路由逻辑，它将调用相应的进程组。然而，在RouteOnContent处理器中，如果给出正则表达式来检查字符串的出现，会不会影响性能，或者在基于条件的路由中如何达到良好的性能。
浏览 2提问于2019-06-17得票数 0
我试图简化Apache NiFi中的流。
EvaluateJsonPath将campaign_id存储到属性；之后，我可以使用RouteOnAttribute：${executesql.rows.c
浏览 0提问于2021-03-09得票数 0
我在Apache中工作，我有一个问题:如何在使用QueryRecord处理器的NiFi中处理嵌套数组？如何使用RPATH获得预期的结果
浏览 0提问于2021-04-17得票数 1
我有两个csv文件和两个文件有记录。我想删除重复的记录。我想要独特的记录。我怎样才能用Apache做这件事？input1.csv；1,ali,veliinput2.csv；1,ali,velioutput.csv；1,ali,veli3,ahmet,ozan
浏览 5提问于2021-12-19得票数 0
回答已采纳
1回答
我有一个csv，超过60列。然而，我只想从最初的中只需要32列。(我的csv有标题)
上面的语句具有输出csv中我想要的32列的所有名称(这个情况、col1、col2等)。根据我的理解，这是由于超过了受支持的列的限制。因为这个
浏览 1提问于2019-12-02得票数 1
我有一个nifi流，它接收.csv文件并将每个文件划分为多个记录，每个csv列值都作为一个属性添加。 在流程中的某一点上，我想从经过的每个记录中收集一个属性的值。可能有从0到n的集合。因此，如果我可以在一段固定的时间内收集数据，或者直到另一个属性(文件名)发生变化，那就太好了。 我尝试过合并内容和记录。我甚至尝试用要保存的属性值替换文本来替换内容，并合并这些属性值，以及许多其他内容。 在nifi中有
浏览 15提问于2021-01-27得票数 0
我正在用API从URL获取一些数字数据，我正在寻找一种方法，在将数据放到文件目录之前，在apache nifi中进行一些数学运算。现在已经谢谢你了。顺便说一下，我正在使用PutFile处理器获取数据并将文件放入某个地方，我使用的是InvokeHTTP处理器。我搜索了一些相关的网站，但我找不到一个可行的方法。
浏览 4提问于2019-07-09得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
