腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(644)
视频
沙龙
1
回答
LookupRecord
中
的
Nifi
RestLookupService
提供
JsonParseException
、
、
、
、
我有一个带有一个GenerateFlowFile处理器和一个带有
RestLookupService
的
LookupRecord
处理器
的
基本
NIFI
流。GenerateFlowFile是用simple JSON配置
的
?
LookupRecord
被配置为从JSON中提取密钥并将其填充到
RestLookupService
。关于意外字符'<‘,
RestLookupService
本身会以
JsonParseExcept
浏览 49
提问于2020-10-30
得票数 2
1
回答
面向记录
的
InvokeHTTP处理器
lagtitude,gis34.095028,-118.306625,"34.095028,-118.306625"34.095028,-118.306625,"34.095028,-118.306625"
浏览 1
提问于2019-04-01
得票数 2
1
回答
使用两个不同
的
CSVs连接多列
的
NiFi
-
LookupRecord
处理器配置失败
、
我试图加入两个不同
的
CSV
的
事情,其中有一个共同
的
专栏如下。(
LookupRecord
.java:395) ... 18 common frames omitted更新CSVRecordWriter
浏览 17
提问于2020-07-15
得票数 1
回答已采纳
1
回答
一次从多个表读取数据,并使用
Nifi
组合基于where子句
的
数据
我有一个场景,需要提取多个数据库表数据,包括模式,并将它们组合(组合数据),然后写入xl文件?
浏览 4
提问于2020-04-17
得票数 0
回答已采纳
1
回答
从多个表
中
增量加载
Nifi
中
的
联接查询
、
对于增量负载,我们将使用QueryDatabaseTable处理器,它从一个表
中
增量地提取数据。为了编写从多个表中提取数据
的
sql查询,我们使用ExecuteSQL处理器。如何提取连接查询
的
增量负载?
浏览 8
提问于2021-12-10
得票数 0
1
回答
NiFi
调用REST接口后,如何获取splitjson(每条记录)
的
响应
我有以下调用rest API
的
序列。用于post数据创建)->InvokeHTTP->XPATH processor for attribute-> splitjson在调用http processor和create payload后生成
的
原始流程文件在这里,我调用rest API,在拆分大型json之后,我使用文本替换来调用另一个api(POST请求),该api使用来自第一个调用处理器
的
原始有效负载
的
属性。在创建了使用xpath表达式属性
的
第二个invoke http响应
的</
浏览 8
提问于2019-07-08
得票数 0
1
回答
Nifi
-无法在
LookupRecord
中找到架构
在Apache
NiFi
中
,无法配置数据库架构。我正在尝试使用
LookupRecord
在PostgesSQL
中
查找记录。但无法指定架构名称,因为没有这样
的
选项。默认情况下,它在公共模式中进行查找。
浏览 23
提问于2020-10-17
得票数 0
1
回答
在
Nifi
DistributedCache
中
执行查找
我在
nifi
中
配置一个样例查找,在其中我使用PutDistributedMapCache在distributedcache中放置一个示例记录。现在,我已经配置了一个Lookup record processor,它读取一个示例json,并在分布式缓存
中
查找两个属性并填充一个字段。缓存条目标识符:${id_store},${id_product}
LookupRecord
配置 生成流文件,该文件转到putcache: 生成用于查找
的
流文件:
浏览 1
提问于2019-08-27
得票数 0
1
回答
使用apache-
nifi
将两个流文件合并为一个流
、
、
、
我有以下使用apache-
nifi
的
场景id,name2,nalakaFlowfile2:1,sachith@email.com合并这两个flowfile后,结果应该是:1,sachith,sachith@email.com3,muha, 这里最重要
的
部分是,3,muha,行应该是email字段为空
的
。我引用了,它与我
的
问题非常相似。而不是为
浏览 6
提问于2019-12-03
得票数 0
1
回答
如何使用
LookUpRecord
处理器?
、
我尝试加入两个基于id
的
csv文件,涉及下面的引用。 现在我有两个csv文件。GetFile-SplitText-ExtractText-
LookUpRecord
-PutFileRecordReader = "CSVReader"LookUpService="SimpleCSVFileLookUpServic
浏览 1
提问于2017-07-07
得票数 1
回答已采纳
1
回答
多个字段
的
NiFi
LookupRecord
如果一些属性(例如,Emp_number、Manager_id、associate_num)
的
值与查找文件
中
可用
的
值列表(例如,csv查找文件
中
的
列名ID )匹配,则我要求从源文件
中
筛选记录。为此,我使用了
NiFi
LookupRecord
processor (1.5版)。在查找处理器
中
添加了动态属性"key“,并将记录路径值指定为/Emp_number。它工作得很好。但是如果我添加额外
的
动态属
浏览 54
提问于2019-08-22
得票数 3
回答已采纳
1
回答
如何为存储在
Nifi
的
PutFile处理器
中
的
图像命名?要分配
的
名称和图像出现在不同
的
流文件
中
、
InvokeHTTP命中所需
的
URL,我知道我们可以添加filename属性到更新属性处理器,以便在put文件
中
为图像/文件命名,但在我
的
例子
中
,让我们将文件名以变量
的
形式来自不同
的
处理器(这里是GenerateFlowFile),该变量被传递到UpdateAttribute处理器
中
。问题是它将图像和文件名放在不同
的
队列
中
,而我想要放在一个队列
中
。这里
浏览 6
提问于2018-06-21
得票数 0
2
回答
如何避免
NiFi
中
的
流文件失败记录?
我有一个json文件,几乎有500.000记录,其中有一些是糟糕
的
分析或双引号在错误
的
地方。问题是,当我试图UpdateRecord出现一个警告显示哪些是故障记录,但我不能加载任何其他有效
的
记录。我
的
记录
中
失败
的
例子: 2020-10-06 01:47:23,471 ERROR org.apache.
nifi
.processors.standard.UpdateRecord: UpdateRecordjava.io.BufferedInputStream@35fab6f
浏览 5
提问于2020-10-06
得票数 1
1
回答
NiFi
-获取要作为外键插入
的
记录ID
、
我有一个具有name、age和role列
的
表用户
的
数据源。现在,我需要用它创建两个表,并将它们放入新
的
DB
中
。表是user和role。因此,首先,我将数据转储到user表
中
,对于role列,我需要插入到role表
中
,并将该ID放入user表
的
role列
中
。我得对每一张唱片都做同样
的
事。检查角色记录是否已经存在,如果是返回ID或创建新记录并返回插入
的
ID。admin John,27,user
浏览 0
提问于2020-10-05
得票数 0
1
回答
如何从openid连接
提供
商加载用户和用户组信息和政治信息?
我已经将
nifi
配置为通过openid连接(Clicl cloack)
提供
程序进行身份验证,我想知道如何配置
nifi
来加载openid
提供
程序
中
定义
的
组信息和策略?如果
nifi
支持此功能,我只能在文档中看到
nifi
可以使用ldap或kerberos身份验证
提供
程序加载。
浏览 0
提问于2018-03-20
得票数 0
回答已采纳
1
回答
使用Apache
的
LDAP身份验证无效
、
、
、
我正试图在我
的
VM上获得我
的
Nifi
独立实例,该实例位于我公司
的
网络
中
,使用登录标识-Providers.xml
中
的
ldap
提供
程序进行身份验证。如果是这样的话,我是否需要手动为每个希望访问
Nifi
的
客户端创建这些证书。我认为LDAP证书足以让一个人对
Nifi
进行身份验证。请告诉我如何获得CA
的
信任库,服务器和客户证书
的
员工使用
Nifi
通过LDA
浏览 4
提问于2016-09-08
得票数 2
回答已采纳
1
回答
为库存
nifi
处理器创建自定义DistributedMapCacheClient控制器服务
、
、
、
我能够让等待和PutDistributedMapCache看到我
的
定制服务,但是处理器无法启动,因为
nifi
说我
的
nar“与AtomicDistributedMapCacheClient不兼容”。DistributedMapCacheClientServices (如CouchbaseMapCacheClient或RedisDistributedMapCacheClient)
中
的
任何一个,我就不会有任何问题我很感谢你
的
帮助。下面是我
的
项目设置及其依赖关系: my-<
浏览 0
提问于2020-01-24
得票数 2
1
回答
Nifi
自定义处理器异常
我使用
的
是
Nifi
0.4.1版本。正在编写自定义代码以将CSV转换为avro格式。我已经创建了类文件,并能够生成nar文件。将nar文件放入lib目录并重新启动
nifi
服务器。当在
nifi
工作区拖动处理器时,无法看到为将csv转换为avro而创建
的
类。谢谢,
浏览 4
提问于2016-02-25
得票数 3
1
回答
如何创建自定义
的
JSON解析异常映射?
、
、
、
、
我使用
的
是jersey-media- JSON -jackson-2.27,它有内部
的
jackson.jaxrs.base,其中JsonParseExceptionMapper是用来在收到无法解析
的
JSON
的
情况下发送一个“400Bad Request”。我已经创建了自己
的
自定义异常映射器。
中
。,当我发送无效
的
JSON时,它仍然使用内置
的
JsonParseExceptionMapper,你有什么想法可以尝试一下吗?
浏览 4
提问于2019-01-31
得票数 2
1
回答
使用
Nifi
注册表和Docker版本控制和持久化
Nifi
流文件
、
、
目前,我正在玩最新
的
稳定版本
Nifi
/
Nifi
-注册表和码头。我正在尝试在Gitlab
中
对流文件进行版本和持久化。我在网上找到了几个信息,但现在它不起作用了。所有组件都正常工作,我也可以将文件从
Nifi
版本转换到
Nifi
,但是Gitlab
的
最后一步目前还没有完成。->我修改了providers.xml并将其安装到容器
中
<class>org.apache.<
浏览 3
提问于2020-03-17
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache NiFi介绍及使用体验
大数据流处理:Flume、Kafka和NiFi对比
Apache NiFi用户指南-数据流的命令和控制
Edge2AI自动驾驶汽车教程
程序员需要关注的十个大数据技术
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券