7得票1回答
Apache NiFi:将JSON转换为SQL(Oracle数据库)

我可以帮您将JSON字符串转换为SQL语句,使用ConvertJSONtoSQL处理器。 例如:JSON字符串 - {"cpuwait":"0.0","servernamee":"mywindows","cpusys":"5.3","cpuidle":"77.6","datee":"29-...

7得票1回答
使用Nifi配置HTTP POST请求

我将尝试为您进行翻译,请查看以下内容: 我正在尝试从REST客户端访问WCF服务。我正在向WCF服务发送POST请求。以下是详细信息供参考。 服务契约定义如下: [ServiceContract] public interface IBZTsoftsensor_WcfService { ...

7得票1回答
Nifi“PutSQL”的越界异常。

我正在尝试使用“PutSQL”处理器来实现这一点。 我使用“ReplaceText”修改流文件并创建一个INSERT语句。我已经在MySQL数据库中测试了该语句,并且该语句有效。 以下是该语句: INSERT INTO monitor.security_nifi (RemoteI...

7得票3回答
Apache NiFi支持版本控制吗?

我正在尝试探索Apache NiFi。目前还没有看到任何版本控制流程的方法。 在多个用户尝试在同一实例中开发时,是否有一种版本控制流程的方式? 多个用户的代码合并如何处理? 在这些方面提供任何帮助将帮助我继续探索。

7得票1回答
NiFi:从文件中删除固定数量的头部行

我正在处理一个文件,希望删除(修剪)前 X 行头部信息,只保留数据,可以避免使用正则表达式。 谢谢。

7得票1回答
如何在Apache NiFi中捕获公告信息

我想知道是否有一种方法可以捕获出现在Nifi UI上的公告消息(基本上是错误),并将其存储在某个属性/文件中,以便以后查看。屏幕每5分钟刷新一次,如果任何处理器失败,我都想知道失败原因。我这里并不特别谈论日志记录部分。

7得票2回答
在Apache NiFi中获取失败原因

我希望记录一些NiFi处理器的故障原因,但我发现它可能有多种原因。 例如SplitAvroJson处理器: "如果FlowFile由于任何原因(例如,FlowFile不是有效的Avro)未能成功处理,它将被路由到此关系" 是否有可能得到我的失败的确切原因,以便将其保存在例如放置文件中? ...

7得票1回答
Apache NiFi处理器中数据溯源的目的是什么?

每个处理器都有一种配置处理器的方法,同时还有一个上下文菜单用于查看数据来源。 是否有一个很好的解释来说明什么是数据来源?

7得票3回答
NiFi - 如何在ExecuteStreamCommand中引用flowFile?

我需要执行类似以下命令的操作: sed '1d' simple.tsv > noHeader.tsv 这将从我的大型流文件(> 1 GB)中删除第一行。 问题是 - 我需要在我的流文件上执行它,所以应该是: sed '1d' myFlowFile > myFlowFile 问题是:我应该...

7得票2回答
Apache Nifi - 从Avro中提取属性

我正在努力理解如何从Avro和JSON中提取属性。我可以使用EvaluateJsonPath处理器从JSON中提取属性。我尝试在Avro上执行相同的操作,但我不确定是否可行。 这是我的流程:ExecuteSQL -> SplitAvro -> UpdateAttribute U...