DSL 是数据库传输服务 DTS 基于 LISP\-1 标准为数据同步场景中数据处理需求设计的脚本语言。DTS 通过 DSL 脚本语言可以对数据中的字符串、日期和数值等进行抽取、转换、加工和加载。 ## DSL 语法特性 DSL 语法拥有以下特性： * 功能强大：支持大量函数组合。 * 操作高效：DSL 的执行无额外的运行时开销，对同步过程的性能损耗较小。 * 语法简单：提供了例如数据过滤、数据转换、数据脱敏等典型场景，您可以参考此类场景设置您的专属脚本语言。详细信息，请参见[应用场景](../6390/141463#.5bqU55So5Zy65pmv)。 ## 数据类型 |**类型** |**描述** |**示例值** | |---|---|---| |int |整型，表示没有小数部分的数值，可以是正数、负数或零。 |123 | |float |浮点型，表示有小数部分的数值。 |3.14 | |string |字符串。 |"abc" | |char |字符型，表示单个字符。 |#a | |bool |布尔型，表示真或假的值。 |true 或 false | |bytes |表示以 0B 开头的 16 进制串。 |0B37 | |symbol |表示无引号包含的字符串。 |abc | |time |表示时间类型。 |(time/parse\-beijing "2015\-02\-23 23:54:55") | ## 表达式类型 |**类型** |**表达式** |**说明** | |---|---|---| |数组 |```sql|数组以方括号包裹的一串元素。例如：|\ | |[参数1 参数2 参数3 ...]||\ | |```|* `[1 2 3]`：表示整型数组。|\ | | |* `["a" "b" "c"]`：表示字符串数组。 | |哈希 |```sql|哈希是以花括号包裹的一串元素。奇数位元素为 key，紧随其后的偶数位元素为 value。例如：|\ | |{key1 value1 key2 value2}|```sql|\ | |```|{"a" 1 "b" 2 }|\ | | |```|\ | | ||\ | | |表示 `key1` 为 `a`，`value1` 为 `1`；`key2` 为 `b`，`value2` 为 `2`。 | |函数调用 |```sql|函数调用是括号包括的一串元素。例如：|\ | |(function-name 参数1 参数2 参数3 ...)|```sql|\ | |```|(+ 1 2)|\ | | |```|\ | | | | |Quoting |```sql|使用单引号 `'` 将列表标记为数据，表示一串数据列表，而不是函数调用。例如：|\ | |'(参数1 参数2 参数3 ...)|```sql|\ | |```|'(1 2 3)|\ | | |```|\ | | | | |函数定义 |```sql|使用 `defn` 定义一个函数。例如定义一个计算平方的函数：|\ | |(defn 函数名 [参数1 参数2 ...]|```sql|\ | | 函数体)|(defn square [x]|\ | |```| (* x x))|\ | | |```|\ | | | | |变量绑定 |```sql|使用关键字 `let` 做变量绑定。例如打印变量 a、b 的值：|\ | |(let [变量1 值1 变量2 值2 ...]|```sql|\ | | 使用变量的表达式)|(let [a 100 b 200]|\ | |```| (println a b))|\ | | |```|\ | | ||\ | | |返回 `100 200`。 | ## 函数类型数据库传输服务 DTS 支持基于 ETL 开发 DSL 脚本语言，具体如下所示。 ### 内置函数 * 表达式函数 * 数值运算 |**功能** |**语法** |**取值范围** |**返回值** | |---|---|---|---| |加法 |```sql|value1 和 value2 的取值范围包含整数或浮点数。 |当参数都为整数时，则返回整数，否则返回浮点数。 |\ | |(+ value1 value2 )| | |\ | |```| | |\ | | | | | |减法 |```sql|value1 和 value2 的取值范围包含整数或浮点数。 |当参数都为整数时，则返回整数，否则返回浮点数。 |\ | |(- value1 value2)| | |\ | |```| | |\ | | | | | |乘法 |```sql|value1 和 value2 的取值范围包含整数或浮点数。 |当参数都为整数时，则返回整数，否则返回浮点数。 |\ | |(* value1 value2)| | |\ | |```| | |\ | | | | | |除法 |```sql|value1 和 value2 的取值范围包含整数或浮点数。 |当参数都为整数时，则返回整数，否则返回浮点数。 |\ | |(/ value1 value2)| | |\ | |```| | |\ | | | | | |取模 |```sql|value1 和 value2 的取值范围包含整数或浮点数。 |当参数都为整数时，则返回整数，否则返回浮点数。 |\ | |(mod value1 value2)| | |\ | |```| | |\ | | | | | * 逻辑运算 * 比较运算 |**功能** |**语法** |**取值范围** |**返回值** | |---|---|---|---| |大于 |```sql|value1 和 value2 的取值范围包含整数、浮点数或字符串。 |`true` 或 `false` |\ | |(> value1 value2)| | |\ | |```| | |\ | | | | | |小于 |```sql|value1 和 value2 的取值范围包含整数、浮点数或字符串。 |`true` 或 `false` |\ | |(< value1 value2)| | |\ | |```| | |\ | | | | | |等于 |```sql|value1 和 value2 的取值范围包含整数、浮点数或字符串。 |`true` 或 `false` |\ | |(= value1 value2)| | |\ | |```| | |\ | | | | | |大于等于 |```sql|value1 和 value2 的取值范围包含整数、浮点数或字符串。 |`true` 或 `false` |\ | |(>= value1 value2)| | |\ | |```| | |\ | | | | | |小于等于 |```sql|value1 和 value2 的取值范围包含整数、浮点数或字符串。 |`true` 或 `false` |\ | |(<= value1 value2)| | |\ | |```| | |\ | | | | | |不等于 |```sql|value1 和 value2 的取值范围包含整数、浮点数或字符串。 |`true` 或 `false` |\ | |(!= value1 value2)| | |\ | |```| | |\ | | | | | * 布尔运算 |**功能** |**语法** |**取值范围** |**返回值** | |---|---|---|---| |OR运算 |```sql|* true|`true` 或 `false`。例如：|\ | |(or true false true)|* false |```sql|\ | |```| |(or (> 1 2) (> 3 2))|\ | | | |```|\ | | | ||\ | | | |返回 `true`。 | |AND 运算 |```sql|* true|`true` 或 `false`。例如：|\ | |(and true false true)|* false |```sql|\ | |```| |(and (> 2 1) (> 3 2))|\ | | | |```|\ | | | ||\ | | | |返回 `true`。 | |NOT 运算 |```sql|* true|`true` 或 `false`。例如：|\ | |(not true)|* false ||\ | |```| |* 示例一：|\ | | | | ```sql|\ | | | | (not (= 1 2))|\ | | | | ```|\ | | | | |\ | | | | 返会 `true`。|\ | | | |* 示例二：|\ | | | | ```sql|\ | | | | (not (= 1 1))|\ | | | | ```|\ | | | | |\ | | | | 返回 `false`。 | * 字符串函数 |**功能** |**语法** |**返回值** | |---|---|---| |获取字符串中某个索引位置的字符 |```sql|返回索引位置的字符。例如：|\ | |(sget "字符串" 索引位置)|```sql|\ | |```|(sget "abcd" 2)|\ | | |```|\ | | ||\ | | |返回 `#c`。 | |向字符串追加字符。 |```sql|返回添加后的字符串。例如：|\ | |(append "字符串" #追加字符)|```sql|\ | |```|(append "ab" #c)|\ | | |```|\ | | ||\ | | |返回 `abc`。 | |返回字符串的子串 |```sql|返回一个包含从 from 到 to（不包含 to）的子字符串的字符串。例如：|\ | |(slice 字符串 from to)|```sql|\ | |```|(slice "abcd" 1 3)|\ | | |```|\ | | ||\ | | |返回 `bc`。 | |字符串间的格式转换 |* 将字符串转换为 int 格式|字符串转换成 int 或 float 格式。例如：|\ | | ```sql||\ | | (int "字符串")|* 返回结果为 123。|\ | | ```| ```sql|\ | | | (int "123")|\ | |* 将字符串转换为 float 格式| ```|\ | | ```sql| |\ | | (float "字符串")|* 返回结果为 3.14。|\ | | ```| ```sql|\ | | | (float "3.14")|\ | | | ```|\ | | | | * 流程控制函数 |**功能** |**语法** |**说明** | |---|---|---| |cond 语句 |```sql|`cond` 类似于通用语言中的 Switch 语句，但 cond 必须包含 default 分支。例如：|\ | |(cond|```sql|\ | | first-condition first-expression|(cond (> age 50) (println "五十而知天命")|\ | | second-condition second-expression| (> age 40) (println "四十不惑")|\ | | ...| (> age 30) (println "三十而立")|\ | | default-expression)| (println "年轻人"))|\ | |```|```|\ | | ||\ | | |当 `age` 是 `20` 时，则返回`年轻人`。 | |if 或 when 语句 |* if 语法表达式：|if 和 when 的语法表达式具有相同含义，满足条件时则执行某些操作。例如：|\ | ||```sql|\ | |```sql|(if (> 2 1) (println "OK"))|\ | |(if condition expression)|```|\ | |```||\ | ||返回 `ok`。 |\ | || |\ | |* when 语法表达式：| |\ | || |\ | |```sql| |\ | |(when condition expression)| |\ | |```| |\ | | | | |unless语句 |```sql|和 if 相反，不满足条件的则执行操作。例如：|\ | |(unless condition expression)|```sql|\ | |```|(unless false (println "OK"))|\ | | |```|\ | | ||\ | | |返回 `ok`。 | * 数据操作函数 * 数组函数 true 或 false |**功能** |**语法** |**返回值** | |---|---|---| |创建指定长度的数组，或创建指定长度的数组并以指定值初始化 |* 创建指定长度的数组语法表达式：|返回指定长度的数组，或指定长度的数组并以指定值初始化。例如：|\ | | ```sql||\ | | (make-array 长度)|* 返回指定长度的数组示例：|\ | | ```| ```sql|\ | | | (make-array 3)|\ | |* 创建指定长度的数组并以指定值初始化语法表达式：| ```|\ | | ```sql| |\ | | (make-array 长度默认值)| 返回的数组为 `[() () ()]`。|\ | | ```|* 指定长度的数组并以指定值初始化示例：|\ | | | ```sql|\ | | | (make-array 3 0)|\ | | | ```|\ | | | |\ | | | 返回的数组为 `[0 0 0]`。 | |按数组索引访问数组 |```sql|返回索引所在的数组。例如：|\ | |(aget 数组索引)|```sql|\ | |```|(aget [1 2 3] 1)|\ | | |```|\ | | ||\ | | |返回 `2`。 | |设置数组元素值 |```sql|替换索引位置的值。例如：|\ | |(aset! 数组索引值)|```sql|\ | |```|(aset! [0 1 2] 1 3)|\ | | |```|\ | | ||\ | | |返回 `[0 3 2]`。 | |判断数组内是否包含某个元素 |```sql|返回值为 true 或 false。判断数组内是否包含某个元素。例如：|\ | |(exist? 数组元素)|```sql|\ | |```|(exist? ["a" "b"] "a")|\ | | |```|\ | | ||\ | | |返回 `true`。 | |获取数组的子数组 |```sql|返回字符串的子数组，返回值为 [from to)。例如：|\ | |(slice 数组 from to)|```sql|\ | |```|(slice [1 2 3 4] 1 3)|\ | | |```|\ | | ||\ | | |返回 `[2 3]`。 | * 哈希函数 |**功能** |**语法** |**返回值** | |---|---|---| |访问 hash 元素 |* 语法一：|返回访问 hash 元素。例如：|\ | | ```sql||\ | | (hget hash key)|* 示例一：|\ | | ```| ```sql|\ | | | (hget {"a" 2 "b" 3} "a")|\ | |* 语法二：| ```|\ | | ```sql| |\ | | (hget hash key defalut)| 返回 `2`。|\ | | ```|* 示例二：|\ | | | ```sql|\ | | | (hget {"a" 2 "b" 3} "c" 0)|\ | | | ```|\ | | | |\ | | | 由于访问的元素 `key` 不存在，则返回自定义的默认值 `0`。|\ | | | :::tip|\ | | | 默认值 defalut 支持自定义。|\ | | ||\ | | | :::| |设置 hash 元素 |```sql|返回成功设置后的 hash 元素。例如|\ | |(def h {"key1" value1})|```sql|\ | |(hset! h "key1" 参数1)|(def h {"a" 3})|\ | |```|(hset! h "a" 2)|\ | | |```|\ | | ||\ | | |返回 `{"a" 2}`。 | |删除 hash 元素 |```sql|返回删除后的 hash 元素。例如：|\ | |(def h {"key1" value1 "key2" value2})|```sql|\ | |(hdel! h "key")|(def h {"a" 3 "b" 2})|\ | |```|(hdel! h "a")|\ | | |```|\ | | ||\ | | |返回 `{"b" 2}`。 | |探测 hash 是否包含 key |```sql|返回值如下：|\ | |(exist? {"参数1" "参数2"} "参数1")||\ | |```|* true：存在。|\ | | |* false：不存在。|\ | | ||\ | | |示例如下：|\ | | |```sql|\ | | |(exist? {"a" "b"} "a")|\ | | |```|\ | | ||\ | | |返回 `true`。 | * 通用容器函数 |**功能** |**语法** |**说明** | |---|---|---| |在字符串或数组后添加元素 |* 在数组后添加元素|返回一个新的数组或字符串。例如：|\ | | ```sql||\ | | (append [参数1 参数2] 元素)|* 在数组后添加元素。|\ | | ```| ```sql|\ | | | (append [1 2] 3)|\ | |* 在字符串后添加元素| ```|\ | | ```sql| |\ | | (append "字符串" #元素)| 返回一个新的数组 `[1 2 3]`。|\ | | ```|* 在字符串后添加元素。|\ | | | ```sql|\ | | | (append "ab" #c)|\ | | | ```|\ | | | |\ | | | 返回一个新的字符串 `"abc"`。 | |连接多个数组或字符串 |* 连接多个数组|返回一个新的数组或字符串。例如：|\ | | ```sql||\ | | (concat [参数1 参数2] [参数3 参数4])|* 连接多个数组。|\ | | ```| ```sql|\ | | | (concat [1 2] [3 4])|\ | |* 连接多个字符串| ```|\ | | ```sql| |\ | | (concat "字符串 1" "字符串 2")| 返回一个新的数组 `[1 2 3 4]`。|\ | | ```|* 连接多个字符串。|\ | | | ```sql|\ | | | (concat "ab" "cd")|\ | | | ```|\ | | | |\ | | | 返回一个新的字符串 `"abcd"`。 | * 字节流函数 |**功能** |**语法** |**返回值** | |---|---|---| |将字节流转换为字符串 |```sql|返回一个字符串。例如：|\ | |(string 字节流)|```sql|\ | |```|(string 0B68656c6c6f)|\ | | |```|\ | | ||\ | | |返回 `hello`。 | |将字符串转换为字节流 |```sql|返回一个字节流。例如：|\ | |(bytes "字符串")|```sql|\ | |```|(bytes "abc")|\ | | |```|\ | | ||\ | | |返回 `0B616263`。 | * 高阶函数 |**功能** |**语法** |**返回值** | |---|---|---| |将函数应用到列表或数组内每一个元素 |```sql|返回数组中每个元素被应用指定函数的数组或列表。例如：|\ | |(map 函数数组)||\ | |```|* 将函数应用到列表内的每一个元素。|\ | | | ```sql|\ | | | (map add3 [1 2 3])|\ | | | ```|\ | | | |\ | | ||\ | | |返回一个新的数组 `[4 5 6]`。|\ | | ||\ | | |* 将函数应用到数组内的每一元素|\ | | | ```sql|\ | | | (map int ["1" "2" "3"]|\ | | | ```|\ | | | |\ | | ||\ | | |返回一个新的数组 `[1 2 3]`。 | |使用指定的函数过滤数组 |```sql|当过滤函数返回 `true` 时则保留元素，否则将丢弃。例如：|\ | |(filter 函数数组)|```sql|\ | |```|(defn even? [a] (= 0 (mod a 2)))|\ | | |(filter even? [1 2 3 4])|\ | | |```|\ | | ||\ | | |返回结果为 `[2 4]`。 | |对数组或列表进行聚合操作 |```sql|返回数组或列表的聚合结果。例如：|\ | |(foldl 函数初始值数组)||\ | |```|* 对数组进行聚合。|\ | | | ```sql|\ | | | (foldl + 0 [1 2 3 4])|\ | | | ```|\ | | | |\ | | | 返回结果为 `10`。|\ | | |* 对列表进行聚合。|\ | | | ```sql|\ | | | (foldl * 1 [1 2 3 4])|\ | | | ```|\ | | | |\ | | ||\ | | |返回结果为 `24`。 | * 类型自省 |**功能** |**语法** |**返回值** | |---|---|---| |零值判断 |zero? |当目标参数为 `0`、`0.0` 时，则返回 `true`，否则返回 `false`。 | |NULL 判断 |null? |当目标参数为 `()` 时，则返回 `true`，否则返回 `false`。 | |空判断 |empty? |当目标参数为 `()`、`[]`、`""` 或 `{}` 时，则返回 `true`，否则返回 `false`。 | |是否为 List |list? |当目标参数是列表时，则返回 `true`，否则返回 `false`。 | |是否为数组 |array? |当目标参数的数据类型是 array 时，则返回 `true`，否则返回 `false`。 | |是否为数字 |number? |当目标参数的数据类型是 int、char 或 float 时，则返回 `true`，否则返回 `false`。 | |是否为整数 |int? |当目标参数的数据类型是 integer 时，则返回 `true`，否则返回 `false`。 | |是否为浮点数 |float? |当目标参数的数据类型是 float 时，则返回 `true`，否则返回 `false`。 | |是否为字符 |char? |当目标参数的数据类型是 char 时，则返回 `true`，否则返回 `false`。 | |是否为字符串 |string? |当目标参数的数据类型是 string 时，则返回 `true`，否则返回 `false`。 | |是否为符号 |symbol? |当目标参数的数据类型是 symbol 时，则返回 `true`，否则返回 `false`。 | |是否为哈希值 |hash? |当目标参数的数据类型是 hash 时，则返回 `true`，否则返回 `false`。 | |是否为字节流 |bytes? |当目标参数的数据类型是 bytes 时，则返回 `true`，否则返回 `false`。 | |是否返回指定数据类型 |type |当返回的目标参数的数据类型是 symbol、string、array、bool、char、float、function、hash、int、list 或 bytes 时，则返回 `true`，否则返回 `false`。 | ### 扩展函数 * 表达式扩展函数 * 运算扩展函数 |**功能** |**语法** |**返回值** | |---|---|---| |代数左移 |```sql|返回代数左移后的结果。例如：|\ | |(sla 操作的数据移动位数)|```sql|\ | |```|(sla 1 3)|\ | | |```|\ | | ||\ | | |返回 `8`。 | |代数右移 |```sql|返回代数右移后的结果。例如：|\ | |(sra 操作的数据移动位数)|```sql|\ | |```|(sra 1 1)|\ | | |```|\ | | ||\ | | |返回 `0`。 | |8bit 逻辑左移 |```sql|返回 8bit 逻辑左移后的结果。例如：|\ | |(sll8 操作的数据移动位数)||\ | |```|* 示例一|\ | | | ```sql|\ | | | (sll8 1 1)|\ | | | ```|\ | | | |\ | | ||\ | | |返回 `2`。|\ | | ||\ | | |* 示例二|\ | | | ```sql|\ | | | (sll8 -1 1)|\ | | | ```|\ | | | |\ | | ||\ | | |返回 `254`。 | |16bit 逻辑左移 |```sql|返回 16bit 逻辑左移后的结果。例如：|\ | |(sll16 操作的数据移动位数)||\ | |```|* 示例一：|\ | | | ```sql|\ | | | (sll16 1 1)|\ | | | ```|\ | | | |\ | | ||\ | | |返回 `2`。|\ | | ||\ | | |* 示例二：|\ | | | ```sql|\ | | | (sll16 -1 1)|\ | | | ```|\ | | | |\ | | ||\ | | |返回 `65534`。 | |32bit 逻辑左移 |```sql|返回 32bit 逻辑左移后的结果。例如：|\ | |(sll32 操作的数据移动位数)||\ | |```|* 示例一：|\ | | | ```sql|\ | | | (sll32 1 1)|\ | | | ```|\ | | | |\ | | | 返回 `2`。|\ | | |* 示例二：|\ | | | ```sql|\ | | | (sll32 -1 1)|\ | | | ```|\ | | | |\ | | | 返回 `4294967294`。 | |64bit 逻辑左移 |```sql|返回 64bit 逻辑左移的结果。例如：|\ | |(sll64 操作的数据移动位数)||\ | |```|* 示例一|\ | | | ```sql|\ | | | (sll64 1 1)|\ | | | ```|\ | | | |\ | | ||\ | | |返回 `2`。|\ | | ||\ | | |* 示例二：|\ | | | ```sql|\ | | | (sll64 -1 1)|\ | | | ```|\ | | | |\ | | ||\ | | |返回 `18446744073709551614`。 | |8bit 逻辑右移 |```sql|返回 8bit 逻辑右移的结果。例如：|\ | |(srl8 操作的数据移动位数)||\ | |```|* 示例一：|\ | | | ```sql|\ | | | (srl8 2 1)|\ | | | ```|\ | | | |\ | | | 返回 `1`。|\ | | |* 示例二：|\ | | | ```sql|\ | | | (srl8 -2 1)|\ | | | ```|\ | | | |\ | | | 返回 `127`。 | |16bit 逻辑右移 |```sql|返回 16bit 逻辑右移的结果。|\ | |(srl16 操作的数据移动位数)||\ | |```|* 示例一|\ | | | ```sql|\ | | | (srl16 2 1)|\ | | | ```|\ | | | |\ | | | 返回 `1`。|\ | | |* 示例二：|\ | | | ```sql|\ | | | (srl16 -2 1)|\ | | | ```|\ | | | |\ | | | 返回 `32767`。 | |32bit 逻辑右移 |```sql|返回 32bit 逻辑右移的结果。例如：|\ | |(srl32 操作的数据移动位数)||\ | |```|* 示例一：|\ | | | ```sql|\ | | | (srl32 2 1)|\ | | | ```|\ | | | |\ | | | 返回 `1`。|\ | | |* 示例二：|\ | | | ```sql|\ | | | (srl32 -2 1)|\ | | | ```|\ | | | |\ | | | 返回 `2147483647`。 | |64bit 逻辑右移 |```sql|返回 64bit 逻辑右移的结果。例如：|\ | |(srl64 操作的数据移动位数)||\ | |```|* 示例一：|\ | | | ```sql|\ | | | (srl64 2 1)|\ | | | ```|\ | | | |\ | | | 返回 `1`。|\ | | |* 示例二：|\ | | | ```sql|\ | | | (srl64 -2 1)|\ | | | ```|\ | | | |\ | | | 返回 `9223372036854775807`。 | |bit 与 |```sql|返回 bit 与的结果。例如：|\ | |(bit-and 操作的数据移动位数)|```sql|\ | |```|(bit-and 3 2)|\ | | |```|\ | | ||\ | | |返回 `2`。 | |bit 或 |```sql|返回 bit 或的结果。例如：|\ | |(bit-or 操作的数据移动位数)|```sql|\ | |```|(bit-or 3 1)|\ | | |```|\ | | ||\ | | |返回 `3`。 | |bit 异或 |```sql|返回 bit 异或的结果。例如：|\ | |(bit-xor 操作的数据移动位数)|```sql|\ | |```|(bit-xor 3 1)|\ | | |```|\ | | ||\ | | |返回 `2`。 | |bit 取非 |```sql|返回 bit 取非的结果。例如：|\ | |(bit-not 操作的数据移动位数)|```sql|\ | |```|(bit-not 2)|\ | | |```|\ | | ||\ | | |返回 `-3`。 | * 时间扩展函数 |**功能** |**语法** |**返回值** | |---|---|---| |返回当前时间 |```sql|返回当前时间。例如：|\ | |(time/now)|```sql|\ | |```|(time/now)|\ | | |```|\ | | ||\ | | |返回结果为当前的时间点。 | |格式化时间 |```sql|支持将时间转换为 unix 时间戳，单位为秒或毫秒，也支持将时间按指定格式转换为字符串。例如：|\ | |(time/format 时间转换目标)||\ | |```|* 将时间转换为 unix 时间戳，单位为秒。|\ | | | ```sql|\ | | | (time/format (time/now) 'timestamp)|\ | | | ```|\ | | | |\ | | |* 将时间转换为 unix 时间戳，单位为毫秒。|\ | | | ```sql|\ | | | (time/format (time/now) 'timestamp-ms)|\ | | | ```|\ | | | |\ | | |* 将时间按指定格式转换为字符串。|\ | | | ```sql|\ | | | (time/format (time/now) "2006-01-02 15:04:05")|\ | | | ```|\ | | | | |时间解析 |```sql|返回时间解析结果。例如：|\ | |(time/parse 解析目标)||\ | |```|* 从 unix 时间戳中解析时间。|\ | | | ```sql|\ | | | (time/parse 1656988237)|\ | | | ```|\ | | | |\ | | |* 使用默认的 layout(2006\-01\-02 15:04:05)，从字符串中解析时间。|\ | | | ```sql|\ | | | (time/parse "2015-02-23 23:54:55")|\ | | | ```|\ | | | |\ | | |* 指定 layout 和时间字符串，从字符串中解析时间。|\ | | | ```sql|\ | | | (time/parse "2014-Feb-04" "2006-Jan-02")|\ | | | ```|\ | | | |\ | | |* 指定 layout、时间字符串和时区，从字符串解析时间。|\ | | | ```sql|\ | | | (time/parse "2014-Feb-04" "2006-Jan-02" "Asia/Shanghai")|\ | | | ```|\ | | | | |北京时间解析 |```sql|```sql|\ | |time/parse-beijing|(time/parse-beijing "2015-02-23 23:54:55")|\ | |```|```|\ | | | | |时间计算 |```sql|返回计算后的时间。例如：|\ | |(time/add-date 时间 n年 n月 n日)|```sql|\ | |```|(time/add-date (time/now) 1 2 3)|\ | | |```|\ | | ||\ | | |返回在当前时间的基础上，年份加 1 年、月份加 2 个月、日加 3 天。 | |^^|```sql|返回计算后的时间。例如：|\ | |(time/add 时间 n 年或 n 月或 n 日或 n 小时或 n 分钟或 n 秒)||\ | |```|* 在当前时间的基础上，年份加 1 年。|\ | | | ```sql|\ | | | (time/add (time/now) 1 'year)|\ | | | ```|\ | | | |\ | | |* 在当前时间的基础上，月份加 1 个月。|\ | | | ```sql|\ | | | (time/add (time/now) 1 'month)|\ | | | ```|\ | | | |\ | | |* 在当前时间的基础上，日加 1 天。|\ | | | ```sql|\ | | | (time/add (time/now) 1 'day)|\ | | | ```|\ | | | |\ | | |* 在当前时间的基础上，小时加 1 小时。|\ | | | ```sql|\ | | | (time/add (time/now) 1 'hour)|\ | | | ```|\ | | | |\ | | |* 在当前时间的基础上，分钟增加 1 分钟。|\ | | | ```sql|\ | | | (time/add (time/now) 1 'minute)|\ | | | ```|\ | | | |\ | | |* 在当前时间的基础上，秒增加 1 秒。|\ | | | ```sql|\ | | | (time/add (time/now) 1 'second)|\ | | | ```|\ | | | | |^^|```sql|返回 time1 和 time2 的时间差值，单位为秒。 |\ | |(time/sub time1 time2)| |\ | |```| |\ | | | | |返回年份 |```sql|返回时间的年份。例如：|\ | |(time/year 时间)|```sql|\ | |```|(time/year (time/now))|\ | | |```|\ | | ||\ | | |返回当前时间的年份。 | |返回月份 |```sql|返回时间的月份。例如：|\ | |(time/month 时间)|```sql|\ | |```|(time/month (time/now))|\ | | |```|\ | | ||\ | | |返回当前时间的月份。 | |返回日 |```sql|返回时间的日。例如：|\ | |(time/day 时间)|```sql|\ | |```|(time/day (time/now))|\ | | |```|\ | | ||\ | | |返回当前时间的日。 | |返回小时 |```sql|返回时间的小时。例如：|\ | |(time/hour 时间)|```sql|\ | |```|(time/hour (time/now))|\ | | |```|\ | | ||\ | | |返回当前时间的小时。 | |返回分钟 |```sql|返回时间的分钟。例如：|\ | |(time/minute 时间)|```sql|\ | |```|(time/minute (time/now))|\ | | |```|\ | | ||\ | | |返回当前时间的分钟。 | |返回秒数 |```sql|返回时间的秒数。例如：|\ | |(time/second 时间)|```sql|\ | |```|(time/second (time/now))|\ | | |```|\ | | ||\ | | |返回当前时间的秒数。 | |返回星期数 |```sql|返回时间的星期数。例如：|\ | |(time/weekday 时间)|```sql|\ | |```|(time/weekday (time/now))|\ | | |```|\ | | ||\ | | |返回当前时间的星期数。 | * 字符串扩展函数 |**功能** |**语法** |**返回值** | |---|---|---| |验证是否包含字符串 |```sql|返回值如下：|\ | |(str/contains? "字符串" "字符")||\ | |```|* `true`：表示该字符存在于字符串内。|\ | | |* `false`：表示该字符不存在于字符串内。|\ | | ||\ | | |例如：|\ | | |```sql|\ | | |(str/contains? "abc" "b")|\ | | |```|\ | | ||\ | | |返回 `true`。 | |查询子字符串的数量 |```sql|返回在字符串内包含多少个子字符串。例如：|\ | |(str/count "字符串" "子字符串")|```sql|\ | |```|(str/count "abcc" "c")|\ | | |```|\ | | ||\ | | |返回 `2`。 | |验证字符串是否以某个子串为前缀 |```sql|返回值如下：|\ | |(str/start-with? "字符串" "字符")||\ | |```|* `true`：表示以该字符为前缀。|\ | | |* `false`：表示不以该字符为前缀。|\ | | ||\ | | |例如：|\ | | |```sql|\ | | |(str/start-with? "abc" "a")|\ | | |```|\ | | ||\ | | |返回 `true`。 | |验证字符串是否以某个子串为后缀 |```sql|返回值如下：|\ | |(str/end-with? "字符串" "字符")||\ | |```|* `true`：表示以该字符为后缀。|\ | | |* `false`：表示不以该字符为后缀。|\ | | ||\ | | |例如：|\ | | |```sql|\ | | |(str/end-with? "abc" "c")|\ | | |```|\ | | ||\ | | |返回 `true`。 | |返回某个目标字符在字符内第一次出现时的下标 |```sql|返回该字符在字符串的下标。例如：|\ | |(str/index "字符串" "目标字符")|```sql|\ | |```|(str/index "abc" "b")|\ | | |```|\ | | ||\ | | |返回 `1`。 | |验证字符串是否都是字母 |```sql|返回值如下：|\ | |(str/alpha? "字符串")||\ | |```|* `true`：表示字符串内都是字母。|\ | | |* `false`：表示字符串内不全是字母。|\ | | ||\ | | |例如：|\ | | |```sql|\ | | |(str/alpha? "ab1")|\ | | |```|\ | | ||\ | | |返回 `false`。 | |验证字符串是否都是数字 |```sql|返回值如下：|\ | |(str/digit? "字符串")||\ | |```|* `true`：表示字符串内都是数字。|\ | | |* `false`：表示字符串内不全是数字。|\ | | ||\ | | |例如：|\ | | |```sql|\ | | |(str/digit? "ab1")|\ | | |```|\ | | ||\ | | |返回 `false`。 | |拼接字符串 |```sql|返回字符串的拼接结果，支持任意拼接符拼接字符串。例如：|\ | |(str/join ["字符串1" "字符串2"] "拼接符")|```sql|\ | |```|(str/join ["a" "b"] "_")|\ | | |```|\ | | ||\ | | |返回 `"a_b"`。 | |将字符串内的大写字母转换为小写字母 |```sql|返回转换为小写字母的字符串。例如：|\ | |(str/lower "字符串")|```sql|\ | |```|(str/lower "ABC")|\ | | |```|\ | | ||\ | | |返回 `"abc"`。 | |将字符串内的小写字母转换为大写字母 |```sql|返回转换为大写字母的字符串。例如：|\ | |(str/upper "字符串")|```sql|\ | |```|(str/upper "abc")|\ | | |```|\ | | ||\ | | |返回 `"ABC"`。 | |替换字符串内的子串 |```sql|返回替换后的字符串。例如：|\ | |(str/replace "字符串" "字符串的子串" "目标子串")|```sql|\ | |```|(str/replace "abc" "b" "B")|\ | | |```|\ | | ||\ | | |返回 `"aBc"`。 | |分割字符串 |```sql|返回分割后的数组，需指定字符串间的拼接符分割字符串，字符串支持任意拼接符拼接。例如：|\ | |(str/split "字符串1 拼接符字符串2" "拼接符")|```sql|\ | |```|(str/split "a_b" "_")|\ | | |```|\ | | ||\ | | |返回 `["a" "b"]`。 | |将字符串的首字母转换为大写字母 |```sql|返回转换后的字符串。例如：|\ | |(str/title "字符串")|```sql|\ | |```|(str/title "abc")|\ | | |```|\ | | ||\ | | |返回 `"Abc"`。 | |验证字符串的首字母是否为大写字母 |```sql|返回值如下：|\ | |(str/title? "字符串")||\ | |```|* `true`：表示字符串的首字母是大写字母。|\ | | |* `false`：表示字符串的首字母不是大写字母。|\ | | ||\ | | |例如：|\ | | |```sql|\ | | |(str/title? "abc")|\ | | |```|\ | | ||\ | | |返回 `false`。 | |删除字符串前缀 |```sql|返回删除了前缀的字符串。例如：|\ | |(str/trim-prefix "字符串" "前缀")|```sql|\ | |```|(str/trim-prefix "_abc" "_")|\ | | |```|\ | | ||\ | | |返回 `"abc"`。 | |删除字符串后缀 |```sql|返回删除了后缀的字符串。例如：|\ | |(str/trim-suffix "字符串" "后缀")|```sql|\ | |```|(str/trim-suffix "abc_" "_")|\ | | |```|\ | | ||\ | | |返回 `"abc"`。 | |删除字符串的前后空格 |```sql|返回删除了前后空格后的字符串。例如：|\ | |(str/trim-space " 字符串 ")|```sql|\ | |```|(str/trim-space " abc ")|\ | | |```|\ | | ||\ | | |返回 `"abc"`。 | |计算字符串的 MD5 值 |```sql|返回字符串的 MD5 值。例如；|\ | |(str/md5 "字符串")|```sql|\ | |```|(str/md5 "abc")|\ | | |```|\ | | ||\ | | |返回 `"900150983cd24fb0d6963f7d28e17f72"`。 | |脱敏字符串的敏感信息 |```sql|返回脱敏后的字符串，支持任意字符进行脱敏。例如；|\ | |(str/mask "字符串" 开始索引结束索引 "*")||\ | |```|* 示例一|\ | | | ```sql|\ | | | (str/mask "hello" 1 2 "*")|\ | | | ```|\ | | | |\ | | | 返回 `"h**lo"`。|\ | | |* 示例二|\ | | | ```sql|\ | | | (str/mask "hello" 1 -1 "*")|\ | | | ```|\ | | | |\ | | | `1 -1` 表示从开始索引到结束索引将全部遮盖。则本示例返回 `"h****"`。 | * 数据操作扩展函数 * 内核扩展函数 |**功能** |**语法** |**返回值** | |---|---|---| |设置函数别名 |```sql|为原函数设置别名。例如：|\ | |(alias 别名原名)|本示例表示为加法运算设置别名 `plus`。|\ | |```|```sql|\ | | |(alias plus +)|\ | | |```|\ | | ||\ | | |当使用加法运算时，您可以通过以下语法进行加法运算：|\ | | |```sql|\ | | |(plus 1 2)|\ | | |```|\ | | ||\ | | |返回 `3`。 | |打印函数 |* 语法一：|输出函数。例如：|\ | | ```sql||\ | | (println 参数)|* 语法一示例：|\ | | ```| ```sql|\ | | | (println "hello world")|\ | |* 语法二：| ```|\ | | ```sql| |\ | | (printf "格式化串" 参数1 参数2...)| 输出`"hello world"`。|\ | | ```|* 语法二示例：|\ | | | ```sql|\ | |* 语法三：| (printf "Hi, %v" "Jack")|\ | | ```sql| ```|\ | | (print 参数)| |\ | | ```| :::tip|\ | | | 默认使用 %v 当作占位符|\ | | | :::|\ | | | 输出 `"Hi, Jack"`。 | * JSON 扩展函数 |**功能** |**语法** |**返回值** | |---|---|---| |将 JSON 对象转换为字符串 |```sql|返回成功转换后的字符串。例如：|\ | |(json/stringify {"key1" value1 "key2" value2 "key3" value3})|```sql|\ | |```|(json/stringify {"a" 1 "b" '() "c" true})|\ | | |```|\ | | ||\ | | |返回 `{"a":1,"b":null,"c":true}`。 | |将字符串转换为 JSON 对象 |```sql|返回成功转换后的 JSON 对象。例如：|\ | |(json/parse "{"key1" : value1, "key2" : value2, "key3" : value3}")|```sql|\ | |```|(json/parse "{"a":1,"b":null,"c":true}")|\ | | |```|\ | | ||\ | | |返回 `{"a" 1 "b" () "c" true}`。 | DTS ETL 和 JSON 之间的映射规则如下表所示： |**DTS ETL 语法构件** |**JSON** | |---|---| |integer |integer | |float |float | |string |string | |symbol |string | |() |null | |array |array | |bytes |base64 encoded string | |list |array | |hash |object | |bool |bool | |char |Integer value of char | * Base64 扩展 |**功能** |**语法** |**返回值** | |---|---|---| |将 Base64 编码的字符串转换为字节流 |```sql|返回转换成功的字节流。例如：|\ | |(base64/decode "Base64")|```sql|\ | |```|(base64/decode "aGVsbG8=")|\ | | |```|\ | | ||\ | | |返回 `"0B68656c6c6f"`。 | |将字节流转换为 Base64 编码 |```sql|返回转换成功的 Base64。例如：|\ | |(base64/encode 字节流)|```sql|\ | |```|(base64/encode 0B68656c6c6f)|\ | | |```|\ | | ||\ | | |返回 `"aGVsbG8="`。 | ### 领域函数 |**功能** |**语法** |**返回值** | |---|---|---| |删除当前记录 |```sql|删除当前数据行，无返回结果。 |\ | |(dts/drop)| |\ | |```| |\ | | | | |查询当前记录是否已被丢弃 |```sql|返回类型为 bool。 |\ | |(dts/dropped?)| |\ | |```| |\ | | | | |返回当前记录的数据库的名称 |```sql|返回类型为 string。 |\ | |(dts/db)| |\ | |```| |\ | | | | |返回当前记录的表格的名称 |```sql|返回类型为 string。 |\ | |(dts/table)| |\ | |```| |\ | | | | |返回当前记录的事件类型 |```sql|返回类型为 string。支持以下事件类型：|\ | |(dts/event)||\ | |```|* BEGIN|\ | | |* COMMIT|\ | | |* DDL|\ | | |* DML | |返回当前记录的 DML 类型 |```sql|返回类型为 string。支持以下 DML 类型：|\ | |(dts/dml)||\ | |```|* `INSERT`：增加。|\ | | |* `UPDATE`：更新。|\ | | |* `DELETE`：删除。 | |设置 Tag |```sql|无返回类型。 |\ | |(dts/set-tag)| |\ | |```| |\ | | | | |查询记录的某列是否为 null |```sql|返回类型为 bool。 |\ | |(dts/column-null? COLUMN)| |\ | |```| |\ | | | | |查询记录的某列是否存在 |```sql|返回类型为 bool。 |\ | |(dts/column-exist? COLUMN)| |\ | |```| |\ | | | | |验证当前事件是否是 DDL 事件 |```sql|返回类型为 bool。 |\ | |(dts/ddl?)| |\ | |```| |\ | | | | |验证当前事件是否是 DML 事件 |```sql|返回类型为 bool。 |\ | |(dts/dml?)| |\ | |```| |\ | | | | |验证当前事件是否是 DML UPDATE |```sql|返回类型为 bool。 |\ | |(dts/update?)| |\ | |```| |\ | | | | |验证当前事件是否是 DML DELETE |```sql|返回类型为 bool。 |\ | |(dts/delete?)| |\ | |```| |\ | | | | |验证当前事件是否是 DML INSERT |```sql|返回类型为 bool。 |\ | |(dts/insert?)| |\ | |```| |\ | | | | |返回记录的某个字段值 |```sql|返回的字段类型支持 string、int、bool 或 float 等。|\ | |(dts/column COLUMN DEFAULT)|:::tip|\ | |```|当该列不存在或为空时，则给定默认值 DEFAULT。|\ | | ||\ | | |:::| |返回当前记录所有字段名 |```sql|返回类型为字符串数组。 |\ | |(dts/columns)| |\ | |```| |\ | | | | |设置字段值 |```sql|无返回类型。 |\ | |(dts/set-column COLUMN VALUE)| |\ | |```| |\ | | | | |使用指定函数对某列值做变换 |```sql|无返回类型。 |\ | |(dts/map-column COLUMN FUNCTION)| |\ | |```| |\ | | | | |重命名字段 |* 将列 `oldCol` 重命名为 `newCol`，且不保留原字段：|无返回类型。 |\ | | ```sql| |\ | | (dts/rename-column "oldCol" "newCol")| |\ | | ```| |\ | | | |\ | |* 将列 `oldCol` 重命名为 `newCol`，保留原字段：| |\ | | ```sql| |\ | | (dts/rename-column "oldCol" "newCol" true)| |\ | | ```| |\ | | | | |过滤某列 |```sql|无返回类型。 |\ | |(dts/drop-column COLUMN)| |\ | |```| |\ | | | | |设置指定列为主键，尤其在异构表同步场景下修改主键列 |```sql|无返回类型。 |\ | |(dts/use-index "column1" "column2")| |\ | |```| |\ | | | | |（语法糖）对某个表执行某些操作 |```sql|无返回类型。 |\ | |(dts/match-table TABLE EXPRESSIONS)| |\ | |```| |\ | | | | |（语法糖）如果是对表的 INSERT 操作则执行某些操作 |```sql|无返回类型。 |\ | |(dts/match-insert-on-table TABLE EXPRESSIONS)| |\ | |```| |\ | | | | |（语法糖）如果是对表的 UPDATE 操作则执行某些操作 |```sql|无返回类型。 |\ | |(dts/match-update-on-table TABLE EXPRESSIONS)| |\ | |```| |\ | | | | |（语法糖）如果是对表的 DELETE 操作则执行某些操作 |```sql|无返回类型。 |\ | |(dts/match-delete-on-table TABLE EXPRESSIONS)| |\ | |```| |\ | | | | |（语法糖）如果是 DML 事件执行某些操作 |```sql|无返回类型。 |\ | |(dts/match-dml-on-table TABLE EXPRESSIONS)| |\ | |```| |\ | | | | |（语法糖）正则匹配某个表（不带库名匹配）并执行某些操作 |```sql|无返回类型。 |\ | |(dts/match-table-regexp TABLE EXPRESSIONS)| |\ | |```| |\ | | | | |（语法糖）正则匹配某个表（带库名匹配）并执行某些操作 |```sql|无返回类型。 |\ | |(dts/match-db-table-regexp DBTABLE EXPRESIONS)| |\ | |```| |\ | | | | ## MySQL 字段类型 MySQL 的字段类型在 DSL 语法中对应的类型如下表所示。 |**MySQL 字段类型** |**示例** |**DSL** **字段类型** |**示例** | |---|---|---|---| |bit |```sql|bytes |```lisp|\ | |b'111'| |0B07|\ | |```| |```|\ | | | | | |tinyint |```sql|int |```lisp|\ | |3| |3|\ | |```| |```|\ | | | | | |bool |```sql|bool |```lisp|\ | |true| |true|\ | |```| |```|\ | | | | | |smallint |```sql|int |```lisp|\ | |3| |3|\ | |```| |```|\ | | | | | |mediumint |```sql|int |```lisp|\ | |3| |3|\ | |```| |```|\ | | | | | |int |```sql|int |```lisp|\ | |3| |3|\ | |```| |```|\ | | | | | |integer |```sql|int |```lisp|\ | |3| |3|\ | |```| |```|\ | | | | | |bigint |```sql|int |```lisp|\ | |3| |3|\ | |```| |```|\ | | | | | |bigint unsigned |```sql|int |```lisp|\ | |18446744073709551615| |18446744073709551615|\ | |```| |```|\ | | | | | |decimal |```sql|float |```lisp|\ | |333.333| |333.333|\ | |```| |```|\ | | | | | |dec |```sql|float |```lisp|\ | |333.333| |333.333|\ | |```| |```|\ | | | | | |float |```sql|float |```lisp|\ | |1.1| |1.1|\ | |```| |```|\ | | | | | |double |```sql|float |```lisp|\ | |1.1| |1.1|\ | |```| |```|\ | | | | | |date |```sql|string |```lisp|\ | |'2001-01-01'| |"2001-01-01"|\ | |```| |```|\ | | | | | |datetime |```sql|string |```lisp|\ | |'2001-01-01 01:01:01'| |"2001-01-01 01:01:01"|\ | |```| |```|\ | | | | | |timestamp |```sql|time |```lisp|\ | |'2001-01-01 01:01:01'| |(time/parse "2001-01-01 01:01:01")|\ | |```| |```|\ | | | | | |time |```sql|string |```lisp|\ | |'01:01:01'| |"01:01:01"|\ | |```| |```|\ | | | | | |year |```sql|int |```lisp|\ | |2001| |2001|\ | |```| |```|\ | | | | | |char |```sql|string |```lisp|\ | |'abc'| |"abc"|\ | |```| |```|\ | | | | | |varchar |```sql|string |```lisp|\ | |'abc'| |"abc"|\ | |```| |```|\ | | | | | |binary |```sql|bytes |```lisp|\ | |'abc'| |0B616263|\ | |```| |```|\ | | | | | |varbinary |```sql|bytes |```lisp|\ | |'abc'| |0B616263|\ | |```| |```|\ | | | | | |tinyblob |```sql|bytes |```lisp|\ | |'abc'| |0B616263|\ | |```| |```|\ | | | | | |tinytext |```sql|string |```lisp|\ | |'abc'| |"abc"|\ | |```| |```|\ | | | | | |blob |```sql|bytes |```lisp|\ | |'abc'| |0B616263|\ | |```| |```|\ | | | | | |text |```sql|string |```lisp|\ | |'abc'| |"abc"|\ | |```| |```|\ | | | | | |mediumblob |```sql|bytes |```lisp|\ | |'abc'| |0B616263|\ | |```| |```|\ | | | | | |mediumtext |```sql|string |```lisp|\ | |'abc'| |"abc"|\ | |```| |```|\ | | | | | |longblob |```sql|bytes |```lisp|\ | |'abc'| |0B616263|\ | |```| |```|\ | | | | | |longtext |```sql|string |```lisp|\ | |'abc'| |"abc"|\ | |```| |```|\ | | | | | |enum |```sql|int |```lisp|\ | |'a'| |1|\ | |```| |```|\ | | | | | |set |```sql|int |```lisp|\ | |'a,b'| |3|\ | |```| |```|\ | | | | | |geometry |```sql|bytes |```lisp|\ | |GeomFromText('POINT(1 1)')| |0B000000000101000000000000000000f03f000000000000f03f|\ | |```| |```|\ | | | | | |point |```sql|bytes |```lisp|\ | |GeomFromText('POINT(1 1)')| |0B000000000101000000000000000000f03f000000000000f03f|\ | |```| |```|\ | | | | | |linestring |```sql|bytes |```lisp|\ | |GeomFromText('LINESTRING(0 0,1 1,2 2)')| |0B000000000101000000000000000000f03f000000000000f03f|\ | |```| |```|\ | | | | | |polygon |```sql|bytes |```lisp|\ | |GeomFromText('POLYGON((0 0,10 0,10 10,0 10,0 0),(5 5,7 5,7 7,5 7, 5 5))')| |0B000000000101000000000000000000f03f000000000000f03f|\ | |```| |```|\ | | | | | |multipoint |```sql|bytes |```lisp|\ | |GeomFromText('MULTIPOINT(1 1,2 2)')| |0B000000000101000000000000000000f03f000000000000f03f|\ | |```| |```|\ | | | | | |multilinestring |```sql|bytes |```lisp|\ | |GeomFromText('MULTILINESTRING((0 0,1 1,2 2),(0 0,2 2,4 4))')| |0B000000000101000000000000000000f03f000000000000f03f|\ | |```| |```|\ | | | | | |multipolygon |```sql|bytes |```lisp|\ | |GeomFromText(‘MULTIPOLYGON(((0 0,10 0,10 10,0 10,0 0)),((5 5,7 5,7 7,5 7, 5 5)))’)| |0B000000000101000000000000000000f03f000000000000f03f|\ | |```| |```|\ | | | | | |geometrycollection |```sql|bytes |```lisp|\ | |GeomFromText('GEOMETRYCOLLECTION(POINT(2 1),LINESTRING(0 0,1 1,2 2,3 3,4 5))')| |0B000000000101000000000000000000f03f000000000000f03f|\ | |```| |```|\ | | | | | |json |```sql|string |```lisp|\ | |'{"key":"value"}'| |"{\"key\": \"value\"}"|\ | |```| |```|\ | | | | | ## 相关文档 * [创建并启动数据同步任务](../6390/118534) * [如何在 DTS 同步任务中配置 ETL](../6390/141465)