1. <strong id="7actg"></strong>
    2. <table id="7actg"></table>

    3. <address id="7actg"></address>
      <address id="7actg"></address>
      1. <object id="7actg"><tt id="7actg"></tt></object>

        Mysql百萬級數(shù)據(jù)遷移實戰(zhàn)筆記

        共 2596字,需瀏覽 6分鐘

         ·

        2021-07-12 13:46

        專注于PHP、MySQL、Linux和前端開發(fā),感興趣的感謝點個關注喲?。。∥恼轮饕募夹g有PHP、Redis、MySQL、JavaScript、HTML&CSS、Linux、Java、Golang、Linux和工具資源等相關理論知識、面試題和實戰(zhàn)內容。

        問題背景

        上個月跟朋友一起做了個微信小程序,趁著5.20節(jié)日的熱度,兩個禮拜內迅速積累了一百多萬用戶,我們在小程序頁面增加了收集formid的埋點,用于給微信用戶發(fā)送模板消息通知。

        這個小程序一開始的后端邏輯是用douchat框架寫的,使用框架自帶的dc_mp_fans表存儲微信端授權登錄的用戶信息,使用dc_mp_tempmsg表存儲formid。截止到目前,收集到的數(shù)據(jù)超過380萬,很大一部分formid都已經成功使用給用戶發(fā)送過模板通知,起到了較好的二次推廣的效果。

        隨著數(shù)據(jù)量的增大,之前使用的服務器空間開始有點不夠用,最近新寫了一個專門用于做小程序后臺開發(fā)的框架,于是想把原來的數(shù)據(jù)遷移到新系統(tǒng)的數(shù)據(jù)庫。買了一臺4核8G的機器,開始做數(shù)據(jù)遷移。下面對遷移過程做一個簡單的記錄。

        Snipaste_2021-07-11_10-35-43

        方案選擇

        mysqldump遷移

        平常開發(fā)中,我們比較經常使用的數(shù)據(jù)備份遷移方式是用mysqldump工具導出一個sql文件,再在新數(shù)據(jù)庫中導入sql來完成數(shù)據(jù)遷移。試驗發(fā)現(xiàn),通過mysqldump導出百萬級量的數(shù)據(jù)庫成一個sql文件,大概耗時幾分鐘,導出的sql文件大小在1G左右,然后再把這個1G的sql文件通過scp命令復制到另一臺服務器,大概也需要耗時幾分鐘。在新服務器的數(shù)據(jù)庫中通過source命令來導入數(shù)據(jù),我跑了一晚上都沒有把數(shù)據(jù)導入進來,cpu跑滿。

        腳本遷移

        直接通過命令行操作數(shù)據(jù)庫進行數(shù)據(jù)的導出和導入是比較便捷的方式,但是數(shù)據(jù)量較大的情況下往往會比較耗時,對服務器性能要求也比較高。如果對數(shù)據(jù)遷移時間要求不是很高,可以嘗試寫腳本來遷移數(shù)據(jù)。雖然沒有實際嘗試,但是我想過大概有兩種腳本方案。

        第一種方式,在遷移目標服務器跑一個遷移腳本,遠程連接源數(shù)據(jù)服務器的數(shù)據(jù)庫,通過設置查詢條件,分塊讀取源數(shù)據(jù),并在讀取完之后寫入目標數(shù)據(jù)庫。這種遷移方式效率可能會比較低,數(shù)據(jù)導出和導入相當于是一個同步的過程,需要等到讀取完了才能寫入。如果查詢條件設計得合理,也可以通過多線程的方式啟動多個遷移腳本,達到并行遷移的效果。

        第二種方式,可以結合redis搭建一個“生產+消費”的遷移方案。源數(shù)據(jù)服務器可以作為數(shù)據(jù)生產者,在源數(shù)據(jù)服務器上跑一個多線程腳本,并行讀取數(shù)據(jù)庫里面的數(shù)據(jù),并把數(shù)據(jù)寫入到redis隊列。目標服務器作為一個消費者,在目標服務器上也跑一個多線程腳本,遠程連接redis,并行讀取redis隊列里面的數(shù)據(jù),并把讀取到的數(shù)據(jù)寫入到目標數(shù)據(jù)庫。這種方式相對于第一種方式,是一種異步方案,數(shù)據(jù)導入和數(shù)據(jù)導出可以同時進行,通過redis做數(shù)據(jù)的中轉站,效率會有較大的提升。

        可以使用go語言來寫遷移腳本,利用其原生的并發(fā)特性,可以達到并行遷移數(shù)據(jù)的目的,提升遷移效率。

        文件遷移

        第一種遷移方案效率太低,第二種遷移方案編碼代價較高,通過對比和在網上找的資料分析,我最終選擇了通過mysql的select data into outfile file.txt、load data infile file.txt into table的命令,以導入導出文件的形式完成了百萬級數(shù)據(jù)的遷移。

        遷移過程

        1. 在源數(shù)據(jù)庫中導出數(shù)據(jù)文件
        select * from dc_mp_fans into outfile '/data/fans.txt'
        1. 復制數(shù)據(jù)文件到目標服務器
        zip fans.zip /data/fans.txt
        scp fans.zip root@ip:/data/
        1. 在目標數(shù)據(jù)庫導入文件
        unzip /data/fans.zip
        load data infile '/data/fans.txt' into table wxa_fans(id,appid,openid,unionid,@dummy,created_at,@dummy,nickname,gender,avatar_url,@dummy,@dummy,@dummy,@dummy,language,country,province,city,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy,@dummy);

        按照這么幾個步驟操作,幾分鐘內就完成了一個百萬級數(shù)據(jù)表的跨服務器遷移工作。

        注意項

        1. MySQL安全項設置

        在mysql執(zhí)行l(wèi)oad data infile和into outfile命令都需要在mysql開啟了secure_file_priv選項, 可以通過show global variables like '%secure%';查看mysql是否開啟了此選項,默認值Null標識不允許執(zhí)行導入導出命令。通過vim /etc/my.cnf修改mysql配置項,將secure_file_priv的值設置為空:

        [mysqld]
        secure_file_priv=''

        則可通過命令導入導出數(shù)據(jù)文件。

        1. 導入導出的數(shù)據(jù)表字段不對應

        上面示例的從源數(shù)據(jù)庫的dc_mp_fans表遷移數(shù)據(jù)到目標數(shù)據(jù)庫的wxa_fans表,兩個數(shù)據(jù)表的字段分別為:dc_mp_fans

        wxa_fans

        在導入數(shù)據(jù)的時候,可以通過設置字段名來匹配目標字段的數(shù)據(jù),可以通過@dummy丟棄掉不需要的目標字段數(shù)據(jù)。

        總結

        結合本次數(shù)據(jù)遷移經歷,總結起來就是:

        小數(shù)據(jù)量可以使用mysqldump命令進行導入導出,這種方式簡單便捷。數(shù)據(jù)量較大,且有足夠的遷移耐心時,可以選擇自己寫腳本,選擇合適的并行方案遷移數(shù)據(jù),這種方式編碼成本較高。數(shù)據(jù)量較大,且希望能在短時間內完成數(shù)據(jù)遷移時,可以通過mysql導入導出文件的方式來遷移,這種方式效率較高。

        在新系統(tǒng)展示數(shù)據(jù)的效果:



        瀏覽 59
        點贊
        評論
        收藏
        分享

        手機掃一掃分享

        分享
        舉報
        評論
        圖片
        表情
        推薦
        點贊
        評論
        收藏
        分享

        手機掃一掃分享

        分享
        舉報
        1. <strong id="7actg"></strong>
        2. <table id="7actg"></table>

        3. <address id="7actg"></address>
          <address id="7actg"></address>
          1. <object id="7actg"><tt id="7actg"></tt></object>
            成人无码区免费AV毛片 | 看一看熟女黄色操逼片 | xxxxwwww日本免费 | 男人超逼蜜桃 | 免费一级一级人妻片 | 特级西西44www无码 | A∨无码 | 嗯啊h在线 | 丁香六月久久 | a免费观看|