參數(shù)

描述

是否必選

默認(rèn)值

path

要讀取的文件路徑，如果要讀取多個(gè)文件，可以使用簡(jiǎn)單正則表達(dá)式匹配，例如/hadoop/data_201704*，如果文件以時(shí)間命名且較為規(guī)律，則可以結(jié)合調(diào)度參數(shù)使用，調(diào)度參數(shù)將根據(jù)業(yè)務(wù)時(shí)間動(dòng)態(tài)替換，詳情請(qǐng)參見調(diào)度參數(shù)支持的格式：

• 當(dāng)指定單個(gè)HDFS文件時(shí)，HDFS Reader暫時(shí)只能使用單線程進(jìn)行數(shù)據(jù)抽取。

• 當(dāng)指定多個(gè)HDFS文件時(shí)，HDFS Reader支持使用多線程進(jìn)行數(shù)據(jù)抽取，線程并發(fā)數(shù)通過(guò)作業(yè)并發(fā)數(shù)concurrent指定。

  說(shuō)明

  實(shí)際啟動(dòng)的并發(fā)數(shù)是您的HDFS待讀取文件數(shù)量和您配置作業(yè)并發(fā)數(shù)兩者中的小者。

• 當(dāng)指定通配符，HDFS Reader嘗試遍歷出多個(gè)文件信息。例如指定/代表讀取/目錄下所有的文件，指定/bazhen/代表讀取bazhen目錄下游所有的文件。HDFS Reader目前只支持*和?作為文件通配符，語(yǔ)法類似于通常的Linux命令行文件通配符。

請(qǐng)注意以下事項(xiàng)：

• 數(shù)據(jù)集成會(huì)將一個(gè)同步作業(yè)所有待讀取文件視作同一張數(shù)據(jù)表。您必須自己保證所有的File能夠適配同一套schema信息，并且提供給數(shù)據(jù)集成權(quán)限可讀。

• 注意分區(qū)讀取：Hive在建表時(shí)，可以指定分區(qū)。例如創(chuàng)建分區(qū)partition(day="20150820", hour="09")，對(duì)應(yīng)的HDFS文件系統(tǒng)中，相應(yīng)的表的目錄下則會(huì)多出/20150820和/09兩個(gè)目錄且/20150820是/09的父目錄。

  分區(qū)會(huì)列成相應(yīng)的目錄結(jié)構(gòu)，在按照某個(gè)分區(qū)讀取某個(gè)表所有數(shù)據(jù)時(shí)，則只需配置好JSON中path的值即可。例如需要讀取表名叫mytable01下分區(qū)day為20150820這一天的所有數(shù)據(jù)，則配置如下。

  "path": "/user/hive/warehouse/mytable01/20150820/*"

是

無(wú)

defaultFS

Hadoop HDFS文件系統(tǒng)namenode節(jié)點(diǎn)地址。公共資源組不支持Hadoop高級(jí)參數(shù)HA的配置。

是

無(wú)

fileType

文件的類型，目前僅支持您配置為TEXT、ORC、RC、SEQ、CSV和parquet。HDFS Reader能夠自動(dòng)識(shí)別文件的類型，并使用對(duì)應(yīng)文件類型的讀取策略。HDFS Reader在做數(shù)據(jù)同步前，會(huì)檢查您配置的路徑下所有需要同步的文件格式是否和fileType一致，如果不一致任務(wù)會(huì)失敗。

fileType可以配置的參數(shù)值列表如下所示：

• TEXT：表示TextFile文件格式。

• ORC：表示ORCFile文件格式。

• RC：表示RCFile文件格式。

• SEQ：表示SequenceFile文件格式。

• CSV：表示普通HDFS文件格式（邏輯二維表）。

• PARQUET：表示普通Parquet文件格式。

由于TextFile和ORCFile是兩種不同的文件格式，所以HDFS Reader對(duì)這兩種文件的解析方式也存在差異，這種差異導(dǎo)致Hive支持的復(fù)雜復(fù)合類型（例如map、array、struct和union）在轉(zhuǎn)換為數(shù)據(jù)集成支持的String類型時(shí)，轉(zhuǎn)換的結(jié)果格式略有差異，以map類型為例：

• ORCFile map類型經(jīng)HDFS Reader解析，轉(zhuǎn)換成數(shù)據(jù)集成支持的STRING類型后，結(jié)果為{job=80, team=60, person=70}。

• TextFile map類型經(jīng)HDFS Reader解析，轉(zhuǎn)換成數(shù)據(jù)集成支持的STRING類型后，結(jié)果為{job:80, team:60, person:70}。

