DataX案例:读取MongoDB的数据导入MySQL


读取MongoDB的数据导入MySQL

1)在MySQL中创建表

mysql> create table jason(name varchar(20),url varchar(20));

2)编写DataX配置文件

[jason@hadoop102 datax]$ vim job/mongodb2mysql.json

{

    "job": {

        "content": [

            {

                "reader": {

                    "name": "mongodbreader",

                    "parameter": {

                        "address": ["127.0.0.1:27017"],

                        "collectionName": "jason",

                        "column": [

                         {

                         "name":"name",

                         "type":"string"

                         },

                         {

                         "name":"url",

                         "type":"string"

                         }

                        ],

                        "dbName": "test",

                    }

                },

                "writer": {

                    "name": "mysqlwriter",

                    "parameter": {

                        "column": ["*"],

                        "connection": [

                            {

                                "jdbcUrl": "jdbc:mysql://hadoop102:3306/test",

                                "table": ["jason"]

                            }

                        ],

                        "password": "000000",

                        "username": "root",

                        "writeMode": "insert"

                    }

                }

            }

        ],

        "setting": {

            "speed": {

                "channel": "1"

            }

        }

    }

}

3)执行

[jason@hadoop102 datax]$ bin/datax.py job/mongodb2mysql.json

4)查看结果

mysql> select * from jason;

+---------+-----------------+

| name    | url             |

+---------+-----------------+

| jason | www.jason.com |

+---------+-----------------+

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM