大家好，我是考100分的小小码 ，祝大家学习进步，加薪顺利呀。今天说一说DataX 离线跨网场景的实施配置「终于解决」,希望您对编程的造诣更进一步.
配置仅限于跨不同网情况，网络互通情况方案和配置会更简单一点
内网A：MySql数据转换成Csv
{
"job": {
"setting": {
"speed": {
"channel":1
}
},
"content": [
{
"reader": {
"name": "mysqlreader",
"parameter": {
"username": "root",
"password": "",
"connection": [
{
"querySql": [
"select id,name from table;"
],
"jdbcUrl": [
"jdbc:mysql://127.0.0.1/database"
]
}
]
}
},
"writer": {
"name": "txtfilewriter",
"parameter": {
"print": true,
"encoding": "UTF-8",
"path": "/result",
"fileName": "result.csv",
"writeMode": "truncate",
"dateFormat": "YYYY-MM-dd hh:mm:ss",
"header":["id", "name"]
}
}
}
]
}
}
代码100分
内网B：CSV导入到内网B配置：
代码100分{
"job": {
"setting": {
"speed": {
"channel": 2
}
},
"content": [
{
"reader": {
"name": "txtfilereader",
"parameter": {
"path":["D:/result/result.csv"],
"encoding": "UTF-8",
"column": [
{
"index": 0,
"name":"id",
"type": "long"
},
{
"index": 1,
"name":"name",
"type": "string"
}
],
"skipHeader": "true"
}
},
"writer": {
"name": "mysqlwriter",
"parameter": {
"writeMode": "insert",
"username": "root",
"password": "",
"column": [
"id", "name"
],
"preSql": [
"truncate table table;"
],
"connection": [
{
"jdbcUrl": "jdbc:mysql://127.0.0.1:3306/table?characterEncoding=utf-8",
"table": [
"table"
]
}
]
}
}
}
]
}
}
注意编码和字段支持的类型，详细可查看DataX官方文档。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
转载请注明出处: https://daima100.com/9623.html
