Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何清除NiFi队列?
我们正在 NiFi 中创建一些流 在某些情况下可能会建立队列 但由于某种原因 流无法按预期工作 在一天结束时 我想清除队列并以某种方式实现自动化 问题是我们如何从后端删除队列 我们有什么办法可以实现这一目标吗 除了 Bryan 提到的明确的
Queue
apachenifi
如何在Nifi getMongo查询字段中获取ISO字符串
我正在尝试使用表达式语言使用以下查询在 Nifi getMongo 查询字段中生成 ISO 字符串 remindmeDate gte now format yyyy MM dd T HH mm ss SSS Z GMT lte now to
MongoDB
EL
apachenifi
Nifi 无法使用 POI API 将 CSV 转换为 Excel
我想使用 groovy 脚本 POI API 将 csv 流文件内容转换为 XLS 文件 我正在使用 ivy 来获取 POI 依赖项 看起来效果很好 请在下面找到更多详细信息 这是我的 Nifi 流程 这是我的脚本 Grapes Grab
Java
Groovy
apachepoi
apachenifi
groovygrape
如何使用wait\notify处理器?
我正在运行 nifi 实例 1 2 0 我只是尝试使用 Wait Notify 处理器并参考以下内容http ijokarumawak github io nifi 2017 02 02 nifi notify batch why merg
apachenifi
无法获取连接,池错误 在 PutSQL 中等待空闲对象超时?
我已将 PutSQL 处理器的并发任务增加到 10 此时它显示以下错误 但没有数据丢失 failed to process due to org apache nifi processor exception ProcessExceptio
apachenifi
动态 Jolt 规范用于处理 JSON 内的嵌套数组是否具有单个元素、多个元素或嵌套数组不存在
动态 Jolt 规范用于处理 JSON 内的子数组是否包含单个元素 多个元素或子数组不存在 如果我们在 JSON 中嵌套数组有多个元素 那么我的 jolt 规范工作得很好 但是如果他们发送没有嵌套数组或有 1 个元素的嵌套数组的 JSON
json
apachenifi
jolt
Nifi 中并行和顺序处理的等待通知
我有一个要求 我需要并行执行 4 个作业 并且当在所有 4 个处理器中并行完成相同的项目作业时 然后触发下一个处理器 为此我使用了等待通知 流程就像 4个并行作业 gt notify 释放信号标识符 itemid 信号计数器名称 proce
apachenifi
apacheminifi
如何在“ExecuteGroovyScript”处理器中使用“DBCPConnectionPoolLookup”?
我想在 ExecuteGroovyScript 处理器中使用 DBCPConnectionPoolLookup 控制器服务 我设置 数据库名称 但我收到这个错误 这是 ExecuteGroovyScript 配置 I found someo
Groovy
apachenifi
删除NiFi中的空属性
因为这个问题仍未解决 我有一个EvaluateJsonPath有时输出带有空字符串的属性的处理器 是否有直接的方法从流程文件中删除属性 我尝试使用UpdateAttributes处理器 但它只能根据匹配属性名称进行删除 我需要匹配属性的值
apachenifi
Nifi PutSQL Timestamp/Datetime错误无法转换错误
我尝试了建议的解决方案 通过使用 UpdateAttribute 处理器来消除时间戳格式转换错误 即 将JSON转换为SQL gt UpdateAttribute gt PutSQL 在 UpdateAttribute 中我使用了 Prop
mysql
apachenifi
updateattribute
PutSql - 日期格式错误
我正在尝试从 Teradata 读取数据并将其填充到 Oracle 数据库 请在下面找到我的流程 ExecuteSQL gt SplitAvro gt ConvertAvroToJSON gt ConvertJSONToSQL gt Put
apachenifi
Nifi:nifi 中的线程
我想知道线程在 nifi 中如何工作 我的意思是一个处理器有一个线程还是它们在一个主线程中 也许我想从处理器获取一个文件 然后我想更新它 如何防止多个处理器同时获取文件数据 除了使用 keep file false 操作 是否可以在执行脚本
Java
Multithreading
Groovy
apachenifi
如何将nif流文件从1.12版本迁移到1.16.3
我有一个在 NiFi 1 12 0 中运行的数据流 此安装的相关属性如下 nifi sensitive props key nifi sensitive props key protected nifi sensitive props al
Java
Migration
apachenifi
apachenifitoolkit
在 Nifi 中从 Avro Schema 创建 Postgresql 表
使用 InferAvroSchema 我获得了文件的 Avro 架构 我想使用此 Avro 架构在 PostregSql 中创建一个表 我必须使用哪个处理器 我使用 GetFile gt InferAvroSchema gt 我想从此架构创
json
postgresql
Avro
apachenifi
如何使用ExecuteScript(以python作为脚本引擎)进行数字加法练习? 【尝试学习NiFi的新手用户】
我对 NiFi 比较陌生 不知道如何正确执行以下操作 我想用ExecuteScript处理器 脚本引擎 python 执行以下操作 请仅在 python 中 1 有一个包含以下信息的CSV文件 第一行是标题 first second thi
apachenifi
dataflow
使用 nifi 使用 invokehttp 将多个文件发布到 API
我有 3 个文件需要发布到 API 端 我正在使用 FetchHDFS 进程获取 3 个文件 我想将它们传递给 API 我怎样才能通过他们 Input 3 files in HDFS Content Type multipart form
API
apachenifi
如何将流文件传递给执行Python脚本并使用属性和Nifi变量来存储该文件?
我是 NiFi 和 Python 的新手 我需要您的帮助将流文件属性值传递给脚本 该脚本正在将嵌套的 json 转换为 csv 当我在本地运行该脚本时 它可以工作 如何将 FlowFile 名称传递给 src json 和 tgt csv
python
json
csv
apachenifi
PublishJMS 处理器无法将消息写入 IBM Websphere MQ
我在通过 PublishJMS 处理器将消息发布到 IBM Websphere MQ 队列时遇到问题 配置PublishJMS处理器和JMS控制器服务 我已经验证MQ连接没有问题 我相信我需要在 PublishJMS 或控制器服务中设置一些
JMS
ibmmq
apachenifi
如何在 Jython 中使用修改后的数据更新行?
我有一个 csv 文件 其中包含数十万行 下面是一些示例行 1 Ni 23 28 02 2015 12 22 33 2212 02 2 Fi 21 28 02 2015 12 22 34 3212 02 3 Us 33 30 03 2015
python
csv
Jython
apachenifi
将 NiFi 中同一列中的字符串值替换为整数值
我想更换一个 字符串值 并将该值输入为整数值使用 Nifi ReplaceText 我不知道如何在 NiFi 中实现这一点 所以我的场景如下 我将有一个 CSV 文件 其中包含几个带有整数的字段和几个作为字符串总值的字段 对于具有字符串值的
apache
amazons3
apachenifi
«
1
2
3
4
»