如上述轉(zhuǎn)換結(jié)果所示，數(shù)據(jù)本身沒(méi)有變化，但是表示的格式略有差異。所以如果您配置的文件路徑中要同步的字段在Hive中是復(fù)合類型的話，建議配置統(tǒng)一的文件格式 。

最佳實(shí)踐建議：

• 如果需要統(tǒng)一復(fù)合類型解析出來(lái)的格式，建議您在Hive客戶端將TextFile格式的表導(dǎo)成ORCFile格式的表。

• 如果是Parquet文件格式，后面的parquetSchema則必填，此屬性用來(lái)說(shuō)明要讀取的Parquet格式文件的格式。

對(duì)于您指定的column信息，type必須填寫，index和value必須選擇其一。

是

無(wú)

column

讀取字段列表，type指定源數(shù)據(jù)的類型，index指定當(dāng)前列來(lái)自于文本第幾列（以0開始），value指定當(dāng)前類型為常量。不從源頭文件讀取數(shù)據(jù)，而是根據(jù)value值自動(dòng)生成對(duì)應(yīng)的列。默認(rèn)情況下，您可以全部按照STRING類型讀取數(shù)據(jù)，配置為"column": ["*"]。

您也可以指定column字段信息（文件數(shù)據(jù)列和常量列配置二選一），配置如下。

{
  "type": "long",
  "index": 0
  //從本地文件文本第一列（下標(biāo)索引從0開始計(jì)數(shù)）獲取INT字段，index表示從數(shù)據(jù)文件中獲取列數(shù)據(jù)。
},
{
  "type": "string",
  "value": "alibaba"
  //HDFS Reader內(nèi)部生成alibaba的字符串字段作為當(dāng)前字段，value表示常量列。
}

是

無(wú)

fieldDelimiter

讀取的字段分隔符，HDFS Reader在讀取TextFile數(shù)據(jù)時(shí)，需要指定字段分割符，如果不指定默認(rèn)為逗號(hào)（,）。HDFS Reader在讀取ORCFile時(shí)，您無(wú)需指定字段分割符，Hive本身的默認(rèn)分隔符為\u0001。

否

,

encoding

讀取文件的編碼配置。

否

utf-8

nullFormat

文本文件中無(wú)法使用標(biāo)準(zhǔn)字符串定義null（空指針），數(shù)據(jù)集成提供nullFormat定義哪些字符串可以表示為null。

例如您配置nullFormat:"null"，如果源頭數(shù)據(jù)是null，數(shù)據(jù)集成會(huì)將其視作null字段。

否

無(wú)

compress

當(dāng)fileType（文件類型）為csv下的文件壓縮方式，目前僅支持gzip、bz2、zip、lzo、lzo_deflate、hadoop-snappy和framing-snappy壓縮。

否

無(wú)

parquetSchema

否

無(wú)

csvReaderConfig

讀取CSV類型文件參數(shù)配置，Map類型。讀取CSV類型文件使用的CsvReader進(jìn)行讀取，會(huì)有很多配置，不配置則使用默認(rèn)值。

常見配置如下所示。

"csvReaderConfig":{
  "safetySwitch": false,
  "skipEmptyRecords": false,
  "useTextQualifier": false
}

所有配置項(xiàng)及默認(rèn)值，配置時(shí)csvReaderConfig的map中請(qǐng)嚴(yán)格按照以下字段名字進(jìn)行配置。

boolean caseSensitive = true;
char textQualifier = 34;
boolean trimWhitespace = true;
boolean useTextQualifier = true;//是否使用csv轉(zhuǎn)義字符。
char delimiter = 44;//分隔符
char recordDelimiter = 0;
char comment = 35;
boolean useComments = false;
int escapeMode = 1;
boolean safetySwitch = true;//單列長(zhǎng)度是否限制100,000字符。
boolean skipEmptyRecords = true;//是否跳過(guò)空行。
boolean captureRawRecord = true;

否

無(wú)

hadoopConfig

hadoopConfig中可以配置與Hadoop相關(guān)的一些高級(jí)參數(shù)，例如HA的配置。公共資源組不支持Hadoop高級(jí)參數(shù)HA的配置。

