1. EXT API

当用户使用API数据源时，可以通过EXT API接入到衡石系统。 EXT API 定义统一的数据接入规范，能支持大量的无数据计算能力的 API 数据源。内置多种 API 数据源的同时支持用户自定义开发方式加入企业内部 API 数据源或其他公有 API 数据源，快速读取 API 数据源。EXT API 轻松实现接入 API 数据源由 1 到 N 的快速增长，增强衡石数据的整合能力。

1.1. 内置API数据源

1.1.1. 明道云数据源

用户在明道云上的应用数据通过简单的配置就可以连接到衡石系统。配置步骤如下：

点击新建数据连接，进入EXT API的连接界面。
输入新建连接名称、选择数据网关、API name选择'mingdaoyun'。
填写明道云配置信息API Config，包括appKey、secretKey、sign apiUrl。其中appKey、secretKey、sign指的是明道云应用中的AppKey、SecretKey、Sign。明道云为私有部署时，apiUrl请填写私有部署地址；公有部署时apiUrl可置空或填写默认地址。
```
{ 
  "appKey":"ab1a55ba2deb3a01",
  "secretKey":"68b7eqbp7r1p5ZeAbw60aXcG0h8G354qfB4waK198G5M7w9y92eP3Dae27emcu7n",
  "sign":"NWRiODkxZmQ0NzljNzcxZDhiMDZjMzE5ZDQzMDFlMWFiNDU0MGViYTI1NjFlNDUyMmNjMmQzMWMzMmM2YzBlZQ=="     
  "apiUrl": "https://api.mingdao.com/v2/open"
}
```
验证成功后，点击保存，数据连接创建完成。在系统中可以查看和使用明道云中的数据。

1.1.2. FTP数据源

EXT API支持FTP数据源，在HENGSHI SENSE中通过简单配置，可以读取ftp指定路径下的文件。配置步骤如下。

点击新建数据连接，进入EXT API的连接界面。
输入新建连接名称、选择数据网关、API name选择'ftp'，填写ftp配置信息，将host、username、password、directory、encoding、passive等信息填入到配置中。
```
{
 "host":"10.10.10.86",
 "username":"anonymous",
 "password":"anonymous",
 "directory":"/",
 "encoding":"utf8",
 "passive":true,
}
```
验证成功后，点击保存，数据连接创建完成。在系统中可以查看和使用连接数据。

说明：
FTP数据源只能将csv和excel解析为表的形式，其他类型的文件不支持解析。

1.1.3. 自定义API数据源

除了内置的API数据源外，系统支持用户自定义API 数据源。自定义API数据源按照规范编写Groovy脚本，并通过环境变量 EXT_API_PATH 指定脚本位置，然后重启系统，系统启动会自动载入脚本中定义的数据源。

载入系统

export EXT_API_PATH=/opt/hengshi/ext_api_files

重启系统，系统启动过程中会自动扫描EXT_API_PATH指定的路径下所有数据源定义文件（以.groovy后缀结尾的文件），并且加载成自定义的数据源。在API数据源创建时就能看到相应的数据源了。

API数据源接入规范

自定义数据源接入时，需要在Groovy脚本中实现下面四个接口。

getAPIName ：用来获取 API 名称。
setOptions：用来处理认证鉴权相关配置信息。
fetchPathTables：用户获取数据源目录结构。
fetchTableData ：用于获取table节点数据。
函数getAPIName
函数getAPIName的作用是输出API名称。该名称会出现在页面的API Name下拉选择框中。每一个API数据源名称不能相同，如果相同会导致发生冲突。该函数是类static函数，返回值为string类型的字符串。
```
static getApiName() {
      return "TrivalApiDemo"
  }
```

函数setOptions

函数setOptions的作用是用来保存处理认证鉴权相关的配置信息。如果不涉及外部网络请求，可以直接留空了。该函数是object函数，函数参数是一个JSON字符串，这个字符串是用户在添加数据连接时填写的信息。

    def setOptions(String options) {
        if (!options?.trim()) {
            return
        }
        def json = jsonSlurper.parseText(options)
        if (json.cityCodeURL?.trim()) {
            config.cityCodeURL = JSON.cityCodeURL
        }
        if (json.weatherURL?.trim()) {
            config.weatherURL = JSON.weatherURL
        }
    }

函数getPathTables

函数getPathTables的作用是返回目录树，把该数据源的所有catalog/schema/table的结构都返回。代码示例如下。


def getPathTables() {
        def tableTree = [
            [pathType: "table", name: "table1", tableType: "table"],
            [pathType: "path", name: "schema2", children: [
                    [pathType: "table", name: "table3", tableType: "view"],
                    [pathType: "table", name: "table4", tableType: "table", remarks: "表别名4"]
            ]]
        ]
        return new JsonBuilder(tableTree).toString()
    }

