MySQL LOAD DATA INFILE—批量從文件(csv、txt)導入數據

来源:https://www.cnblogs.com/NaughtyCat/archive/2020/06/22/mysql-load-data-inflie-and-optimizing.html
-Advertisement-
Play Games

最近做的項目,有個需求(從Elastic Search取數據,業務運算後),每次要向MySQL插入1300萬條數據左右。最初用MySQL的executemany()一次插入10000條數據,統計的時間如下: 如上,插入時間由於系統的IO變化,會有波動,最快在4秒左右。 後改為"load data i ...


 

 最近做的項目,有個需求(從Elastic Search取數據,業務運算後),每次要向MySQL插入1300萬條數據左右。最初用MySQL的executemany()一次插入10000條數據,統計的時間如下:

 如上,插入時間由於系統的IO變化,會有波動,最快在4秒左右。

 後改為"load data infile"大概,10萬條數據平均1秒~1.5秒,實際的代碼示例如下:

query = "LOAD DATA INFILE '/var/lib/mysql-files/es.csv' INTO TABLE g_visit_relation_asset_temp FIELDS TERMINATED BY ',' LINES TERMINATED BY '\n' IGNORE 1 LINES \
                        (srcip, srcport, dstip, dstport, l7p, @dummy, cnt, @dummy, cnt_date)"
mysqlcur.execute(query)
mysqlconn.commit()

說明:

(1)MySQL需要開啟對"load data inflie"的許可權支持

    mysqlcur.execute("SET GLOBAL local_infile = 1") (2)需要對mysql文件目錄(筆者: “/var/lib/my-files/”)有管理員的許可權(查看mysql路徑,用“locate mysql”) 如果沒有的話,可以指定本地路徑,需要加上關鍵字"local"即:LOAD DATA LOCAL

(3)Concurrency 支持

 如果預設是 LOW_PRIORITY ,則LOAD DATA要等其它客戶端讀完了,才會開始寫入。加上“Concurrency ”可以,在讀的同時,同時支持寫入,不過速度會稍微下降一點,筆者測試環境影響不大

(4)IGNORE 1 LINES (跳過第一行)

 筆者通過python pandas to_csv()導出的csv是帶標題的,如下:

不需要標題導入到資料庫,就調過嘛

(5)@dummy ,通過占位符,跳過不需要的數據

導入到表的column順序必須和文件保持一致,通過@dummy可以跳過不需要的column

(6)character set 指定字元集

對於漢字,你需要加上 character set utf8

(8)分隔符及換行符

 以“,“作為分隔符,以“\n"作為換行符: FIELDS TERMINATED BY ',' LINES TERMINATED BY '\n'

其他性能優化相關(Only for MyISAM):

通過設置隔離級別、去除索引檢查、唯一性檢查等提高速度(分session和global級別)提高寫入速度,插入之前,設置如下配置:

    mysqlcur.execute("SET SESSION FOREIGN_KEY_CHECKS = 0")
    mysqlcur.execute("SET SESSION UNIQUE_CHECKS = 0")
    mysqlcur.execute("SET SESSION tx_isolation='READ-UNCOMMITTED'")
    mysqlcur.execute("SET SESSION sql_log_bin = 0")

Loda data infile 完了再改回去,如下:

    mysqlcur.execute("SET SESSION FOREIGN_KEY_CHECKS = 1")
    mysqlcur.execute("SET SESSION UNIQUE_CHECKS = 1")
    mysqlcur.execute("SET SESSION tx_isolation='REPEATABLE-READ'")
    mysqlcur.execute("SET SESSION sql_log_bin = 1")

“DISABLE KEYS” 然後 “ENABLE KEYS”,筆者實際測試沒什麼用,只是導入數據更快,總的時間並沒有提升。區別在於:一個是插入一條,創建一個索引;一個是全部導入完了後,再一次創建所有索引。

引用:

*******************************************************************************************

精力有限,想法太多,專註做好一件事就行

  • 我只是一個程式猿。5年內把代碼寫好,技術博客字字推敲,堅持零拷貝和原創
  • 寫博客的意義在於打磨文筆,訓練邏輯條理性,加深對知識的系統性理解;如果恰好又對別人有點幫助,那真是一件令人開心的事

