通过Nifi更新Json字段
是指使用Apache Nifi工具来对Json数据进行更新操作。Apache Nifi是一个可视化的数据流编程工具，用于构建数据流管道和实时数据处理系统。
在Nifi中，可以使用多个处理器来实现对Json字段的更新。以下是一个完善且全面的答案：
概念： Json字段更新是指对Json数据中的特定字段进行修改或更新的操作。Json（JavaScript Object Notation）是一种轻量级的数据交换格式，常用于数据传输和存储。
分类： Json字段更新可以分为两种类型：添加新字段和更新已有字段。添加新字段是在Json数据中添加一个新的键值对，而更新已有字段是修改Json数据中已有字段的值。
优势： 通过Nifi更新Json字段具有以下优势：
- 灵活性：Nifi提供了丰富的处理器和功能，可以根据具体需求灵活地进行Json字段更新操作。
- 可视化编程：Nifi的可视化界面使得编程变得更加直观和易于理解，即使对于非专业开发人员也能够轻松上手。
- 实时处理：Nifi支持实时数据处理，可以对流式数据进行Json字段更新，满足实时数据处理的需求。
应用场景： 通过Nifi更新Json字段可以应用于各种场景，例如：
- 数据清洗：对原始数据进行清洗和转换，包括删除无用字段、重命名字段、修复错误数据等。
- 数据转换：将Json数据转换为其他格式，如XML、CSV等。
- 数据集成：将不同数据源的Json数据进行整合和合并，更新字段以满足业务需求。
- 数据分析：对Json数据进行字段更新，以便进行更深入的数据分析和挖掘。
推荐的腾讯云相关产品和产品介绍链接地址： 腾讯云提供了多个与数据处理和云计算相关的产品，以下是一些推荐的产品：
- 腾讯云数据工厂（DataWorks）：提供数据集成、数据开发、数据运维等功能，可用于数据清洗和转换操作。详细介绍请参考：https://cloud.tencent.com/product/dm
- 腾讯云流计算 Oceanus：提供实时数据处理和分析的能力，可用于实时更新Json字段。详细介绍请参考：https://cloud.tencent.com/product/oceanus
- 腾讯云云函数（SCF）：提供事件驱动的无服务器计算服务，可用于编写自定义的数据处理逻辑。详细介绍请参考：https://cloud.tencent.com/product/scf
通过Nifi更新Json字段是一种灵活且强大的数据处理方式，可以帮助用户实现对Json数据的定制化操作和优化。
相关·内容
如何在NiFi ValidateRecord processor / JsonRecordSetWriter中将时间戳序列化为Json字段。
在输入时，我有一个CSV文件，其中包含一个格式为yyyy-MM-dd HH:mm:ss.SSS的时间戳列。在我的NiFi流中，我有一个ValidateRecord处理器，它使用CSVReader进行读取，使用JsonRecordSetWriter作为编写器。它们都使用Avro模式，时间戳字段定义如下
"fields" : [ {
"name" : "timestamp",
"type
浏览 143提问于2018-10-19得票数 1
回答已采纳
我正在尝试使用NiFi的PutCassandraRecord处理器将一些JSON记录插入到Cassandra DB中。我试图将时间戳类型插入到Cassandra中，但是NiFi抱怨输入字符串"2019-02-02T08:00:00.000“的NumberFormatException。
所述时间戳字段的cassandra数据类型是(ts时间戳)我使用的Avro模式：{ "name"："ts"，" type "：{"type"："long"，"logicalType"：" timest
浏览 8提问于2019-05-14得票数 1
我正在尝试使用JSON1.9.0处理器来修改UpdateRecord，但是它没有按照我所希望的那样替换这些值。 这是源消息 {
"type": "A",
"ids": [{
"id": "1",
"value": "abc"
}, {
"id": "2",
"value": "def"
浏览 24提问于2019-03-22得票数 1
1回答
我要用nifi把分贝压平。我在一个基于PK的表中读取，对于每一行，nifi内容都显示为一个MapRecord。我需要从MapRecord中提取每个字段值，并使其成为json属性。
输入：
{
"maxResults": 150,
"total": 89,
"issues": "MapRecord[{issueId=1, firstName=Jack, lastName=Smith}]",
"address": "MapRecord[{addressId=1, street=Mock
浏览 2提问于2021-09-10得票数 0
我有一个RedPanda消息队列，NIFI从该队列中提取JSON数据。然后，使用JOLTTransform将JSON数据简化为我想要的字段。
其结果是单个JSON对象。
{
"foo": "bar",
"message": "<Litteral copy of 1 syslog line>"
}
我希望使用像ParseSyslog或ExtractGrok这样的处理器来解析消息字段的内容，并将成功解析的结果添加回JSON内容。
到目前为止，我已经能够使用message将消息字段提取到一个名为EvaluateJSO
浏览 11提问于2022-11-18得票数 0
回答已采纳
我们将Apache Nifi设置为将文件写入本地驱动器，然后运行处理这些文件的程序，并将响应输出到" response“属性。这是一个JSON字符串，我们随后将其传递给API以更新记录。
然而，问题是，尽管我们可以成功地写入、读取和处理文件，但Nifi无法理解响应文本中的非英语字符。当我们发回响应时，这会导致名称被破坏。这只适用于我们从程序中收到的JSON字符串。
Nifi正在运行Windows 10环境当我们使用Nifi输出的文件手动运行程序时，我们得到了正确的输出。仅在Nifi中出现问题。
举个例子，输入json是：
{
"player" : "mörk
浏览 2提问于2019-09-11得票数 0
我需要了解ValidateRecord和ConvertRecord处理器在NiFi中的理解和功能。
我的需求
我有一个JSON流文件内容，具有不同的属性，很少字段是强制的，很少是可选的，也很少有字段是时间戳字段，很少是双重类型的。在LOV中有些字段应该有值
我使用了AvroSchemaRegistry和下面的模式定义：
{
"namespace": "nifi",
"name": "test_json",
"type": "record",
"fields&#
浏览 0提问于2018-08-19得票数 0
我有文件从三个不同的来源进入一个"PutHDFS“处理器。这三个源都有单独的键标签，并且将被分离到不同的目录。由于源代码的名称在文件名中，所以我能够创建一个名为"source_name“的变量，我可以使用它来使目录变得很好，如下所示：
/my/hdfs/directory/${source_name}/reports
我想对Kerberos主体和Kerberos Keytab执行类似的操作，如下所示：
Kerberos主体：${source_name}@acme.com
Kerberos Keytab：/home/nifi/Keytab/${source_name}.keyta
浏览 0提问于2019-08-14得票数 0
回答已采纳
使用NiFi 1.7.1 (使用JavaAvro1.8.1)和在AvroSchemaRegistry中，我试图定义一个模式，其中包含顶级的字段name和app.name。根据Avro docs1，我假设我可以像普通"name": "app.name"那样定义全名，但是我点击了错误Illegal character in: app.name。的确，全名的名称部分不允许点，但根据文档：“如果指定的名称包含一个点，则假定它是一个全名.”
然后，我尝试使用命名空间字段。使用以下模式：
{
"type": "record",
浏览 0提问于2018-09-14得票数 1
回答已采纳
我有一个putDatabaseRecord处理器，它接收带有字段名和值的JSON数组。
更新和插入失败，我不明白原因。种源事件中的FlowFile如下所示：
[ {"ID" : 1,"code":1}]
更新失败
Record does not have a value for the PrimaryKey column 'ID'
这是假的，因为我可以在JSON中看到列和值。
插入失败：
Record does not have a value for the Required column 'code'
但再说一次，这是假的！
浏览 2提问于2018-01-09得票数 1
我在NiFi 1.12.0中运行了数据流，此安装的相关属性如下所示：
nifi.sensitive.props.key=
nifi.sensitive.props.key.protected=
nifi.sensitive.props.algorithm=PBEWITHMD5AND256BITAES-CBC-OPENSSL
nifi.sensitive.props.provider=BC
nifi.sensitive.props.additional.keys=
当我将基本版本从1.12.0升级到1.16.3时，我将面临nifi中的迁移问题。它具有以下属性。
nifi.sensitive.pr
浏览 51提问于2022-10-17得票数 0
回答已采纳
现在，我正在使用nifi和它的处理器来处理一些流内容(mqtt侦听器、json求值、文本替换、写入数据库……)。我试图持久化flowfiles，因此我做了一些卷映射(见下文)。但是它不工作；重新启动容器后，似乎流文件没有保存…… 谁能给我一个如何解决这个问题的提示？ nifi:
image: apache/nifi
restart: on-failure
ports:
- "8000:8000"
networks:
- traefik
environment:
- NIFI_WEB_HTTP_PORT=8000
volumes:
- nifi_conf:/op
浏览 96提问于2019-03-25得票数 5
回答已采纳
我有几十个字段，如何轻松地将其转换为nifi属性？
我使用了EvaluateJsonPath，但是需要一个一个地输入值。
我将在菲尼克斯DB中使用这些属性，当我使用ConvertJsontoSQL时，它不工作.
你能帮我解决这个问题吗？
JoltTransformJSON样品含量如下；
{
"AAAA": "AAAA",
"BBBB": "BBBB",
"CCCC": "CCCC",
"DDDD": "DDDD",
"EEEE"
浏览 7提问于2022-11-19得票数 0
回答已采纳
1回答
我用FileBeat发送日志到我的NIFI服务器，我想排除一些字段。
日志是json和.log
这有可能吗？
浏览 2提问于2021-02-03得票数 0
回答已采纳
我正在安装一个带有嵌入式动物园管理员的三节点非安全nifi集群(1.5)。
安装已经完成，集群启动和选举已经完成，没有任何明显的问题。
然而，当我击中gui时，我看到了以下情况：
javax.ws.rs.ProcessingException: java.net.ConnectException:连接拒绝(连接拒绝)
在nifi-apps.log中有：
2018-03-07 14:41:37,857 WARN [Replicate Request Thread-7] o.a.n.c.c.h.r.ThreadPoolRequestReplicator Failed to replicate re
浏览 0提问于2018-03-07得票数 1
回答已采纳
我正在尝试使用NiFi REST在我的NiFi集群中自动化配置部署。我将变量定义为自定义属性文件：nifi.variable.registry.properties=./conf/dbconfig.properties
含量( dbconfig.properties )
dbuser=username
dbpass=password
在配置JSON文件中，我试图将这些变量引用为：
{
"name": "ConnectDB",
"config": {
"properties": {
浏览 0提问于2018-01-11得票数 1
我按照NiFi 1.10 stateless guildeline在mysql中创建了一个执行sql的简单进程组。我已经将db控制器服务的必要参数放到了参数上下文中。 ? ? ? 它在nifi canvas中运行良好。然后将其添加到注册表并准备一个json parm文件:stateless simpledb.json {
"registryUrl": "http://localhost:18080",
"bucketId": "cac8f127-e328-45c1-a4cb-0e03dc837ceb
浏览 76提问于2019-12-14得票数 3
FlowFile规模的考虑因素是什么？它会影响I/O吗?如果提供足够的内存，它是否越大越好？因为每个FlowFile的NIFI都会从磁盘持续到内存？ 特别是对于Kafka Consumer Processor，它包含一个名为Message Demarcator的属性。有了设置，一个FlowFile可以包含多个事件，如果没有它，一个FlowFile只包含一个事件。比方说，如果FlowFile包含1000个json对象，性能会比1个json对象更高吗？ 尤其让我困惑的部分是这个文档https://community.hortonworks.com/questions/21011/how-i-ex
浏览 14提问于2019-01-18得票数 0
回答已采纳
我有一个Nifi Groovy脚本。将字段分配给nifi属性，但如果json值为空，则定义null。如果json值为null，我想要定义属性为空。
空属性如下所示；
我想喜欢这个；
这是我使用的脚本；
import org.apache.commons.io.IOUtils
import java.nio.charset.*
def flowFile = session.get();
if (flowFile == null) {
return;
}
def slurper = new groovy.json.JsonSlurper()
def attrs =
浏览 15提问于2022-11-26得票数 0
回答已采纳
我是apache NiFi的新手。
我正在尝试使用nifi将数据放入elasticsearch中。
我希望通过组合特定的字符串和从时间戳字段转换为日期格式的值来指定索引名。
我能够使用下面的表达式创建所需的形状，但未能使用内容的时间戳字段的值创建索引名。
${now():format('yyyy-MM-dd')}
示例json数据
{
"timestamp" :1625579799000,
"data1": "abcd",
"date2": 12345
}
我想得到以下结果：
index :
浏览 3提问于2021-07-06得票数 0
我有一个json数组，需要写入数据库(作为文本)。
我有两个选择：
写入为对象数组，因此字段将包含{}、{}、{}，将每个记录作为对象写入，因此该字段将包含{}
问题是，nifi不知道如何将json对象映射到PutDatabaseRecord上的特定数据库字段。
我怎么绘制地图？
这是我的流程：
浏览 0提问于2020-07-20得票数 1
2回答
我试图在我的牧场服务器的一个码头上运行Apache。牧场主在跑龙套，因为我有其他的服务在运行。它安装在Debian盒上。
我正在尝试测试官方的Apache容器。由于牧场主的默认端口是8080，所以我尝试在另一个端口上运行它。我试图运行第一个命令，因为它在文档中引用：
docker run --name nifi -p 9090:9090 -d -e NIFI_WEB_HTTP_PORT='9090' apache/nifi:latest
这给了我在标题中提到的错误：
The request contained an invalid host header [xx.xx.xx.x
浏览 2提问于2018-04-10得票数 0
回答已采纳
我能够让Apache NiFi通过CSVReader生成模式，然后我可以使用ConvertRecord将模式写入属性。但是，我需要使用UpdateRecord添加字段，但是这些字段没有添加到flow文件或架构属性中。我认为这是因为字段不是最初推断模式的一部分。我无法在注册表中创建模式，因为它是从文件推断出来的。那么，当模式不包括字段时，如何将字段添加到记录中呢？
浏览 1提问于2018-08-15得票数 3
回答已采纳
我需要了解如何使用json文件更新我的svc配置:我的svc已经启动并运行，但它不是我想要的类型，它是一个集群ip，我想将它更改为入口类型和类型的负载均衡器:下面是服务：
kubectl -n nifitest get svc -o wide
simplenifi-all-node ClusterIP 192.164.115.193 <none> 8080/TCP,6007/TCP,10000/TCP 44h app=nifi,nifi_cr=simplenifi
现在我想部署一个指向入口的服务
那么，tere是一个kubectl命令，类
浏览 2提问于2021-01-29得票数 0
回答已采纳
我正在尝试使用geoEnrichIP处理器作为nifi流的一部分。我试图跟踪文档而没有运气。
我试图将geoEnrichIP处理器附加到convertRecord处理器的末尾。
ConvertRecord(Json) -> geoEnrichIP
在geoEnrichIP的配置中，我为ip地址字段添加了一个属性。字段是Enrich: host_address，但输出中没有任何内容。我不认为我指的是包含IP地址的字段host_address。
如何正确引用host_address的ip地址名以丰富地理位置数据？
谢谢
浏览 7提问于2021-09-22得票数 1
回答已采纳
1回答
在将apache从1.13升级到1.18之后，我开始看到以下错误。此外，我还可以从使用该证书的流中看到webgui上的相同错误。
警告主要的不安全密码提供者算法PBEWITHMD5AND256BITAES-CBC-OPENSSL密码请求org.apache.nifi.deprecation.log.DeprecationException:参考类org.apache.nifi.security.util.crypto.NiFiLegacyCipherProvider ClassLoader [org.apache.nifi.nar.NarClassLoader./work/nar/framew
浏览 14提问于2022-11-03得票数 0
回答已采纳
1回答
从Nifi消费Rest
、、、、
下面是我使用安全rest的nifi工作。
当我运行invokeHttp处理器时，我会得到以下异常：
2017-09-19 07:58:59,744 ERROR [Timer-Driven Process Thread-3] o.a.nifi.processors.standard.InvokeHTTP
java.lang.NullPointerException: null
at org.apache.nifi.processors.standard.InvokeHTTP.setHeaderProperties(InvokeHTTP.java:859) ~[nifi-
浏览 1提问于2017-09-20得票数 1
请指导我使用适当的Nifi处理器组件将字符串转换为json的正确组件。
输入是内容类型为文本/纯文本的字符串。
{ productName : "tv", locationName: " chennai"}
由于作为输入发送的内容类型错误，EvaluateJsonPath的输出仍然与我无法根据json计算json属性相同。
{
productName : "tv",
locationName: " chennai"
}
注意:尝试过SplitText，AttirtubesToJson处理器无法实现所需的转换。
浏览 1提问于2017-08-22得票数 1
回答已采纳
1回答
当涉及到NiFi时，我完全是一个菜鸟-所以请随时强调任何愚蠢/无知。
我正在使用NiFi阅读卡夫卡主题中的消息。
每条消息都包含JSON，该JSON包含一个名为Function的字段，然后是一大堆基于函数的不同字段。例如，如果Function ="Login"，您可以期待用户名和密码字段，但如果Function = "Pay"，您可以期待"From“、"To”和"Amount“字段。
我需要以不同的方式处理每种类型的函数。因此，基本上，我希望从Kafka读取消息，确定函数，然后根据函数将消息路由到适当的规则集。
这听起来应该很简单--但有
浏览 0提问于2020-06-03得票数 0
1回答
我在向nifi发送一个简单的PUT请求时遇到了问题，基本上我想用java代码启动一个nifi处理器。
错误消息-服务器返回的HTTP响应代码: 405用于URL：
我应该采取什么步骤来解决这个405问题？nifi网站提供了关于rest的高级文档，但是没有关于如何使用Java向NiFi发出适当的PUT请求的指南。
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import jav
浏览 0提问于2018-08-21得票数 0
回答已采纳
1回答
我运行的是Solr5.4.1和Nutch1.11，我也在使用Apache Nifi，特别是GetSolr处理器。
我知道我的SolrRecord中的tstamp是获取索引值的时间。
我面临的挑战是让GetSolr进程在NiFi中以无人参与的方式工作，我需要提供一个日期字段来进行筛选。如果我使用tstamp，它只会在第一次填充我的数据流，之后tstamp筛选器会排除未来的值，因为它查看的是索引时间，而不是记录被摄取到Solr中的时间。
所以我的问题是:我如何在我的SolrRecord中包含一个字段，它将包含插入到Solr中的时间戳，而不是爬虫获取的时间戳。
浏览 2提问于2016-02-10得票数 0
在这个表单中有一个json对象。
{
"email" : "test@gmail.com",
"name" : "somename",
"age" : "someage"
.
.
.
}
我想把上面的json翻译成
[{
"key" : "email",
"value": "test@gmail.com"
},
{
"key" : "name",
浏览 0提问于2018-05-04得票数 0
回答已采纳
1回答
我有一个Json文件，不断更新新的项目。使用Nifi，我想创建一个从这个Json文件中提取内容的流，然后创建一个输出文件，例如CSV，这样我就可以用它在Excel中做一些分析。我是Nifi的新手，所以您能为这个事件提供一些流程流程吗？任何能让我开始的事都会很有帮助。
浏览 2提问于2016-03-15得票数 0
我在获得executeScript nifi进程的javascript脚本时遇到了问题，希望能在这方面提供帮助。目标是传递一个包含json对象的流文件。我需要在不事先知道内容/字段的情况下解析这个json，并将其传递给正在传递给下一个进程(即MergeContent )的流文件，并对数字流文件进行计数。尝试测试脚本，得到以下错误：
nifi.script.ExecuteScript - ExecuteScript[id=bd6842e9-e3a4-4d88-a59d-
7da1d74d109b] ExecuteScript[id=bd6842e9-e3a4-4d88-a59d-7da1d
浏览 0提问于2018-08-13得票数 1
回答已采纳
我试图使用表达式语言在Nifi getMongo查询字段中使用以下查询生成ISO字符串，
{
"remindmeDate": {
"$gte": "${now():format("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'",'GMT')}",
"$lte": "${now():toNumber():plus(359999):format("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'"
浏览 9提问于2017-06-15得票数 2
回答已采纳
1回答
正在尝试将csv制表符分隔的文件转换为CSV文件为UTF-16的JSON。
所有字段都是CSV和JSON格式的字符串。
在NiFi中使用SplitRecord处理器。处理器运行时没有任何错误，但转换为JSON的数据值如下所示
"\u0000R\u0000e\u0000t\u0000a\u0000i\u0000l.......“
我应该提一下，这是avro模式中的UTF-16吗？如果是这样，我该怎么做呢？
这同样适用于UTF-8文件，但不适用于UTF-16文件。
更新:在阅读器中找不到字符集属性。
使用HDF版本3.0.1.1。图片如下：
浏览 3提问于2018-01-30得票数 1
3回答
我有一个合并了所有记录的json，我需要拆分合并后的json并使用NiFi加载到单独的数据库中
我执行时的文件
db.collection.findOne()
我的输入如下所示：
[
{
"name": "sai",
"id": 101,
"company": "adsdr"
},
{
"name": "siva",
"id": 102,
"company": "shar"
浏览 5提问于2016-10-27得票数 1
1回答
您好，我有一个Nifi docker容器停止，我想更新一个属性文件。
每当我更新一个字段时，当我运行docker-compose start时，它不会更新属性文件。
这怎么可能呢？
这是我的docker构图：
version: "3.3"
services:
nifi:
image: apache/nifi
volumes:
- /home/ubuntu/nifi/conf:/opt/nifi/nifi-current/conf
ports:
- "8080:8080"
谢谢
浏览 0提问于2019-09-10得票数 1
我有这样的JSON有效负载； {
"id": "",
"name": "",
"A": {...},
"B": {...},
"C": {...}
} 我想要提取A, B and C字段与id and name字段作为不同的记录。像这样； {
"id": "",
"name": "",
"A": {...}
}
{
浏览 62提问于2019-03-15得票数 2
我在nifi之后安装Java。在nifi属性中，我使用实例的私有IP编辑nifi.web.https.host字段。我启动了Nifi。我看了看出现的日志。我把公网IP放在browser.And里，出现了这个错误信息。 ?
浏览 13提问于2021-09-17得票数 0
我有一个Nifi流，在Json中有多行数据，对于每个行，需要执行以下操作：
拆分数据(EvaluateJsonPath)并将相关字段插入数据库(Mysql)，将表A的字段取为表A，并将它们放入DB中。此操作的返回值是表A中自动生成的ID。从表插入获取返回值，并与表B字段合并。表A的返回值成为表B中的引用值，因此分隔行条目成为链接。
我已经设置了flow (见图)，但是MergeContent处理器失败了，因为我认为它不知道如何正确地合并内容。如果我有200行，它只合并一行，其余的就失败了。我在Nifi中读过关于碎片整理的文章，但是没有成功地实现它，所以非常感谢您的任何输入。
流程图：
浏览 7提问于2019-11-15得票数 1
我尝试用Nifi更新Oracle数据库中的一些DB列。
我有这么一部分的电路：
我对上一次PutDatabaserecord有意见
nifi_ml_nifi.1.rb4f8g690fro@KoshDomain | 2021-07-12 17:34:20,919 ERROR [Timer-Driven Process Thread-2] o.a.n.p.standard.PutDatabaseRecord PutDatabaseRecord[id=017a10b4-fe2c-1b89-f752-67545ebb8406] Failed to put Records to data
浏览 4提问于2021-07-12得票数 0
回答已采纳
我在Nifi中收到了一个工作流，它将日志从IBM-MQ转换为JSON格式，并将信息放入Oracle数据库。每个日志行都是使用ExtractGrok解析的，在给我提供工作流的人执行的原始解析中，获得的格式如下：‘yyyy-MM-ddh.mm.ss’，而实际上解析忽略了其他字符(可能是时间戳格式)。PutSQL处理器得到了标题中的错误(APACHE NIFI error message:'dd/MM/yyyy hh:mm:ss'，它不能转换成时间戳)，不管我如何解析时间部分，我已经用JOLT以各种方式做到了这一点(图片包含3个例子)。我如何让Nifi放入Oracle中的时间字段?
浏览 69提问于2020-08-06得票数 1
回答已采纳
1回答
我希望使我的nifi数据卷和配置保持不变，这意味着即使我再次删除容器和docker compose up，我也希望在docker compose up中保留到目前为止构建的内容。我尝试按下面的方式挂载卷，如在批量部分中的中所示，但是它不能工作，而且我的nifi处理器也没有保存。我如何才能正确地做这件事？在我的docker-compose.yaml文件下面。
version: "3.7"
services:
nifi:
image: koroslak/nifi:latest
container_name: nifi
restart: always
浏览 5提问于2022-07-23得票数 0
1回答
我正试图在两个Nifi服务器之间创建一个站点到站点连接。Nifi1 (Hostname wef2 -在windows上运行)需要将流量传递给nifi2 (IP 10.168.233.168 -运行在linux上)-我定义了连接，所有都是绿色的，但是在Nifi1上我得到了以下错误消息
*端口ID 0176100c-8d25-196b-1f72-6befa5cab12a是NIFI2的输入端口。
**2020-12-01 01:54:13,508 INFO [pool-12-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully c
浏览 1提问于2020-12-01得票数 0
我开始使用Apache Nifi，并且我有几个具有不同结构的XML文件来提取字段，然后调用一些API，在转换为JSON和POST之后使用不同的API进行丰富。 有没有关于使用哪些组件的参考资料？
浏览 116提问于2021-08-13得票数 0
回答已采纳
我很难找到任何示例，说明如何在putMongo NiFi处理器中使用upsert (或进行更新)功能。
如果有人能给我一个例子，然后我可以根据自己的需要量身定做，我将不胜感激。
具体来说，给定一个包含单个JSON文档的流文件，从文档中提取一个值，对该值进行过滤，然后使用文档中其他可用属性和字段的子集进行向上处理。
我想要做的是类似于SQL合并，其中插入可以遵循一条路径，而更新可以遵循另一条路径，但我认为功能不允许这样做。
谢谢
浏览 0提问于2019-05-28得票数 0
1回答
我正在使用JSON1.11.4构建一个数据管道，其中IoT设备以NiFi格式发送数据。每次从IoT设备接收数据时，我都会收到两个JSON；
JSON_INITIAL
{
devId: "abc",
devValue: "TWOINITIALCHARS23",
}
和JSON_FINAL
{
devId: "abc",
devValue: "TWOINITIALCHARS45",
}
有几毫秒的时间差，我用来接收这两个流文件。在我的用例中，我需要以这样的方式合并这个JSON，我得到的JSON如下所示(请注意在
浏览 6提问于2020-08-05得票数 0
我正在配置KNOX以保护NiFi，遵循此，并在请求证书时遇到错误，令牌不满足16字节的最小大小。
root@hadoop:/home/knox# /home/hadoop/nifi/config/nifi-toolkit/bin/tls-toolkit.sh client --subjectAlternativeNames "CN=hostname.org, OU=KNOX" -F -f /home/knox/nifi-ca-config.json
2019/09/25 14:14:17 INFO [main] org.apache.nifi.toolkit.tls.servi
浏览 6提问于2019-09-25得票数 0
我正试图在一个NiFi上安装VitrualBox：
当我运行“/op/nifi-1.0.0/bin/nifi.shstart”时，我从bootstrap.comf文件中得到一个错误:不支持的major.minor版本52.0
浏览 2提问于2016-10-09得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
