Linkis-Cli 方式使用

    您可以参照下面的例子简单地向Linkis提交任务

    第一步，检查conf/目录下是否存在默认配置文件，且包含以下配置：

    第二步，进入linkis安装目录，输入指令：

    1.     ./bin/linkis-cli -engineType spark-2.4.3 -codeType sql -code "select count(*) from testdb.test;"  -submitUser hadoop -proxyUser hadoop

    第三步，您会在控制台看到任务被提交到linkis并开始执行的信息。

    linkis-cli目前仅支持同步提交，即向linkis提交任务后，不断询问任务状态、拉取任务日志，直至任务结束。任务结束时状态如果为成功，linkis-cli还会主动拉取结果集并输出。

    1.    ./bin/linkis-cli [参数] [cli参数]

    • cli参数

    Cli参数可以通过手动指定的方式传入，此方式下会覆盖默认配置文件中的冲突配置项

    1.     ./bin/linkis-cli -engineType spark-2.4.3 -codeType sql -code "select count(*) from testdb.test;"  -submitUser hadoop -proxyUser hadoop  --gwUrl http://127.0.0.1:9001  --authStg token --authKey [tokenKey] --authVal [tokenValue]

    5.2 添加引擎初始参数

    1.     -confMap key1=val1,key2=val2,...

    例如：以下示例设置了引擎启动的yarn队列、spark executor个数等启动参数：

    1.    ./bin/linkis-cli -engineType spark-2.4.3 -codeType sql -confMap wds.linkis.yarnqueue=q02,spark.executor.instances=3 -code "select count(*) from testdb.test;"  -submitUser hadoop -proxyUser hadoop

    当然，这些参数也支持以配置文件的方式读取，我们稍后会讲到

    标签可以通过-labelMap参数添加，与-confMap一样，-labelMap参数的类型也是Map:

    5.4 变量替换

    Linkis-cli的变量替换通过${}符号和共同实现

    1.    ./bin/linkis-cli -engineType spark-2.4.3 -codeType sql -code "select count(*) from \${key};" -varMap key=testdb.test  -submitUser hadoop -proxyUser hadoop

    执行过程中sql语句会被替换为：

    1.    select count(*) from testdb.test

    注意'\$'中的转义符是为了防止参数被linux提前解析，如果是-codePath指定本地脚本方式，则不需要转义符

    1. linkis-cli支持加载用户自定义配置文件，配置文件路径通过--userConf参数指定，配置文件需要是.properties文件格式
    1.    ./bin/linkis-cli -engineType spark-2.4.3 -codeType sql -code "select count(*) from testdb.test;"  -submitUser hadoop -proxyUser hadoop  --userConf [配置文件路径]
    1. 哪些参数可以配置？

    所有参数都可以配置化，例如：

    cli参数：

    1.    wds.linkis.client.common.gatewayUrl=http://127.0.0.1:9001
    2.    wds.linkis.client.common.authStrategy=static
    3.    wds.linkis.client.common.tokenKey=[静态认证key]
    1.    wds.linkis.client.label.engineType=spark-2.4.3
    2.    wds.linkis.client.label.codeType=sql

    Map类参数配置化时，key的格式为

    Map前缀包括：

    • sourceMap前缀: wds.linkis.client.source
    • configurationMap前缀: wds.linkis.client.param.conf
    • runtimeMap前缀: wds.linkis.client.param.runtime
    • labelMap前缀: wds.linkis.client.label

    注意：

    1. variableMap不支持配置化

    2. 当配置的key和指令参数中已输入的key存在冲突时，优先级如下：

      1. 指令参数 > 指令Map类型参数中的key > 用户配置 > 默认配置

    示例：

    配置引擎启动参数：

    1.    wds.linkis.client.param.conf.spark.executor.instances=3
    2.    wds.linkis.client.param.conf.wds.linkis.yarnqueue=q02

    配置labelMap参数：

    1.    wds.linkis.client.label.myLabel=label123

    5.6 输出结果集到文件

    1.     task-[taskId]-result-[idx].txt

    例如：

    1.     task-906-result-1.txt
    2.     task-906-result-2.txt