*******************************************************************************************


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 參考自:https://www.cnblogs.com/barfoo/p/4585392.html ls file.img | sed "s:^:`pwd`/:" 保持更新,轉載請註明出處;更多內容請關註cnblogs.com/xuyaowen; https://www.cnblogs.com/ba ...
  • SRAM存儲器是一款不需要刷新電路即能保存它內部存儲數據的靜態隨機存儲器。而DRAM每隔一段時間,要刷新充電一次,否則就會出現內部數據會消失,因此SRAM存儲器具有較高的性能。SRAM雖然只是存儲器,但是使用的方法不一樣,晶元的面積是不一樣的。基於SRAM有兩個事實: (1)1R1W的SRAM面積要 ...
  • 一 METRICS子系統組件 1.1 metric架構介紹 OpenShift metric子系統支持捕獲和長期存儲OpenShift集群的性能度量,收集節點以及節點中運行的所有容器的指標。 metric子系統被由以下開源項目的容器組件構成: Heapster 從Kubernetes集群中的所有節點 ...
  • Mysql查詢語句執行過程 Mysql分為server層和存儲引擎兩部分,或許可以再加一層連接層 連接層(器) Mysql使用的是典型的C/S架構。連接器通過典型的TCP握手完成連接。 需要註的是, 如果用戶名和密碼都正確,那麼該連接所擁有的許可權僅僅是連接成功建立時的所讀取到的許可權 這就意味著:當連 ...
  • 讓MySQL為我們記錄執行流程 我們可以開啟profiling,讓MySQL為我們記錄SQL語句的執行流程 查看profiling參數 shell > select @@profiling; 進行更改 shell > set profiling = 1; 執行語句 select * from emp ...
  • SQL基礎隨記 (Tobe Continued) 其實這裡的隨記,要是好久不接觸突然被問的話有時還真的一時答不上,自己寫一遍勝過盲掃。當然,也有些常讀常新的地方會記錄下來。 對SQL語言進行劃分 DDL Data Definition Language 定義 增刪改資料庫和表的結構 DML Data ...
  • MySQL-錯誤:2059-Authentication plugin 'caching_sha2_password' cannot be loaded 一 現象 使用docker鏡像創建容器後,mysql測試連接不成功 二 原因 網上查詢得到原因:在mysql8之前的版本中加密規則為mysql_n ...
  • Oracle在執行自隱式轉換時:總是會把字元串轉為數字,字元串轉為日期。當列進行轉換,會跳過索引,降低性能。 創建一個表格,給三個列建立索引,進行測試。 create table t1(n1 number, v1 varchar2(10), d1 date); insert into t1 sele ...
一周排行
    -Advertisement-
    Play Games
  • .Net8.0 Blazor Hybird 桌面端 (WPF/Winform) 實測可以完整運行在 win7sp1/win10/win11. 如果用其他工具打包,還可以運行在mac/linux下, 傳送門BlazorHybrid 發佈為無依賴包方式 安裝 WebView2Runtime 1.57 M ...
  • 目錄前言PostgreSql安裝測試額外Nuget安裝Person.cs模擬運行Navicate連postgresql解決方案Garnet為什麼要選擇Garnet而不是RedisRedis不再開源Windows版的Redis是由微軟維護的Windows Redis版本老舊,後續可能不再更新Garne ...
  • C#TMS系統代碼-聯表報表學習 領導被裁了之後很快就有人上任了,幾乎是無縫銜接,很難讓我不想到這早就決定好了。我的職責沒有任何變化。感受下來這個系統封裝程度很高,我只要會調用方法就行。這個系統交付之後不會有太多問題,更多應該是做小需求,有大的開發任務應該也是第二期的事,嗯?怎麼感覺我變成運維了?而 ...
  • 我在隨筆《EAV模型(實體-屬性-值)的設計和低代碼的處理方案(1)》中介紹了一些基本的EAV模型設計知識和基於Winform場景下低代碼(或者說無代碼)的一些實現思路,在本篇隨筆中,我們來分析一下這種針對通用業務,且只需定義就能構建業務模塊存儲和界面的解決方案,其中的數據查詢處理的操作。 ...
  • 對某個遠程伺服器啟用和設置NTP服務(Windows系統) 打開註冊表 HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\W32Time\TimeProviders\NtpServer 將 Enabled 的值設置為 1,這將啟用NTP伺服器功 ...
  • title: Django信號與擴展:深入理解與實踐 date: 2024/5/15 22:40:52 updated: 2024/5/15 22:40:52 categories: 後端開發 tags: Django 信號 松耦合 觀察者 擴展 安全 性能 第一部分:Django信號基礎 Djan ...
  • 使用xadmin2遇到的問題&解決 環境配置: 使用的模塊版本: 關聯的包 Django 3.2.15 mysqlclient 2.2.4 xadmin 2.0.1 django-crispy-forms >= 1.6.0 django-import-export >= 0.5.1 django-r ...
  • 今天我打算整點兒不一樣的內容,通過之前學習的TransformerMap和LazyMap鏈,想搞點不一樣的,所以我關註了另外一條鏈DefaultedMap鏈,主要調用鏈為: 調用鏈詳細描述: ObjectInputStream.readObject() DefaultedMap.readObject ...
  • 後端應用級開發者該如何擁抱 AI GC?就是在這樣的一個大的浪潮下,我們的傳統的應用級開發者。我們該如何選擇職業或者是如何去快速轉型,跟上這樣的一個行業的一個浪潮? 0 AI金字塔模型 越往上它的整個難度就是職業機會也好,或者說是整個的這個運作也好,它的難度會越大,然後越往下機會就會越多,所以這是一 ...
  • @Autowired是Spring框架提供的註解,@Resource是Java EE 5規範提供的註解。 @Autowired預設按照類型自動裝配,而@Resource預設按照名稱自動裝配。 @Autowired支持@Qualifier註解來指定裝配哪一個具有相同類型的bean,而@Resourc... ...