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
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...