如何在 NiFi 中映射流文件中的列数据?

How to map the column wise data in flowfile in NiFi?(如何在 NiFi 中映射流文件中的列数据?)
本文介绍了如何在 NiFi 中映射流文件中的列数据?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我有一个具有以下结构的csv文件,

i have csv file which having following structure.,

Alfreds,Centro,Ernst,Island,Bacchus
Germany,Mexico,Austria,UK,Canada
01,02,03,04,05

现在我必须将这些数据移动到数据库中,如下所示.

Now i have to move that data into database like below.

Name,City,ID
Alfreds,Germay,01
Centro,Mexico,02
Ernst,Austria,03
Island,UK,04
Bacchus,Canda,05

我尝试映射这些列,但我无法按列提取数据.

i try to map those colums but i can't able to extract the data in column wise.

这里我按列输入数据,但我需要在 SQLServer 中按行插入数据

Here my input data in column wise but i need to insert those in row wise in SQLServer

任何人都可以建议在 sql server 中将列数据转换为行数据的方法吗?.

Can anyone suggest way to transfer column wise data into row wise in sql server?.

谢谢

推荐答案

@Andy,

在 NiFi 中也可以不使用 ExecuteScript.

It could be possible in NiFi also without using ExecuteScript.

我在 ExtractText 中提取了 3 个输入行作为 input.1,input.2,input.3.然后使用 表达式语言 并将其存储在 "TotalCount" 属性中.

I have extract the 3 input rows as input.1,input.2,input.3 in ExtractText. And then count number of columns in "input.1" using AnydelinateValues in expression language and store that in "TotalCount" Attribute.

最初制作Count=1".

Initially made "Count=1".

使用循环概念通过使用Count"获取第一列,然后在RouteOnAttribute中增加Count"检查Count""le(totalcount)"

Using Loop Concept to get the first column by using "Count" and then increment "Count" Check "Count" in RouteOnAttribute "le(totalcount)"

现在使用 "Count" 属性形成插入查询.

Now form insert Query with "Count" Attribute.

它对我来说效果很好.它可能对某人有用.

It worked well for me.It could be useful for someone.

这篇关于如何在 NiFi 中映射流文件中的列数据?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!

相关文档推荐

Execute complex raw SQL query in EF6(在EF6中执行复杂的原始SQL查询)
Hibernate reactive No Vert.x context active in aws rds(AWS RDS中的休眠反应性非Vert.x上下文处于活动状态)
Bulk insert with mysql2 and NodeJs throws 500(使用mysql2和NodeJS的大容量插入抛出500)
Flask + PyMySQL giving error no attribute #39;settimeout#39;(FlASK+PyMySQL给出错误,没有属性#39;setTimeout#39;)
auto_increment column for a group of rows?(一组行的AUTO_INCREMENT列?)
Sort by ID DESC(按ID代码排序)