Connections with other Tools-ch.md 7.5 KB
Newer Older
S
StoneT2000 已提交
1
# 与其他工具的连接
2 3 4 5 6

## Telegraf

TDengine能够与开源数据采集系统[Telegraf](https://www.influxdata.com/time-series-platform/telegraf/)快速集成,整个过程无需任何代码开发。

7
### 安装Telegraf
8 9 10

目前TDengine支持Telegraf 1.7.4以上的版本。用户可以根据当前的操作系统,到Telegraf官网下载安装包,并执行安装。下载地址如下:https://portal.influxdata.com/downloads

11
### 配置Telegraf
12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34

修改Telegraf配置文件/etc/telegraf/telegraf.conf中与TDengine有关的配置项。 

在output plugins部分,增加[[outputs.http]]配置项: 

- url:http://ip:6020/telegraf/udb,其中ip为TDengine集群的中任意一台服务器的IP地址,6020为TDengine RESTful接口的端口号,telegraf为固定关键字,udb为用于存储采集数据的数据库名称,可预先创建。
- method: "POST" 
- username: 登录TDengine的用户名
- password: 登录TDengine的密码
- data_format: "json"
- json_timestamp_units:      "1ms"

在agent部分:

- hostname: 区分不同采集设备的机器名称,需确保其唯一性
- metric_batch_size: 30,允许Telegraf每批次写入记录最大数量,增大其数量可以降低Telegraf的请求发送频率,但对于TDengine,该数值不能超过50

关于如何使用Telegraf采集数据以及更多有关使用Telegraf的信息,请参考Telegraf官方的[文档](https://docs.influxdata.com/telegraf/v1.11/)

## Grafana

TDengine能够与开源数据可视化系统[Grafana](https://www.grafana.com/)快速集成搭建数据监测报警系统,整个过程无需任何代码开发,TDengine中数据表中内容可以在仪表盘(DashBoard)上进行可视化展现。

35
### 安装Grafana
36

X
xieyinglin 已提交
37
目前TDengine支持Grafana 5.2.4以上的版本。用户可以根据当前的操作系统,到Grafana官网下载安装包,并执行安装。下载地址如下:https://grafana.com/grafana/download。
38

39
### 配置Grafana
40 41 42 43 44

TDengine的Grafana插件在安装包的/usr/local/taos/connector/grafana目录下。

以CentOS 7.2操作系统为例,将tdengine目录拷贝到/var/lib/grafana/plugins目录下,重新启动grafana即可。

X
xieyinglin 已提交
45
### 使用 Grafana
46

X
xieyinglin 已提交
47
#### 配置数据源
48

X
xieyinglin 已提交
49
用户可以直接通过localhost:3000的网址,登录Grafana服务器(用户名/密码:admin/admin),通过左侧`Configuration -> Data Sources`可以添加数据源,如下图所示:
50

X
xieyinglin 已提交
51
![img](../assets/add_datasource1.jpg)
52

X
xieyinglin 已提交
53
点击 `Add data source` 可进入新增数据源页面,在查询框中输入TDengine 可选择添加,如下图所示:
54

X
xieyinglin 已提交
55
![img](../assets/add_datasource2.jpg)
56

X
xieyinglin 已提交
57
进入数据源配置页面,按照默认提示修改相应配置即可:
58

X
xieyinglin 已提交
59
![img](../assets/add_datasource3.jpg)
60

X
xieyinglin 已提交
61 62 63
* HostTDengine:集群的中任意一台服务器的IP地址与TDengine RESTful接口的端口号(6020),默认http://localhost:6020。
* User:TDengine 用户名。
* Password:TDengine 用户密码。
64

X
xieyinglin 已提交
65
点击 `Save & Test` 进行测试,成功会有如下提示:
66

X
xieyinglin 已提交
67
![img](../assets/add_datasource4.jpg)
68

X
xieyinglin 已提交
69
#### 创建 Dashboard
70

X
xieyinglin 已提交
71
回到主界面创建 Dashboard,点击 Add Query 进入面板查询页面:
72

X
xieyinglin 已提交
73
![img](../assets/create_dashboard1.jpg)
74

X
xieyinglin 已提交
75
如上图所示,在 Query 中选中 `TDengine` 数据源,在下方查询框可输入相应 sql 进行查询,具体说明如下:
76

X
xieyinglin 已提交
77 78 79
* INPUT SQL:输入要查询的语句(该 SQL 语句的结果集应为两列多行),例如:`select avg(mem_system) from log.dn where  ts >= $from and ts < $to interval($interval)` ,其中,from、to 和 interval 为 TDengine插件的内置变量,表示从Grafana插件面板获取的查询范围和时间间隔。除了内置变量外,`也支持可以使用自定义模板变量`
* ALIAS BY:可设置当前查询别名。 
* GENERATE SQL: 点击该按钮会自动替换相应变量,并生成最终执行的语句。
X
xieyinglin 已提交
80 81
    
按照默认提示查询当前 TDengine 部署所在服务器指定间隔系统内存平均使用量如下:
82

X
xieyinglin 已提交
83
![img](../assets/create_dashboard2.jpg)
84

X
xieyinglin 已提交
85 86 87 88 89 90 91 92 93 94 95 96 97
> 关于如何使用Grafana创建相应的监测界面以及更多有关使用Grafana的信息,请参考Grafana官方的[文档](https://grafana.com/docs/)。
> 
#### 导入 Dashboard

在 Grafana 插件目录 /usr/local/taos/connector/grafana/tdengine/dashboard/ 下提供了一个 `tdengine-grafana.json` 可导入的 dashboard。

点击左侧 `Import` 按钮,并上传 `tdengine-grafana.json` 文件:

![img](../assets/import_dashboard1.jpg)

导入完成之后可看到如下效果:

![img](../assets/import_dashboard2.jpg)
98 99 100 101 102 103


## Matlab

MatLab可以通过安装包内提供的JDBC Driver直接连接到TDengine获取数据到本地工作空间。

104
### MatLab的JDBC接口适配
105 106 107 108 109 110 111 112 113 114 115 116 117

MatLab的适配有下面几个步骤,下面以Windows10上适配MatLab2017a为例:

- 将TDengine安装包内的驱动程序JDBCDriver-1.0.0-dist.jar拷贝到${matlab_root}\MATLAB\R2017a\java\jar\toolbox
- 将TDengine安装包内的taos.lib文件拷贝至${matlab_ root _dir}\MATLAB\R2017a\lib\win64
- 将新添加的驱动jar包加入MatLab的classpath。在${matlab_ root _dir}\MATLAB\R2017a\toolbox\local\classpath.txt文件中添加下面一行

`$matlabroot/java/jar/toolbox/JDBCDriver-1.0.0-dist.jar`

- 在${user_home}\AppData\Roaming\MathWorks\MATLAB\R2017a\下添加一个文件javalibrarypath.txt, 并在该文件中添加taos.dll的路径,比如您的taos.dll是在安装时拷贝到了C:\Windows\System32下,那么就应该在javalibrarypath.txt中添加如下一行:

`C:\Windows\System32`

118
### 在MatLab中连接TDengine获取数据
119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175

在成功进行了上述配置后,打开MatLab。

- 创建一个连接:

  `conn = database(‘db’, ‘root’, ‘taosdata’, ‘com.taosdata.jdbc.TSDBDriver’, ‘jdbc:TSDB://127.0.0.1:0/’)`

- 执行一次查询:

  `sql0 = [‘select * from tb’]`

  `data = select(conn, sql0);`

- 插入一条记录:

  `sql1 = [‘insert into tb values (now, 1)’]`

  `exec(conn, sql1)`

更多例子细节请参考安装包内examples\Matlab\TDengineDemo.m文件。

## R 

R语言支持通过JDBC接口来连接TDengine数据库。首先需要安装R语言的JDBC包。启动R语言环境,然后执行以下命令安装R语言的JDBC支持库:

```R
install.packages('rJDBC', repos='http://cran.us.r-project.org')
```

安装完成以后,通过执行`library('RJDBC')`命令加载 _RJDBC_ 包:

然后加载TDengine的JDBC驱动:

```R
drv<-JDBC("com.taosdata.jdbc.TSDBDriver","JDBCDriver-1.0.0-dist.jar", identifier.quote="\"")
```
如果执行成功,不会出现任何错误信息。之后通过以下命令尝试连接数据库:

```R
conn<-dbConnect(drv,"jdbc:TSDB://192.168.0.1:0/?user=root&password=taosdata","root","taosdata")
```

注意将上述命令中的IP地址替换成正确的IP地址。如果没有任务错误的信息,则连接数据库成功,否则需要根据错误提示调整连接的命令。TDengine支持以下的 _RJDBC_ 包中函数:


-	dbWriteTable(conn, "test", iris, overwrite=FALSE, append=TRUE):将数据框iris写入表test中,overwrite必须设置为false,append必须设为TRUE,且数据框iris要与表test的结构一致。
-	dbGetQuery(conn, "select count(*) from test"):查询语句
-	dbSendUpdate(conn, "use db"):执行任何非查询sql语句。例如dbSendUpdate(conn, "use db"), 写入数据dbSendUpdate(conn, "insert into t1 values(now, 99)")等。
-	dbReadTable(conn, "test"):读取表test中数据
-	dbDisconnect(conn):关闭连接
-	dbRemoveTable(conn, "test"):删除表test

TDengine客户端暂不支持如下函数:
- dbExistsTable(conn, "test"):是否存在表test
- dbListTables(conn):显示连接中的所有表