DEV Community
·
在NiFi中，ExtractText和PutSQL处理器之间的流文件当前被处罚
💡
原文英文，约200词，阅读约需1分钟。
📝
内容提要
我有一个需求，需要从文件中读取用户的姓名（每行一个），并插入到数据库（Oracle）中。我在NiFi中使用GetFile->SplitText->ExtractText->PutSql来实现。对于少量记录（大约10条记录），一切正常。但是当我尝试处理50条或100条以上的记录时，ExtractText和PutSql之间的连接出现问题，显示“当前有一个流文件被处罚，此时无法处理数据”。所有的流文件都保留在队列中。注意，在PutSQL中，我使用的是简单的SQL语句（insert into users_table(user_name) values ('user123');）。对于10条或20条记录，它可以正常工作，但是当我提供100条以上的记录时，它就会卡住。
🎯
关键要点
- 需求是从文件中读取用户姓名并插入到Oracle数据库中。
- 使用NiFi的GetFile->SplitText->ExtractText->PutSql流程实现该需求。
- 对于少量记录（约10条），流程正常工作。
- 处理50条或100条以上记录时，ExtractText与PutSql之间的连接出现问题。
- 出现错误提示：'当前有一个流文件被处罚，此时无法处理数据'。
- 所有流文件在队列中保留，无法继续处理。
- 在PutSQL中使用简单的SQL语句进行插入。
- 对于10条或20条记录，流程正常，但处理100条以上记录时会卡住。
🏷️
标签
➡️
