python處理數據,存進hive表

首先,公司的小組長給了我一個任務,把一個txt的文件中的部分內容,存進一個在hive中已有的表的相同結構的表中。所以我的流程主要有三個,首先,把數據處理成和hive中表相同結構的數據,然後仿照已有的hive中表的結構再創建一張新的數據表,最後把本地的txt文件上傳到hive中新建的數據表中。

1:已有的數據表的結構和在hive表中的結構完全對不上,下面的圖是原來hive中表的結構和小組長給我的txt中表的結構:

大家可以看出,我們原來的hive中表的字段一共有17個,而組長給我的表中的字段一共有9個,其中最後一個爲json結構,而且順序還不對,所以我們要進行篩選,把對應上的字段放到相應位置,對應不上的字段寫成空。


大家要注意幾個地方,原來的數據是按照tab來劃分的,所以我們要數好對應的tab的數目,好來計算出來數據的實際的位置信息,然後我們按照原來hive表中的數據順序,重新排列我們新建表的數據的順序,下面給大家看看結果:

其中line[0]=null,line[1]=102,大家以此類推。

3:我們把本地的txt文件導入到hive表中。首先我們要新建一個和原來hive表中相同結構的數據表,然後把我們的數據導入到表中,

hive> creat table new_sft(x1 string,x2 string ,...,xn string) partitioned by (d string);

建好表之後,把數據導入到新表之中:

hive> load data local inpath‘/home/opendev/1.txt’ into table new_sft;

最後給大家看看我的最終的結果: