如何在Apache NiFi的FTP上附加一个JSON文件？
在Apache NiFi的FTP上附加一个JSON文件，可以通过以下步骤完成：
- 配置FTP连接：在NiFi的控制面板中，使用"GetFTP"或"FetchFTP"等处理器配置FTP连接参数，包括FTP服务器地址、端口、用户名和密码等。
- 获取JSON文件：使用"GetFTP"或"FetchFTP"处理器从FTP服务器上获取JSON文件。配置处理器的目标路径，可以是FTP服务器上的特定目录或文件。
- 解析JSON数据：使用"EvaluateJsonPath"处理器解析JSON文件中的数据。配置处理器的属性，指定要提取的JSON字段和输出属性的名称。
- 附加JSON文件：使用"PutFile"处理器将JSON文件附加到FTP上。配置处理器的目标路径，可以是FTP服务器上的特定目录或文件。选择"Append"选项，以确保文件被附加而不是覆盖。
- 完成流程：将以上处理器连接起来，构建完整的数据流程。确保处理器的顺序正确，并且连接器正确配置。
相关·内容
在Apache中，我有一个流，其中NiFi的内容是JSON对象的数组。每个流文件都有一个唯一的filename属性。// flowfile1:
[ {}, {}, {}, ... ]
[ {}, {}, {}, ... ]
现在，如果具有给定<
浏览 24提问于2020-06-05得票数 0
我一直试图访问NiFi流量文件属性从卡夫卡消息在星火流。我使用Java作为语言。场景是，NiFI使用GetSFTP处理器从FTP位置读取二进制文件，并使用publishKafka处理器将byte[]消息发布到Kafka。这些byte[]属性使用火花流作业转换为ASCII数据，这些解码后的ASCII被写入Kafka进行进一步处理，并使用NiFi处理器保存到HDFS。我的问题是我无法跟踪二进制文件名和解码的ASCII<e
浏览 9提问于2017-06-09得票数 1
回答已采纳
我启动了一个apache/nifi容器，构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
1回答
$.id:append('-') & ${id: append ('-')} in JsonPathProcessor不给我任何结果，在Apache中的传入属性末尾添加文本的正确方法是什么？
浏览 3提问于2017-05-16得票数 0
回答已采纳
有人遇到下面的问题后安装Apache在Linux上吗？nifi-1.16.1 Bootstrap文件: /home/azureuser/nifi-1.16.1/conf/bootstrap.conf
当检查下面的状态时: Java :/usr/lib/jvm/java-11-OpenJDK-AMD 64 NiFi home: /home/azureuser/ N
浏览 8提问于2022-08-20得票数 -1
我在Windows上安装了所有的东西：2- Apache NififormatConvert 获取.csv文件，将其转换为JSON到SQL，将结果转储到表<code>F 215</code>
浏览 4提问于2022-08-29得票数 0
1回答
我想为NiFi中的每个处理器创建日志文件。我使用splitText来分割日志文件，然后处理它们之后，我将一个日志消息分发到5个文件中。我希望保存这些数据，并将其写入每个处理器的一个日志文件中(例如，我使用这个表达式获取可执行文本处理器${regex:toLower():contains('executescript')})。如何将这些日志写入每个处理器的一个日志文件</e
浏览 2提问于2017-08-30得票数 0
我对Nifi有个问题。当我设置nifi.web.http.host=luan 01时，我无法通过公共IP访问浏览器上的Nifi，例如：、。我只能通过主机名访问Nifi。你有什么解决办法吗？非常感谢。
浏览 2提问于2019-06-29得票数 1
回答已采纳
通常，当我必须向RestAPI发布多个包含multipart/form-data的文件时，我会使用如下所述的ExecuteGroovyScript：
'GroovyScript' is invalid because ... unresolved dependency: org.apache.httpcomponents#httpmime
我没有此NiF
浏览 0提问于2021-05-14得票数 1
嗨，我尝试使用DockerFile在Docker上运行NIFI Apache，但我得到了错误，就像我在图片中附加的一样，DockerFile上是否缺少任何设置？我的Docker撰写文件 version: '3.5'
nifi: context: ./config/nifi/conf:/opt
浏览 42提问于2019-03-11得票数 2
2回答
传输大量小文件
、、、、
当你的数据在MB甚至GB范围内时，通常的数据传输方法(scp、http和ftp实用程序，如curl或wget)可以很好地工作，但是当你有非常大的小文件集合(例如10KB)时，传输将非常慢，并且根本不会使用带宽有两个服务器( S1，S2)，当在S1中接收到一个文件时，它应该立即将其发送到S2。
您是否了解如何使用一些DSP工具，例如Apache Flink或NIFI？
浏览 3提问于2018-12-16得票数 0
我的本地windows机器上有一个文件中的数据。本地机器上运行着Apache NiFi。我想使用NiFi通过网络将这个文件发送到HDFS。如何在本地计算机上在中配置putHDFS处理器，以便通过网络将数据发送给HDFS
谢谢!
浏览 3提问于2016-08-11得票数 3
回答已采纳
我希望设置一个NiFi工作流，该工作流将从FTP服务器压缩的大型JSON文档( 500 MB到3GB之间)，将JSON对象拆分为单独的流文件，最后将每个JSON对象转换为SQL并将其插入到MySQL数据库中我在Oracle 8上运行NiFi 1.6.0，Java有1024 MB的堆空间集。我目前的流量是：
GetFTP -> CompressContent
浏览 0提问于2018-05-08得票数 1
回答已采纳
我是NiFi的新手，但我想在NiFi中做一个流程，在其中我将从FTP点获取一个.xls文件，并将其转换为JSON文件，并将其放入websocket服务器中。但是没有关于Excel的处理器。
浏览 6提问于2017-03-11得票数 1
我有一个扩展MergeContent进程的自定义处理器，当NiFi启动时，我在日志中看到以下错误：
2016-09-09 18:17:00,607 ERROR [main] org.apache.nifi.NiFi: org.apache.nifi.processor.Processor: Provider org.apache.nifi.processors.standard.DetectDuplicate cou
浏览 8提问于2016-09-10得票数 2
回答已采纳
首先，感谢您的帮助。我的问题是这花了我很多时间，因为我正在处理大文件。我的下一个任务是尝试修改<em
浏览 1提问于2020-01-17得票数 0
如何在NiFi ValidateRecord processor / JsonRecordSetWriter中将时间戳序列化为Json字段。在输入时，我有一个CSV文件，其中包含一个格式为yyyy-MM-dd HH:mm:ss.SSS的时间戳列。在我的NiFi流中，我有一个ValidateRecord处理器，它使用CSVReader进行读取，使用JsonRecordSetWriter作为编写器。当有像201
浏览 143提问于2018-10-19得票数 1
回答已采纳
我们正在尝试使用NiFi运行一个spark程序。，我们试图跟踪。
2020-04-13 21:50:49,955 INFO NiFi Web 85 org.
浏览 10提问于2020-04-03得票数 6
我是apache NIFI的新手。我想知道保存按钮在哪里。我在youtube上看到了一个教程中的一个例子。我想保存我创建的所有处理器，以供将来参考。我没看到任何保存按钮。以后把我的作品保存下来是可能的吗？或者在另一台机器上打开？
请帮帮忙。
浏览 5提问于2017-09-22得票数 15
回答已采纳
正在尝试在与本地实例连接的nipyapi中创建PutMongo处理器。我已经指定了所有必需的配置，但似乎不起作用。else:AttributeError: 'list' object has no attribute 'type'*
感谢大家的帮助
浏览 4提问于2020-11-09得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
