# dataTransform - 数据加工组件扩展
SuccBI数据加工内置了大量常用的加工组件,如汇总、行转列、列加工等,能满足大部分的数据加工需求,一些个性化加工需求也可以通过SQL组件、脚本组件实现,但是SQL组件、脚本组件不方便复用,每个用到的地方都需要再次编写SQL或者脚本。
数据加工组件扩展组件可以做到和产品内置的加工组件一样的复用,由扩展开发者开发好数据加工组件扩展后,使用者可以像使用内置加工组件一样使用扩展组件。
本文讲述如何开发一个SuccBI数据加工组件扩展。
# 扩展文件结构
- package.json 定义扩展的配置信息。
- main.action 定义扩展的执行逻辑。
# package.json
每一个扩展都需要在根目录中有一个描述文件package.json
。
示例如下:
{
"name": "template-dataTransform-blank",
"displayName": "空白模板",
"icon": "icon-extension",
"categories": ["data"],
"version": "1.0.0",
"thumbnail": "default.png",
"author": {
"name": "YourName"
},
"contributes": {
"dataTransform": {
"inputDataStreamTypes": ["DbTable", "ModelTable", "Stream"],
"inputDataStreamCount" : "None",
"outputDataStreamType": "DbTable",
"properties": {
"propertyItems":[
{
"name":"param1",
"type":"number",
"caption":"参数1",
"desc":"说明如何使用参数1"
}
]
}
}
}
}
详细说明:
在dataTransform
属性中描述扩展组件的配置信息,包括下列属性:
inputDataStreamTypes
描述扩展组件可以接受哪些输入节点,是一个json字符串数组,可以设置这些类型:DbTable
数据库表或视图ModelTable
模型表Stream
数据流、Sql
SQL查询
inputDataStreamCount
描述此组件可以接受几个输入节点,可以设置如下值:Any
随便是否有输入节点,可以没有也可以有,输入节点只是控制执行顺序,输入节点不能是不落地数据的节点MustOne
必须且只需要一个数据输入节点MustTwo
必须要两个输入节点MustMore
必须需要多个数据输入节点
outputDataStreamType
描述此组件的输出数据类型,可以设置如下值:DbTable
输出数据在一个数据库表或视图中Stream
输出数据是一个数据流
scriptAction
加工逻辑所在的后端脚本,默认是main.action
,脚本中有一个onProcessExtensionNode
函数。properties
描述使用这个加工组件时可以设置测选项propertyItems
选项列表,是一个json数组,每个元素说明一个选项的定义,可以包含如下属性:name
属性名,应该是一个字母组成的标识符,用于在扩展组件运行的时候传递给扩展组件的加工逻辑type
属性类型,描述用户输入此属性时的输入方式,具体见下文caption
属性标题,应该是一个简短的描述,如:每月发放月限量desc
属性描述,可选,一段文字描述如何使用此属性items
可选值列表,可选,当属性类型是combobox时有效
属性类型可以有如下选项:
filter
过滤条件number
数字输入combobox
下拉选项输入checkbox
勾选框输入text
文本输入date
日期输入,支持输入相对日期field
字段选择下拉框fields
字段选择下拉框,可以多选字段
# main.action
main.action
文件是一个后端脚本文件,定义了数据加工扩展的执行逻辑。
入口函数是onProcessExtensionNode
,会在如下2个时机被调用:
- 用户在数据加工界面中选择使用此扩展组件,并进行数据预览时。
- 定时调度包含了此扩展组件的加工流程时。
可以直接编辑main.action
文件,也可以在SuccIDE或元数据项目设置中通过脚本编辑器直接编辑
ts语法的脚本文件main.action.ts
,编辑器会自动编译并生成main.action
。
脚本模版:
import etl from "svr-api/etl";
/**
* 入口函数是`onProcessExtensionNode`,会在如下2个时机被调用:
*
* 1. 用户在数据加工界面中选择使用此扩展组件,并进行数据预览时。
* 2. 定时调度包含了此扩展组件的加工流程时。
*/
function onProcessExtensionNode(context: IDataFlowScriptNodeContext): void {
//TODO
}
# 示例
0条评论
评论