dataX同步數據到MySQL


1.dataX下載地址https://github.com/alibaba/DataX,python版本2.X。

2.dataX下載后解壓直接使用,通過cmd進入bin目錄。

 

 3.輸入python2 datax. py -r streamreader -w streamwriter,查看json模板。

 

 4.配置json文件,可新建也可直接配置。以csv文件導入mysql為例

{
    "job": {
        "content": [
            {
                "reader": {
                    "name": "txtfilereader", 
                    "parameter": {
                    "path": ["D:/hot.csv"], 
                    "encoding":"utf-8",
                        "column": [
                            {
                                "index": 0,
                                "type": "string"
                            },
                            {
                                "index": 1,
                                "type": "string"
                            }
                        ],
                    "skipHeader": "true",
                      "fileDelimiter":","
                    }
                }, 
                "writer": {
                    "name": "mysqlwriter", 
                    "parameter": {
                        "column": [
                            "name",
                            "value",
                          
                        ], 
                        "connection": [
                            {
                               "jdbcUrl": "jdbc:mysql://localhost:3306/hanjia?&useSSL=false&serverTimezone=UTC", 
                               "table": ["hot"]
                            }
                        ], 
                        "password": "password", 
                        "username": "root",
                        "writeMode":"insert"
                    }
                }
            }
        ], 
        "setting": {
            "speed": {
                "channel": "2"
            }
        }
    }
}
View Code

5.輸入python2 datax. py  .. / job/X. json,運行配置好的json文件

 

 第一次運行會出現亂碼,輸入CHCP 65001即可解決。

 

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM