1. 概述
1.1 版本
FineDataLink 版本 | 功能变动 |
---|---|
4.2.1.2 | 数据开发-定时任务中支持读取 InfluxDB 数据库 |
1.2 功能简介
数据开发-定时任务中支持读取 InfluxDB 数据库。
1.3 使用限制
FDL 支持 InfluxDB 版本:1.x、2.x。InfluxDB 数据库支持两种查询语言:InfluxQL 和 Flux(区别与联系可自行百度),FDL 中使用该数据源配置 SQL 语句时,也支持这两种查询语言:
1.x 版本查询时,只能用 Influxql 语句。
2.x 版本查询时,只能用 Flux 语句。
2. 准备工作
2.1 前提条件
详情请参见:前提条件
2.2 版本和驱动
下载驱动,并放置到FDL工程安装地址\webapps\webroot\WEB-INF\lib下,放置后,需要重启 FDL 工程。
支持的数据库版本 | 驱动 |
---|---|
1.x | |
2.x |
2.3 收集连接信息
配置数据连接时:
1.x 版本必填项:服务器地址、用户名、密码。
2.x 版本必填项:服务器地址、授权令牌(Token)、组织名称(Organization)。
3. 具体连接步骤
1)管理员登录 FDL 工程,点击「管理系统>数据连接>数据连接管理」,选中某个文件夹后,新建数据连接。如下图所示:
2)设置数据连接名称(可同时修改数据连接所在目录)。如下图所示:
3)可根据数据源分类、支持形式、适配模块、数据源名称筛选数据库。如下图所示:
4)填写 2.3 节收集的服务器地址、用户名、密码信息。如下图所示:
部分设置项说明如下表所示:
数据库 1.x 版本必填项:服务器地址、用户名、密码。
数据库 2.x 版本必填项:服务器地址、授权令牌(Token)、组织名称(Organization)。
设置项 | 说明 |
---|---|
授权令牌(token) | 只有未过期的令牌才能成功进行身份验证,确保令牌尚未过期 |
组织名称(organization) | organization 是一组用户的工作空间,一个组下用户可以创建多个 bucket |
Chunk_size | 默认值为 10000 ,需要填写正整数 FDL 默认已开启分块,该参数用于控制查询结果的分块大小 |
5)点击「测试连接」,若连接成功则「保存」该连接。
4. 使用数据源
4.1 数据开发
1)数据开发-定时任务中支持读取 InfluxDB 数据库。
「数据同步」「参数赋值」「全局赋值参数」「数据转换-DB表输入」的DB表输入来源新增 InfluxDB 。如下图所示:
配置方式为「选表」时,不支持并行取数功能。
2)InfluxDB 数据库不支持表备注、字段备注功能。表备注、字段备注功能说明请参见:数据同步-数据去向与映射
3)InfluxDB 数据库支持两种查询语言:InfluxQL 和 Flux(区别与联系可自行百度),FDL 中使用该数据源配置 SQL 语句时,也支持这两种查询语言。
注:1.x 版本查询时,只能用 Influxql 语句;2.x 版本查询时,只能用 Flux 语句。
场景一:配置方式为 SQL 时:
FDL 中支持在 SQL 编辑框中编写 SQL 语句,支持 InfluxQL 和 Flux 两种查询语言。
FDL 中支持同时查询两个表的 Influxql 查询语句:
SELECT * FROM luke.autogen.luke, luke.autogen.cpu
FDL 中不支持 InfluxDB 2.x 用如下语句同时查询两个表:
from(bucket: "tsdb")
|> range(start: -1h)
|> filter(fn: (r) =>( r._measurement == "go_info" or r._measurement == "go_goroutines"))
场景二:配置方式为「选表」时:
查询语言 | 说明 |
---|---|
InfluxQL | 选表处是默认的保留策略,若用户指定非默认保留策略,会查不出指定该表名的数据 保留策略:数据保留策略RP(Retention Policies),用来让自定义数据的保留时间 |
Flux | 过滤框需要填写两块内容,分别为:
FDL 不支持在 Flux 查询语句中引用模版变量 v |
5. 异常场景说明
异常场景 | 说明 |
---|---|
InfluxDB数据源,用户原配置「授权令牌,组织名称」配置项,后期删了,选择了用户名、密码 | 定时任务中将 Flux 灰化显示,查询语句配置项内容灰化显示,不可编辑 默认选中 Influxql 语法,前端将 Influxql 联动出的为空配置项标红,后端运行报错 |