DataX之读取Hive数据_datax 读取hive

1、编写脚本read-hive.json

{
    "job": {
        "setting": {
            "speed": {
                "channel": 3
            }
        },
        "content": [
            {
                "reader": {
                    "name": "hdfsreader",
                    "parameter": {
                        "path": "/user/hive/warehouse/ods.db/ods_emp/*",
					"defaultFS": "hdfs://hdfs-ha",
					"hadoopConfig":{
						"dfs.nameservices": "hdfs-ha",
						"dfs.ha.namenodes.hdfs-ha": "nn1,nn2",
						"dfs.namenode.rpc-address.hdfs-ha.nn1": "node01:8020",
						"dfs.namenode.rpc-address.hdfs-ha.nn2": "node02:8020",
						"dfs.client.failover.proxy.provider.hdfs-ha": "org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider"
					},
                        "column": ["*"],
                        "fileType": "text",
                        "encoding": "UTF-8",
                        "fieldDelimiter": ","
                    }
                },
                "writer": {
                    "name": "streamwriter",
                    "parameter": {
                        "print": true
                    }
                }
            }
        ]
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

2、执行脚本

/datax/bin/datax.py ./read-hive.json
1