如何将文件名保存在Nifi中的变量中？
在Nifi中，可以通过使用UpdateAttribute处理器将文件名保存在变量中。下面是具体的步骤：
- 在Nifi的流程中添加一个UpdateAttribute处理器。
- 配置UpdateAttribute处理器的属性，将文件名保存在一个变量中。可以使用以下表达式来提取文件名：
- 属性名称：
filename - 属性值：
${path:substringAfterLast('/')}这个表达式会从文件路径中提取最后一个斜杠后的部分，即文件名，并将其保存在名为filename的变量中。
- 属性名称：
- 将UpdateAttribute处理器连接到其他处理器或输出端，以便进一步处理文件或将其发送到目标位置。
这样，文件名就会保存在Nifi的变量中，可以在后续的处理器中使用该变量进行操作。
关于Nifi的更多信息和使用方法，可以参考腾讯云的Nifi产品介绍页面：腾讯云Nifi产品介绍
相关·内容
我是Nifi的新手，我正在尝试获取一个文件名，并将该文件名保存在一个变量中，以便稍后在此过程中使用。基本上，我有一个包含2个.txt文件(1.txt和2.txt)的文件(data_yyyyMMdd.tar.gz)，在解压该文件之前，我想将其名称保存到一个变量中，然后使用该变量将内容添加到解压后的文件中文件内容(原文)：1.txt id|name 1|apple 2
浏览 31提问于2020-09-03得票数 0
我试图使用NiFi表达式语言中包含文件路径的环境变量。当我只为文件名提供环境变量${MY_VAR}时，它不会被解析。但是，如果NiFi EL前面有空格或其他字符，则将对其进行计算，但这将导致文件名无效。如何在没有任何额外字符的情况下解决这个问题。PS:我正在尝试在默认的StandardSSLContextService中在Truststore文件名字段中指定文件名
浏览 0提问于2017-08-08得票数 0
回答已采纳
我正在尝试导出Nifi模板并将其导入到另一个Nifi实例中。但是，我们注意到，当我在另一个Nifi实例中导入模板时，被定义为PG作用域的变量并不存在。我错过什么明显的事情了吗？
问候
浏览 2提问于2019-07-18得票数 1
回答已采纳
要执行的python命令如下所示：我试图使用GetFile处理器在NiFi中拾取这些文件，因为我可以在日志中看到文件名，因此它负责挑选这些文件。另一方面，我有一个ExecuteProcess进程设置来运行上面提到的python脚本。但是，我需要将文件名传递到ExecuteProcess中，这样
浏览 3提问于2017-01-31得票数 3
回答已采纳
下面是一个简单的NiFi流，它监视文件的文件夹并复制到另一个文件夹。它工作正常，但我正在寻找一个处理器，它只提取文件名并将文件名写入文本文件中。我尝试过ExtractText处理器，但不知道如何将它配置为只读取文件名。任何建议都是非常感谢的。
浏览 0提问于2018-08-01得票数 3
回答已采纳
我想知道，在Twitter API中使用Nifi + Kafka而不是直接将Spark连接到它有什么好处，我想它会像这样更容错，但我真的不知道。
浏览 2提问于2022-01-08得票数 0
回答已采纳
我有文件从三个不同的来源进入一个"PutHDFS“处理器。这三个源都有单独的键标签，并且将被分离到不同的目录。由于源代码的名称在文件名中，所以我能够创建一个名为"source_name“的变量，我可以使用它来使目录变得很好，如下所示：
/my/hdfs/directory/${source_name}/reports我想对Kerberos主体和Kerberos Keytab执行类似的
浏览 0提问于2019-08-14得票数 0
回答已采纳
但是我们无法连接Apache NIfi中的Teiid服务器。我们尝试了以下方法来包括信任-
也在下面的文件中配置了trusto
浏览 5提问于2020-04-28得票数 0
我们正在对Apache NiFi做一个概念验证测试。布局屏幕的字体看起来大约是10磅，这太小了如何简单地更改所使用的字体？
浏览 14提问于2018-01-04得票数 0
回答已采纳
我有多个nifi服务器，我希望能够通过脚本中的REST接口发布模板。
“/控制器/模板”端点似乎是支持POSTing的适当REST端点--一个用于我的Nifi安装的任意模板。"snippetId“字段使我感到困惑，如何确定”其内容将包含模板的代码片段的id“？有没有人有一个例子，我可以上传一个模板"test.xml“到我的服务器而不必使用UI？
浏览 3提问于2016-07-18得票数 8
回答已采纳
这是一个关于尼菲的问题。
但是，在流的末尾，PutFile处理器抛出一个错误，说“同名<e
浏览 0提问于2019-05-24得票数 0
回答已采纳
我一直试图访问NiFi流量文件属性从卡夫卡消息在星火流。我使用Java作为语言。这些byte[]属性使用火花流作业转换为ASCII数据，这些解码后的ASCII被写入Kafka进行进一步处理，并使用NiFi处理器保存到HDFS。我的问题是我无法跟踪二进制文件名和解码的ASCII文件。我必须在已解码的ASCII中添加一个标题部分(用于文件名、文件大小、记录计数等)，但我没有弄清楚如何从NiFi KafkaConsumer
浏览 9提问于2017-06-09得票数 1
回答已采纳
我正在查看nifi以将文件写入HDFS。我希望将文件写入基于文件名/年/月/日/小时的目录结构中1)这可能吗?
浏览 1提问于2019-07-23得票数 0
我想在我的Nifi处理器中引用一个环境变量(一个linux环境变量)。我尝试通过直接引用处理器属性中的${MY_VARIABLE_NAME}来使用表达式语言。但这似乎行不通。这有可能吗？谢谢你的建议。
浏览 2提问于2017-02-14得票数 3
1回答
我已经将Nifi设置为从SFTP中获取文件，然后根据文件名将它们放到HDFS文件夹中。从那里开始，它需要发送命令alter table ${dbname}.${tablename} add partition (year=${year}, date='${date}');
我知道我需要使用"PutHiveQL“处理器，但我不知道如何将'alter‘命令提供给它我以前所有的处理器都是为了创建构建HDFS文件夹路径的变量。没有真正<e
浏览 0提问于2019-10-01得票数 1
回答已采纳
当我在ExecuteScript processor中运行python作业时，就会发生这种情况。我已经找了很多次答案，但还是找不到一个可行的解决方案。一个回答说我应该添加这样的代码来包含我的外部python库，我尝试了一下，但错误仍然存在。import sys另外，我在processor中添加了module属
浏览 2提问于2017-09-19得票数 2
我将一些XML格式的文档加载到Marklogic中。uuid属性名称属性默认为“PutMarkLogic”。如何将其更改为文件名。我已经更新了Nifi中的UpdateAttribute和PutMarkLogic属性。它起作用了。
浏览 79提问于2019-03-03得票数 3
回答已采纳
我有一个nifi流，它从RDBMS (SQL Server)表中提取记录，并将这些记录放在HDFS上，采用拼接格式。此流程将在一天内运行几次，以从源表中获取增量记录。现在，我需要为100+不同的源表复制相同的过程。因此，不是为每个单独的表创建sql流，而是可以创建主流(比如说模板)，并将源提取100+、目标文件名等参数传递给主流，然后对每个源表重复这些步骤。我使用的是Nifi Nifi 1.7。我已经非常接近对流本身进行参数化了。
示
浏览 0提问于2019-02-01得票数 1
在NiFi中，如何创建配置StandardRestrictedSSLContextService控制器服务所需的密钥库、信任库和证书？采取的步骤：
$keytool -import -alias mycert -keystore /opt/nifi/conf/
浏览 1提问于2020-09-16得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
