greenplum中怎么使用gpfdist與外部表高效導入數據-創新互聯

本篇內容介紹了“greenplum中怎么使用gpfdist與外部表高效導入數據”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

目前創新互聯已為數千家的企業提供了網站建設、域名、虛擬空間、網站托管維護、企業網站設計、浮梁網站維護等服務，公司將堅持客戶導向、應用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協力一起成長，共同發展。

greenplum作為OLAP分析型軟件，自然避免不了從外部數據庫加載大量的數據，然而傳統的ETL數據傳輸方法（select=>insert）到GP需要經過GP的單點master，效率非常低。

下面介紹外部表用gpfdist快速導入數據：

普通外部表和可寫外部表區別：

1、普通外部表只能select,可寫外部表只能insert

2、可寫外部表沒有錯誤表

3、可寫外部表可以指定分布鍵，如果不指定，默認隨機分布；普通外部表只能隨機分布

gpfdist優勢：

1、直接由segment并發加載

2、直接加載數據文件，并可讀寫（和選擇的外部表類型有關）

3、默認數據隨機分配，每個節點負載均衡（和選擇的外部表類型有關）

示例：

1、啟動gpfdist

安裝完GP后，自帶gpfdist文件，直接指定目錄、端口等就能啟動服務。如果需要獨立的文件服務器，則需要在文件服務器上單獨下載gpfdist使用

[gpadmin@gp-master ~]nohup /disk/GP/bin/gpfdist -p 8081 -d /disk/upload &

使用nohup &是起守護進程作用，不然執行啟動服務的客戶端關閉后，這個進程也會被關閉；指定端口8081，指定文件服務器目錄/disk/upload

[gpadmin@gp-master ~]$ ps -ef|grep gpfdist

gpadmin 816 32606 0 17:08 pts/4 00:00:00 grep gpfdist

gpadmin 13036 1 0 Oct21 ? 00:00:44 /disk/GP/bin/gpfdist -p 8081 -d /disk/upload

2、創建普通外部表

CREATE EXTERNAL TABLE "ods"."order" (

"id" varchar(64),

"create_by" varchar(64),

"create_date" timestamp,

"update_by" varchar(64),

"update_date" timestamp,

"del_flag" char(1),

"user_id" varchar(64),

"user_name" varchar(64),

"account_id" varchar(64),

"equ_def_id" varchar(64),

"amount_in" numeric(20,2),

"amount_in_money" numeric(20,2),

"amount_out" numeric(20,2),

"amount_out_money" numeric(20,2),

"fee" numeric(20,2),

"fee_discount" numeric(20,2),

"money" numeric(20,2),

"actual_pay_money" numeric(20,2),

"discount_money" numeric(20,2),

"pay_time" timestamp,

"order_type" varchar(16),

"status" varchar(64),

"rel_biz_type" varchar(64),

"rel_biz_id" varchar(64),

"equ_agreement" varchar(64),

"remarks" varchar(100),

"transaction_type" varchar(1),

"pay_stop_date" timestamp,

"stop_time" timestamp,

"bid_method" varchar(64),

"profit_fee_rate" numeric(20,2),

"quit_charge_rate" numeric(20,2),

"return_tb" numeric(20,2),

"last_order_id" varchar(64),

"root_order_id" varchar(64),

"invest_name_for_me" varchar(64),

"invest_name_for_buyer" varchar(64),

"invest_start_time" timestamp,

"available_amount" numeric(20,2),

"surplus_days" int4,

"transferable_flag" varchar(64),

"trc_order_id" varchar(64)

) LOCATION ('gpfdist://gp-master:8081/order.csv') format 'csv' (DELIMITER ';');

注意有幾個坑：

1、這個實驗數據order.csv是生產環境mysql的測試數據，表中有時間類型字段，如果從線上數據導出到txt文本，這個時候你的時間格式就變成了varchar，再導入到GP的時間類型字段時候會報格式錯誤，所以盡量導出為csv格式的文本

2、指定gpfdist信息：LOCATION ('gpfdist://文件服務器主機名或IP:gpfdist端口/加載文件') format '文件格式' (DELIMITER '分隔字符')

3、從線上數據導出到文本，不要行頭，不要封閉符，只需要分隔字符

測試數據90W記錄的數據，gpfdist加載數據在秒級別，效率很高

創建可寫外部表

CREATE WRITABLE EXTERNAL TABLE "ods"."order1" (