没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
DataX3.0系列文章
1、datax3.0部署与验证
2、mysql相关同步-mysql同步到mysql、mysql和hdfs相互同步
3、oracle相关同步-oracle到hdfs
4、sybase相关同步-sybase到hdfs
5、ETL工具的比较(DataPipeline,Kettle,Talend,Informatica,Datax ,Oracle Goldeng
@TOC
本文介绍oracle的相关同步,oracle同步到hdfs中。
本文分为三部分,即配置文件模板、配置文件和提交任务。
本文的前提:数据库对应的表已经建好。
一、配置文件模板
[root@bd-node-05 job]# python ../bin/datax.py -r oraclereader -w hdfswriter
DataX (DATAX-OPENSOURCE-3.0), From Alibaba !
Copyright (C) 2010-2017, Alibaba Group. All Rights Reserved.
Please refer to the oraclereader document:
https://github.com/alibaba/DataX/blob/master/oraclereader/doc/oraclereader.md
Please refer to the hdfswriter document:
https://github.com/alibaba/DataX/blob/master/hdfswriter/doc/hdfswriter.md
Please save the following configuration as a json file and use
python {DATAX_HOME}/bin/datax.py {JSON_FILE_NAME}.json
to run the job.
{
"job": {
"content": [
{
"reader": {
"name": "oraclereader",
"parameter": {
"column": [],
"connection": [
{
"jdbcUrl": [],
"table": []
}
],
"password": "",
"username": ""
二、编写配置文件
t_N.json
}
},
"writer": {
"name": "hdfswriter",
"parameter": {
"column": [],
"compress": "",
"defaultFS": "",
"fieldDelimiter": "",
"fileName": "",
"fileType": "",
"path": "",
"writeMode": ""
}
}
}
],
"setting": {
"speed": {
"channel": ""
}
}
}
}
{
"job": {
"content": [
{
"reader": {
"name": "oraclereader",
"parameter": {
"username": "test",
"password": "88888",
"where": "",
"connection": [
{
"querySql": ["select * from T_N_TEST"],
"jdbcUrl":
["jdbc:oracle:thin:@192.168.*.*:1521:sdb"]
}
]
}
},
"writer": {
"name": "hdfswriter",
"parameter": {
"defaultFS": "hdfs://hdfsHA",
"hadoopConfig":{
"dfs.nameservices": "hdfsHA",
三、提交任务
"dfs.ha.namenodes.hdfsHA": "namenode36,namenode38",
"dfs.namenode.rpc-address.hdfsHA.namenode36": "bd-
node-02:8020",
"dfs.namenode.rpc-address.hdfsHA.namenode38": "bd-
node-03:8020",
"dfs.client.failover.proxy.provider.hdfsHA":
"org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider"
},
"column": [
{"name": "LSH","type": "INT"},
{"name": "DSHH","type": "STRING"},
{"name": "DKHZH","type": "STRING"},
{"name": "DCZRQ","type": "TIMESTAMP"},
{"name": "DCZJE","type": "double"},
{"name": "DYXQ","type": "TIMESTAMP"},
{"name": "DCZFS","type": "STRING"},
{"name": "DCZKH","type": "STRING"},
{"name": "DIPDH","type": "STRING"},
{"name": "DCZRY","type": "INT"},
{"name": "DTGID","type": "STRING"},
{"name": "HZKHZH","type": "STRING"},
{"name": "DXGDDDBH","type": "STRING"},
{"name": "SHRY","type": "INT"},
{"name": "SHRQ","type": "TIMESTAMP"},
{"name": "SHFLAG","type": "STRING"},
{"name": "HZFLAG","type": "STRING"},
{"name": "FLAG","type": "STRING"},
{"name": "DFXSH","type": "STRING"},
{"name": "DZT","type": "STRING"},
{"name": "DJSSH","type": "STRING"},
{"name": "DKHLSH","type": "INT"}
],
"compress": "",
"fieldDelimiter": ",",
"fileName": "t_n",
"fileType": "text",
"path": "/user/hive/warehouse/test.db/t_n",
"writeMode": "append"
}
}
}
],
"setting": {
"speed": {
"channel": 6
}
}
}
}
剩余13页未读,继续阅读
资源评论
一瓢一瓢的饮alanchanchn
- 粉丝: 2827
- 资源: 69
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功