Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Apache NiFi ExecuteScript:通过映射文件替换 Json 值的 Groovy 脚本
我正在 Groovy 脚本上使用 Apache NiFi 0 5 1 以将传入的 Json 值替换为映射文件中包含的值 映射文件如下所示 它是一个简单的 txt Header1 Header2 Header3 A some text A2
json
Groovy
apachenifi
NiFi 如何将 InvokeHTTP 处理器与 SOAP 结合使用
我看到其他人已经能够使其发挥作用 但是我无法找到足够的详细信息来解释他们如何实现这一目标 以便我能够使其发挥作用 This guy http apache nifi developer list 39713 n7 nabble com SO
soap
soapui
apachenifi
在nifi中将JSON转换为CSV
我想在 nifi 中将 JSON 文件转换为 CSV 我们可以用 Python 和其他编程语言来实现这一点 并且有多篇文章介绍它 我有多个 JSON 文件 每个文件都有不同的架构 一个特定文件只有一个架构 我可以看到有一些模板可以将 CSV
json
csv
apachenifi
hortonworksdataflow
nifi invokehttp post复杂的json
我尝试在 Apache NiFi 中使用 InvokeHttpProcessor 来执行具有复杂 JSON 正文的 POST 请求 因此本教程 http www tomaszezula com 2016 10 30 nifi and htt
json
REST
googleanalytics
googleanalyticsapi
apachenifi
NiFi:ExtractText 中的正则表达式获取 CSV 标头而不是数据
我正在开发一个获取 CSV 文件的流程 我想根据 CSV 记录中的第一个字段将记录放入不同的目录中 例如 CSV 文件看起来像这样 country firstname lastname ssn mob num US xxxx xxxxx x
csv
apachenifi
Apache NIFI Jon 不会自动终止
我是 Apache NIFI 工具的新手 我正在尝试从 mongo db 导入数据并将该数据放入 HDFS 中 我创建了 2 个处理器 第一个用于 MongoDB 第二个用于 HDFS 并且我正确配置了它们 该作业正在成功运行并将数据存储到
apachenifi
NiFi:ReplaceTextWithMapping 处理器
我有以下插入语句 insert into temp1 values test1 test2 insert into temp2 values test3 预期成绩 insert into temp1 values 100 200 inser
regex
apachenifi
Apache NiFi 用于将数据从 RDMBS 导入到 HDFS - 与 SQOOP 的性能比较
我们正在探索 Apache NiFi 作为满足我们企业需求的通用数据摄取工具 一种典型的数据摄取要求是从 RDBMS 移动数据 系统到 HDFS 我能够使用 NiFi 提供的GenerateTableFetch 和 ExecuteSQL 处
apachenifi
nifi 中的 JSON 数组到多个 JSON 对象
我想在 Nifi 中实现以下请求响应场景 我的目标是在更多不同的处理器中使用每个值作为数组 对象键 1 对象键 2 因此 如果我可以将其转换为多个 JSON 那么使用拆分 JSON 我可以稍后使用多个值 请为此提出各种解决方案 输入 JSO
apachenifi
Nifi DistributedCache查找问题
我配置了一个流程如下 GetFile SplitText gt 分割成流文件 ExtractText gt 使用两个键添加属性 PutDistributedMapCache gt 缓存条目标识符是 Key1 Key2 现在我配置了一个示例G
apachenifi
有没有办法更改 Nifi 中 PublishJMS 处理器的交付模式?
我使用 Nifi PublishJMS 处理器向 IBM MQ 发送消息 消息在 MQ 中具有持久性 持久性 我想将其更改为非持久性 Nifi PublishJms 处理器中是否有属性可以纠正此问题 或者是从MQ端完成的 我无权访问 MQ
JMS
ibmmq
apachenifi
Apache NiFi - OutOfMemory 错误:SplitText 处理器上超出了 GC 开销限制
我正在尝试使用 NiFi 使用 HDF 1 2 处理大型 CSV 文件 每个文件可能有数十亿条记录 我已经实现了我的流程 对于小文件来说一切正常 问题是 如果我尝试将文件大小增加到 100MB 1M 记录 我会得到一个java lang O
Apache Nifi:使用更新记录处理器替换列中的值
我有一个 csv 看起来像这样 name code age Himsara 9877 12 John 9437721 16 Razor 232 45 我必须更换色谱柱code根据一些正则表达式 我的逻辑如下面的 Scala 代码所示 if
csv
replace
apachenifi
自动化 NIFI 模板部署
我是 nifi 的新手 我试图了解 因为它看起来很多基于 GUI 是否有一种方法可以在 Nifi 上自动扩展和缩减 以及如何采用 xml Nifi 模板并将其部署到集群 本质上 我们想做的是使用 Nifi 从 kafka 服务器收集 JMX
apachenifi
在 NiFi 处理器“InvokeHTTP”中,您在哪里编写 POST 请求的正文?
在发布有关 Apache NiFi InvokeHTTP 的问题之前 我已经浏览了所有其他问题及其答案 但我仍然不确定我应该拥有的最佳流程 我的情况如下 1 从 Apache Kafka 我获取原始元数据 2 使用EvaluateJSONP
apachenifi
如何使用 NiFi 将字符串转换为 JSON 数组
在 NiFi 中 我正在处理包含以下属性的流文件 Key my array Value u firstElement u secondElement 我想在此数组上拆分 flowFile 以单独处理每个元素 然后合并 我尝试使用SplitJ
apachenifi
apacheminifi
在我的流程中了解 NIFI 中的通知和等待流程
我是 NIFI 流程的新手 在我当前的工作中 我有通知和等待流程 有人可以帮助我理解这个流程吗 On what basis the Notify work in my case we have 4 schema files process
apachenifi
有 JOLT 文档吗? &、@等运算符的含义是什么? (NiFi、JoltTransformJSON)
是的 有 我提出这个问题是为了分享我的知识 问答风格 因为我自己很难找到它 谢谢https stackoverflow com a 67821482 1561441 https stackoverflow com a 67821482 15
json
apachenifi
jolt
列的类型为没有时区的时间戳,但表达式的类型为字符变化:Nifi
我正在尝试使用 nifi 将 CSV 记录插入 Postgres 数据库 示例 csv 文件 timenow location 2019 10 21 15 13 11 colombo nifi场景运行时 出现以下错误 错误列 timenow
csv
timestamp
apachenifi
timescaledb
Apache NiFi:使用映射值将列添加到 csv
使用 GetFile 处理器将 csv 导入 NiFi 工作流程 我有一列由 id 组成 每个id代表一个特定的字符串 大约有3个id 例如 如果我的 csv 包含 name age id John 10 Y Jake 55 N Finn
apachenifi
dataprocessing
1
2
3
4
»