job.json 骨架
job.json 骨架
{
"job": {
"setting": {
"speed": { "channel": 3 },
"errorLimit": { "record": 0, "percentage": 0.02 }
},
"content": [
{
"reader": {
"name": "mysqlreader",
"parameter": {
"username": "ro_user", "password": "***",
"column": ["id", "amount", "created_at"],
"splitPk": "id",
"connection": [
{ "jdbcUrl": ["jdbc:mysql://10.0.0.5:3306/app"], "table": ["orders"] }
]
}
},
"writer": {
"name": "streamwriter",
"parameter": { "print": true }
}
}
]
}
}运行任务
运行任务
python bin/datax.py job.jsonsplitPk 是切分键：选整型/字符串类主键可并行抽取；不配 splitPk 时按单通道顺序读。