# 外部用户属性关联导入功能

# 一、介绍

在一些情况下，您需要将外部的用户数据导入到 TA 集群，但是数据中的用户标识并不是 TA 系统中的#account_id 或#distinct_id，比如数据以手机号、身份证号或者其他标识 ID 作为主键。如果需要将这部分数据作为用户属性导入到 TA 系统，则需要通过update_user_by_foreignkey命令设定关联关系，将外部的用户属性更新到 TA 系统中，目前支持 datax 所有支持的数据源：

# 二、使用方法

# 2.1 命令说明

数据导入的命令如下：

ta-tool update_user_by_foreignkey -conf <config files> [--date xxx]

# 2.2 命令参数说明

# 2.2.1 -conf

传入的参数为导入任务的配置文件路径，每一个任务即为一个配置文件，支持多个任务同时导入，支持通配符的方式，例如：/data/config/*或者 ./config/*.json

# 2.2.1 --date

可选参数**--date**：可选，参数表示数据日期，时间宏会基于此基准时间进行替换，可不传，不传则默认取当前日期，格式为YYYY-MM-DD，时间宏的具体使用方法，可参考时间宏使用方法

# 2.3 时间宏使用方法

配置文件内部可以使用时间宏替换时间参数，ta-tool 工具会以导入的开始时间为基准，基于时间宏的参数做时间的偏移计算，并替换掉配置文件中的时间宏，支持的时间宏格式：@[{yyyyMMdd}], @[{yyyyMMdd}-{nday}], @[{yyyyMMdd}+{nday}]等等

  • yyyyMMdd可以替换成任意可以被 Java dateFormat解析的日期格式，例如：yyyy-MM-dd HH:mm:ss.SSS, yyyyMMddHH000000
  • n 可以是任意整数，表示时间的偏移值
  • day 表示时间的偏移单位，可以取如下几种: day, hour, minute, week, month
  • 举例： 假设当前时间为2018-07-01 15:13:23.234
    • @[{yyyyMMdd}] 替换为 20180701
    • @[{yyyy-MM-dd}-{1day}] 替换为 2018-06-31
    • @[{yyyyMMddHH}+{2hour}] 替换为 2018070117
    • @[{yyyyMMddHHmm00}-{10minute}] 替换为 20180701150300

# 三、功能说明

# 3.1 配置样例

{
	"job": {
		"content": [{
			 "reader": {
                    "name": "mysqlreader",
                    "parameter": {
                        "username": "username",
                        "password": "password",
                        "connection": [
                            {
                                "querySql": [
                                    "SELECT card_id, property1, property2,property3 FROM table1;"
                                ],
                                "jdbcUrl": [
                                    "jdbc:mysql://ip:port/database"
                                ]
                            }
                        ]
                    }
                },
			"writer": {
				"parameter": {
                    "appid": "6f9e64da5bc74792b9e9c1db4e3e3822",
					"column": [{
							"type": "string",
							"name": "card_id"
						},
						{
							"type": "string",
							"name": "property1"
						},
						{
							"type": "string",
							"name": "property2"
						},
						{
							"type": "double",
							"name": "property3"
						}
					],
						"joinkey":{
					      "importDataKey": ["card_id"],
						  "taUserTableKey": ["card_id"]
					}
				}
			}
		}]
	}
}

# 3.2 参数说明

# 3.2.1 reader 部分

# 3.2.2 writer 部分

  • appid
    • 描述：对应项目的 appid。
    • 必选：是
    • 默认值：无
  • column
    • 描述：读取字段列表，type指定数据的类型，name 指定为 reader 对应位置的列，导入 ta 系统时的属性名。 用户可以指定Column字段信息，配置如下：
[
  {
    "type": "double",
    "name": "property1"
  },
  {
    "type": "string",
    "name": "property2"
  },
  {
    "type": "bigint",
    "name": "property3"
  }
]
  • joinkey.importDataKey
    • 描述：配置信息中 writer 的 column 作为关联的列名。
    • 必选：是
    • 默认值：无
  • joinkey.taUserTableKey
    • 描述：TA 系统中 user 表作为关联的列名。
    • 必选：是
    • 默认值：无

# 3.3 类型转换

DataX 内部类型 HIVE 数据类型
Long TINYINT,SMALLINT,INT,BIGINT
Double FLOAT,DOUBLE
String STRING,VARCHAR,CHAR
Boolean BOOLEAN
Date DATE,TIMESTAMP

← 数据归档与回档 →