nifi中替换文本处理器中的PUTSQL with insert语句出错，

文章/答案/技术大牛

发布

1回答

使用NiFi将JSON转换为SQL并在DB2中插入数据。

json、apache-nifi

我需要使用JSON数据(键-值对)生成SQL insert语句，并执行INSERT SQL语句以写入DB2。我在NiFi中使用处理器ConvertJSONtoSQL和PutSQL。我的PutSQL抛出错误。 PutSQL配置： ? 我得到这样的输出流文件。 INSERT INTO TEST_TABLE (COL1, COL2, COL3) VALUES (

浏览 162提问于2020-12-03得票数 0

2回答

apache-nifi

在nifi中的替换文本处理器中使用PUTSQL语句时出现错误，并在“routing to failure: com.microsoft.sqlserver.jdbc.SQLServerException: putSQL 4 is out of range”中显示以下错误。

浏览 3提问于2017-02-10得票数 2

1回答

executeSql在putSql处理器后失败

mysql、apache-nifi

所以我的nifi处理器基本上是这样的： executeSQL(数据集查询集) >>> convertAvrotoJson >>>> convetJSONtoSQL(转换为insert语句) >>>>putSQL (insert语句) >>> executeSQL(删除与一组表中的第一个处理器查询相

浏览 1提问于2019-02-17得票数 1

回答已采纳

1回答

带有NiFi处理器的PutSQL中的错误日志记录

logging、apache-nifi

当管道中的my_logging_table Put处理器失败时，我希望将NiFi行作为日志插入。到目前为止，我不得不为创建另一个日志-处理器--每个管道处理器，它具有以下sql-statement('Failed-NiFi-processor-name', 'failed', current_timestamp) 这显然导致<

浏览 5提问于2021-07-15得票数 2

回答已采纳

1回答

Nifi "PutSQL“异常

java、mysql、processor、apache-nifi

我正试图使用"PutSQL“处理器来做到这一点。 INSERT INTO monitor.security_nifi (RemoteIPAddress, Timestamp,RequestUrl, Status, Instance) VALUES ('

浏览 5提问于2016-09-21得票数 7

3回答

NiFi 1.10 PutSQL错误:查询必须类似INSERT

apache-nifi

我看过的所有帖子都推荐使用PutSQL。Got: truncate table SBST.geographicalcat数据库是Clickhouse，使用的是上一个JDBC。truncate命令在ExecuteSQL处理器的Pre-SQL<e

浏览 0提问于2019-11-25得票数 0

1回答

带有MS-SQL: update语句挂起的apache处理器

sql-server、apache-nifi

系统: 2016，Apache NiFi 1.11.4 UPDATE [MyERP].[dbo].

浏览 2提问于2020-04-13得票数 0

回答已采纳

2回答

获取Nifi PutSQL处理器的最后执行时间戳

python、apache-nifi

有办法通过REST获得PutSQL处理器最后一次执行的时间戳吗？这样的时间戳存在吗?或者我可以自己构建一个时间戳？设置：，我有气流触发我的Nifi，它以几个PutSQL处理器结束-在这些完成之后，我需要在气流中执行其他的东西。Idea:，我想触发第一个Nifi处理器，然后在气流中等待，直到最后一个PutSQL处理器的last_e

浏览 1提问于2021-04-12得票数 1

回答已采纳

2回答

Apache在带Enum列的表中使用PutDatabaseRecord插入失败

database、etl、apache-nifi

我正在使用Apache学习/执行我的第一个ETL，但是我遇到了一个问题，我正在迁移的数据进入一个JSON文件并转到Postgres数据库，但是它在插入部分失败了数据库中的一个列被定义为Enum：表的列名为insurer，类型为Insurer。

浏览 14提问于2022-09-28得票数 1

3回答

时间戳不兼容(NiFi的PutSQL)

java、python、json、postgresql、apache-nifi

我面临着使用Nifi 处理器将时间戳插入到PostgreSQL数据库中的问题。更具体地说，当尝试在时间戳列中插入“2018-01-31T19:01:09+00:00”格式的日期时，我会收到以下错误消息：我已经测试了在命令行的时间戳列中插入'2018-01-31T19:01:09+00:00‘，它工作

浏览 1提问于2018-04-02得票数 4

回答已采纳

1回答

Nifi -截断并加载到mysql db表

mysql、load、truncate、apache-nifi、data-ingestion

我正在从SFTP站点读取CSV文件，并使用Nifi将其加载到mysql db。这个流看起来工作得很好，但是每次我运行它时，我都需要先截断表，

浏览 2提问于2017-12-29得票数 1

回答已采纳

2回答

Nifi-1.0.0 -同步机制

java、synchronization、data-synchronization、apache-nifi

NiFi是否有同步机制，以便知道什么时候完成了处理？我摄取了一些数据，做了一些处理，在步骤N-1中，我想知道所有的数据都已经被处理了，以便进入(最后)步骤N。GetFile / 1000行-> Proc1 /流程步骤0PutSQL / insert到db

浏览 4提问于2016-09-15得票数 2

回答已采纳

1回答

Nifi PutSQL时间戳/日期时间错误不能转换错误

mysql、apache-nifi、update-attribute

我尝试了建议的解决方案，使用"UpdateAttribute“处理器消除时间戳格式转换错误，即转换processor >UpdateAttribute-> PutSQL日志：值是''，不能在org.apache.nifi.processors.standard.PutSQL.setPar

浏览 4提问于2017-08-15得票数 4

1回答

sql、apache-nifi

我正在尝试使用NiFi在具有相似表结构的两个数据库之间传输数据。数据结构示例：没有“最大值列”，因此不可能确定是否有新数据。所以每次我创建完整表格内容的“快照”。问题是不清楚是否应该在目标数据库中插入或更新特定的记录。我创建了处理器的两个分支:插入和更新。只有insert才适用于新记录，而update只适用于现有记录。PutSQL处理器可以处理大

浏览 1提问于2017-03-29得票数 2

1回答

我有6个表，我想一个接一个地创建--每个连续的表都依赖于前一个表。我试图将所有6个SQL脚本放入Apache中的一个PutSQL-processor中，但当试图使用错误table_1 does not exist创建table_2时，处理器失败了。我试图通过激活Database Session AutoCommit来绕过它，但我仍然得到了相同的结果。我是否必须创建6个单独的PutSQL-processors，或者是否有一种方法将多个<

浏览 3提问于2020-11-25得票数 0

回答已采纳

点击加载更多