"hadoopConfig":{
"dfs.nameservices": "testDfs",
"dfs.ha.namenodes.testDfs": "namenode1,namenode2",
"dfs.namenode.rpc-address.youkuDfs.namenode1": "",
"dfs.namenode.rpc-address.youkuDfs.namenode2": "",
"dfs.client.failover.proxy.provider.testDfs": "org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider",
"dfs.data.transfer.protection": "integrity",
"dfs.datanode.use.datanode.hostname" :"true",
"dfs.client.use.datanode.hostname":"true"
}

"hadoopConfig":{ "dfs.data.transfer.protection": "integrity", "dfs.datanode.use.datanode.hostname" :"true", "dfs.client.use.datanode.hostname":"true" }

否

無(wú)

haveKerberos

是否有Kerberos認(rèn)證，默認(rèn)為false。例如用戶配置為true，則配置項(xiàng)kerberosKeytabFilePath和kerberosPrincipal為必填。

否

false

kerberosKeytabFilePath

Kerberos認(rèn)證keytab文件的絕對(duì)路徑。如果haveKerberos為true，則必選。

否

無(wú)

kerberosPrincipal

Kerberos認(rèn)證Principal名，如****/hadoopclient@**.*** 。如果haveKerberos為true，則必選。

"haveKerberos":true,
"kerberosKeytabFilePath":"/opt/datax/**.keytab",
"kerberosPrincipal":"**/hadoopclient@**.**"

否

無(wú)

參數(shù)

描述

是否必選

默認(rèn)值

defaultFS

Hadoop HDFS文件系統(tǒng)namenode節(jié)點(diǎn)地址，例如hdfs://127.0.0.1:9000。公共資源組不支持Hadoop高級(jí)參數(shù)HA的配置，請(qǐng)新增和使用自定義數(shù)據(jù)集成資源組。

是

無(wú)

fileType

文件的類型，目前僅支持您配置為text、orc和parquet：

• text：表示Hive中的存儲(chǔ)表，TextFile文件格式。

• orc：表示Hive中的壓縮表，ORCFile文件格式。

• parquet：表示普通Parquet File文件格式。

是

無(wú)

path

存儲(chǔ)到Hadoop HDFS文件系統(tǒng)的路徑信息，HDFS Writer會(huì)根據(jù)并發(fā)配置在path目錄下寫入多個(gè)文件。

為了與Hive表關(guān)聯(lián)，請(qǐng)?zhí)顚慔ive表在HDFS上的存儲(chǔ)路徑。例如Hive上設(shè)置的數(shù)據(jù)倉(cāng)庫(kù)的存儲(chǔ)路徑為/user/hive/warehouse/，已建立數(shù)據(jù)庫(kù)test表hello，則對(duì)應(yīng)的存儲(chǔ)路徑為/user/hive/warehouse/test.db/hello。

是

無(wú)

fileName

HDFS Writer寫入時(shí)的文件名，實(shí)際執(zhí)行時(shí)會(huì)在該文件名后添加隨機(jī)的后綴作為每個(gè)線程寫入實(shí)際文件名。

是

無(wú)

column

寫入數(shù)據(jù)的字段，不支持對(duì)部分列寫入。

為了與Hive中的表關(guān)聯(lián)，需要指定表中所有字段名和字段類型，其中name指定字段名，type指定字段類型。

您可以指定column字段信息，配置如下。

"column": 
[
    {
        "name": "userName",
        "type": "string"
    },
    {
        "name": "age",
        "type": "long"
    }
]

是（如果filetype為parquet，此項(xiàng)無(wú)需填寫）

無(wú)

writeMode

HDFS Writer寫入前數(shù)據(jù)清理處理模式：

• append：寫入前不做任何處理，數(shù)據(jù)集成HDFS Writer直接使用filename寫入，并保證文件名不沖突。

• nonConflict：如果目錄下有fileName前綴的文件，直接報(bào)錯(cuò)。

• truncate：寫入前清理fileName名稱前綴匹配的所有文件。例如，"fileName": "abc"，將清理對(duì)應(yīng)目錄所有abc開頭的文件。

是

無(wú)

fieldDelimiter

HDFS Writer寫入時(shí)的字段分隔符，需要您保證與創(chuàng)建的Hive表的字段分隔符一致，否則無(wú)法在Hive表中查到數(shù)據(jù)。

是（如果filetype為parquet，此項(xiàng)無(wú)需填寫）

無(wú)

compress

HDFS文件壓縮類型，默認(rèn)不填寫，則表示沒(méi)有壓縮。

其中text類型文件支持gzip和bzip2壓縮類型。

否

無(wú)

encoding

寫文件的編碼配置。

否

無(wú)壓縮

parquetSchema