结构定义说明：

pathType 的种类有 table(代表叶子结点的表), path(代表数据库中的schema或者catalog)
name 就是表名或者schema/catalog的名字
tableType 只对table有意义，它的类型一般写成table就可以了(另外一个选项是view，不常用)
当 pathType为path时，代表这个节点不是一个表，而是一个schema或者catalog这样的中间目录结构，此时它可以有 children 数组节点
remarks 是当前节点的一个说明，需要的时候可以提供，是可选项。

通过上面的函数定义的schema，可以在数据连接中查看如下的table。

函数fetchTableData

函数fetchTableData函数的作用是获取一个叶子节点，即table节点的数据。代码示例如下。

    def fetchTableData(List<String> tablePath) {
        def tableName = tablePath.last()
        def schemaData = [
                schema: [
                        [fieldName: "field1", label: "字段别名1", type: "string"],
                        [fieldName: "field2", label: null, type: "string"],
                        [fieldName: "field3", type: "number"],
                        [fieldName: "field4", type: "date"],
                        [fieldName: "field5", type: "time"]],
                data: [
                        ["a", "b", 10, "2022-01-01", "2022-01-01 23:59:59"],
                        ["c", "d", 20.20, "2019-12-39", "2019-12-39 23:59:59"]
                ]
        ]
        return new JsonBuilder(schemaData).toString()
    }

Schema结构定义：

fieldName字段名，需要在table内具有唯一性，能区分不同的字段。
type：字段的类型，常用的类型有：string, number, date, time, json, bool。
label：字段的别名。

Data结构定义：

data的每一个元素都是一个数组，数组的元素个数必须和schema相同，数据的类型也必须一一匹配。

通过上述示例，可以返回的数据如下。

API数据源定义文件方式

API数据源定义文件方式有很多种，上面示例是使用JSON方式定义一个API数据源，这种方式简单，但是性能不高，当数据量较大时，可以使用Java方式。下面使用Java构造一个天气API自定义数据源。weather.groovy文件定义内容如下。

//Weather.groovy

import com.hengshi.nangaparbat.dto.DatasetResultDto
import com.hengshi.nangaparbat.model.PathTableNode
import static com.hengshi.nangaparbat.model.Dataset.Field
import static com.hengshi.nangaparbat.model.Type.TypeName
import groovy.json.JsonSlurper



class Provider {
    static getApiName() {
        return "天气API"
    }

    def setOptions(String options) {
        if (!options?.trim()) {
            return
        }
        def json = jsonSlurper.parseText(options)
        if (json.cityCodeURL?.trim()) {
            config.cityCodeURL = json.cityCodeURL
        }
        if (json.weatherURL?.trim()) {
            config.weatherURL = json.weatherURL
        }
    }

    def getPathTables() {
        def txt = config.cityCodeURL.toURL().text
        def arr = jsonSlurper.parseText(txt)
        return arr.collect{ obj ->
            def node = PathTableNode.createTableNode(obj.city_code)
            node.setRemarks(obj.city_name)
            return node
        }
    }

    def fetchTableData(List<String> tablePath) {
        def url = config.weatherURL + tablePath.last()
        def txt = url.toURL().text;
        def result = new DatasetResultDto()
        def schema = []
        def data = []
        def row = []
        def arr = jsonSlurper.parseText(txt)
        arr.data.each{ k, v ->
            def field = new Field();
            field.setFieldName(k)
            field.setType(TypeName.string)
            if (k.startsWith("pm")) {
                field.setType(TypeName.integer)
            }
            schema.add(field)
            row.add(v);
        }
        result.setSchema(schema)
        data.add(row)
        result.setData(data)
        return result
    }


    def jsonSlurper = new JsonSlurper()

    def config = [
            cityCodeURL: "https://github.com/baichengzhou/weather.api/raw/master/src/main/resources/citycode-2019-08-23.json",
            weatherURL: "http://t.weather.itboy.net/api/weather/city/"
    ]
}

代码说明：

DatasetResultDto定义了fetchTableData的返回结果，它由schema和data组成，通过setData和setSchema来写入。
PathTableNode定义了getPathTables的返回，它由pathType, name, children 和 tableType组成，也是通过各自的setter来写入
schema由多个Field组成，Field由fieldName, type和label组成。
type的种类是一个枚举类型定义的TypeName。
CityCode中定义了目录结构。
天气网站是天气数据来源，记录了各个城市的天气数据。

使用上述示例代码定义了天气API数据源，将weather.groovy导入系统后，获取API数据。