寫Parquet格式文件時(shí)的必填項(xiàng)，用來(lái)描述目標(biāo)文件的結(jié)構(gòu)，所以此項(xiàng)當(dāng)且僅當(dāng)fileType為parquet時(shí)生效，格式如下。

message MessageType名 {
是否必填, 數(shù)據(jù)類型, 列名;
......................;
}

配置項(xiàng)說(shuō)明如下：

• MessageType名：填寫名稱。

• 是否必填：required表示非空，optional表示可為空。推薦全填optional。

• 數(shù)據(jù)類型：Parquet文件支持BOOLEAN、INT32、INT64、INT96、FLOAT、DOUBLE、BINARY（如果是字符串類型，請(qǐng)?zhí)頑INARY）和FIXED_LEN_BYTE_ARRAY等類型。

示例如下。

message m {
optional int64 id;
optional int64 date_id;
optional binary datetimestring;
optional int32 dspId;
optional int32 advertiserId;
optional int32 status;
optional int64 bidding_req_num;
optional int64 imp;
optional int64 click_num;
}

否

無(wú)

hadoopConfig

hadoopConfig中可以配置與Hadoop相關(guān)的一些高級(jí)參數(shù)，例如HA的配置。公共資源組不支持Hadoop高級(jí)參數(shù)HA的配置，請(qǐng)新增和使用自定義數(shù)據(jù)集成資源組。

"hadoopConfig":{
"dfs.nameservices": "testDfs",
"dfs.ha.namenodes.testDfs": "namenode1,namenode2",
"dfs.namenode.rpc-address.youkuDfs.namenode1": "",
"dfs.namenode.rpc-address.youkuDfs.namenode2": "",
"dfs.client.failover.proxy.provider.testDfs": "org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider"
}

否

無(wú)

dataxParquetMode

針對(duì)Parquet文件進(jìn)行同步的模式。使用fields支持array、map和struct等復(fù)雜類型。可選值包括fields和columns。

配置dataxParquetMode為fields時(shí)，支持hdfs over oss，即HDFS的存儲(chǔ)為OSS，OSS的數(shù)據(jù)存儲(chǔ)格式為parquet。此時(shí)您可以在hadoopConfig中增加OSS相關(guān)的參數(shù)，詳情如下：

• fs.oss.accessKeyId：訪問(wèn)OSS的AccessKeyID。

• fs.oss.accessKeySecret：訪問(wèn)OSS的AccessKeySecret。

• fs.oss.endpoint：訪問(wèn)OSS的endpoint。

訪問(wèn)OSS的示例如下所示。

```json
    "writer": {
    "name": "hdfswriter",
    "parameter": {
        "defaultFS": "oss://test-bucket",
        "fileType": "parquet",
        "path": "/datasets/oss_demo/kpt",
        "fileName": "test",
        "writeMode": "truncate",
        "encoding": "UTF-8",
        "hadoopConfig": {
            "fs.oss.accessKeyId": "the-access-id",
            "fs.oss.accessKeySecret": "the-access-key",
            "fs.oss.endpoint": "oss-cn-hangzhou.aliyuncs.com"
            },
            "parquetSchema": "message test {\n    required int64 id;\n    optional binary name (UTF8);\n    optional int64 gmt_create;\n    required group map_col (MAP) {\n        repeated group key_value {\n            required binary key (UTF8);\n            required binary value (UTF8);\n        }\n    }\n    required group array_col (LIST) {\n        repeated group list {\n            required binary element (UTF8);\n        }\n    }\n    required group struct_col {\n        required int64 id;\n        required binary name (UTF8);\n    }    \n}",
            "dataxParquetMode": "fields"
            }
        }
    ```

否

columns

haveKerberos

是否有Kerberos認(rèn)證，默認(rèn)為false。如果您配置為true，則配置項(xiàng)kerberosKeytabFilePath和kerberosPrincipal為必填。

否

false

kerberosKeytabFilePath

Kerberos認(rèn)證keytab文件的絕對(duì)路徑。

如果haveKerberos為true，則必選。

無(wú)

kerberosPrincipal

Kerberos認(rèn)證Principal名，如****/hadoopclient@**.*** 。如果haveKerberos為true，則必選。

由于Kerberos需要配置keytab認(rèn)證文件的絕對(duì)路徑，您需要在自定義資源組上使用此功能。配置示例如下。

"haveKerberos":true,
"kerberosKeytabFilePath":"/opt/datax/**.keytab",
"kerberosPrincipal":"**/hadoopclient@**.**"

否

無(wú)