02-rest-api.mdx 8.8 KB
Newer Older
1 2
---
title: REST API
3 4
sidebar_label: REST API
description: 详细介绍 TDengine 提供的 RESTful API.
5 6
---

sangshuduo's avatar
sangshuduo 已提交
7
为支持各种不同类型平台的开发,TDengine 提供符合 RESTful 设计标准的 API,即 REST API。为最大程度降低学习成本,不同于其他数据库 REST API 的设计方法,TDengine 直接通过 HTTP POST 请求 BODY 中包含的 SQL 语句来操作数据库,仅需要一个 URL。REST API 的使用参见 [视频教程](https://www.taosdata.com/blog/2020/11/11/1965.html)。
8 9

:::note
T
t_max 已提交
10
与原生连接器的一个区别是,RESTful 接口是无状态的,因此 `USE db_name` 指令没有效果,所有对表名、超级表名的引用都需要指定数据库名前缀。支持在 RESTful URL 中指定 db_name,这时如果 SQL 语句中没有指定数据库名前缀的话,会使用 URL 中指定的这个 db_name。
11 12 13 14
:::

## 安装

15
RESTful 接口不依赖于任何 TDengine 的库,因此客户端不需要安装任何 TDengine 的库,只要客户端的开发语言支持 HTTP 协议即可。TDengine 的 RESTful API 由 [taosAdapter](../../reference/taosadapter) 提供,在使用 RESTful API 之前需要确保 `taosAdapter` 正常运行。
16 17 18 19 20

## 验证

在已经安装 TDengine 服务器端的情况下,可以按照如下方式进行验证。

sangshuduo's avatar
sangshuduo 已提交
21
下面以 Ubuntu 环境中使用 `curl` 工具(请确认已经安装)来验证 RESTful 接口是否工作正常,验证前请确认 taosAdapter 服务已开启,在 Linux 系统上此服务默认由 systemd 管理,使用命令 `systemctl start taosadapter` 启动。
22 23 24

下面示例是列出所有的数据库,请把 h1.taosdata.com 和 6041(缺省值)替换为实际运行的 TDengine 服务 FQDN 和端口号:

T
t_max 已提交
25 26 27 28
```bash
curl -L -H "Authorization: Basic cm9vdDp0YW9zZGF0YQ==" \
  -d "select name, ntables, status from information_schema.ins_databases;" \
  h1.taosdata.com:6041/rest/sql
29 30 31 32 33 34
```

返回值结果如下表示验证通过:

```json
{
T
t_max 已提交
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55
    "code": 0,
    "column_meta": [
        [
            "name",
            "VARCHAR",
            64
        ],
        [
            "ntables",
            "BIGINT",
            8
        ],
        [
            "status",
            "VARCHAR",
            10
        ]
    ],
    "data": [
        [
            "information_schema",
T
t_max 已提交
56 57
            16,
            "ready"
T
t_max 已提交
58 59 60
        ],
        [
            "performance_schema",
T
t_max 已提交
61 62
            9,
            "ready"
T
t_max 已提交
63 64 65
        ]
    ],
    "rows": 2
66 67 68 69 70
}
```

## HTTP 请求格式

T
t_max 已提交
71
```text
72
http://<fqdn>:<port>/rest/sql/[db_name][?tz=timezone]
73 74 75 76
```

参数说明:

S
songshuqi 已提交
77
- fqdn: 集群中的任一台主机 FQDN 或 IP 地址。
T
t_max 已提交
78
- port: 配置文件中 httpPort 配置项,缺省为 6041。
T
t_max 已提交
79
- db_name: 可选参数,指定本次所执行的 SQL 语句的默认数据库库名。
80
- tz: 可选参数,指定返回时间的时区,遵照 IANA Time Zone 规则,如 `America/New_York`。
81 82 83 84 85

例如:`http://h1.taos.com:6041/rest/sql/test` 是指向地址为 `h1.taos.com:6041` 的 URL,并将默认使用的数据库库名设置为 `test`。

HTTP 请求的 Header 里需带有身份认证信息,TDengine 支持 Basic 认证与自定义认证两种机制,后续版本将提供标准安全的数字签名机制来做身份验证。

T
t_max 已提交
86
- [自定义身份认证信息](#自定义授权码)如下所示:
87

T
t_max 已提交
88
  ```text
89 90 91
  Authorization: Taosd <TOKEN>
  ```

T
t_max 已提交
92
- Basic 身份认证信息如下所示:
93

T
t_max 已提交
94
  ```text
95 96 97 98 99 100 101 102
  Authorization: Basic <TOKEN>
  ```

HTTP 请求的 BODY 里就是一个完整的 SQL 语句,SQL 语句中的数据表应提供数据库前缀,例如 db_name.tb_name。如果表名不带数据库前缀,又没有在 URL 中指定数据库名的话,系统会返回错误。因为 HTTP 模块只是一个简单的转发,没有当前 DB 的概念。

使用 `curl` 通过自定义身份认证方式来发起一个 HTTP Request,语法如下:

```bash
103
curl -L -H "Authorization: Basic <TOKEN>" -d "<SQL>" <ip>:<PORT>/rest/sql/[db_name][?tz=timezone]
104 105
```

T
t_max 已提交
106
或者,
107 108

```bash
109
curl -L -u username:password -d "<SQL>" <ip>:<PORT>/rest/sql/[db_name][?tz=timezone]
110 111
```

T
t_max 已提交
112
其中,`TOKEN` 为 `{username}:{password}` 经过 Base64 编码之后的字符串,例如 `root:taosdata` 编码后为 `cm9vdDp0YW9zZGF0YQ==`。
113 114 115

## HTTP 返回格式

T
t_max 已提交
116 117 118 119 120 121 122 123 124 125 126 127 128
### HTTP 响应码

| **response code** | **说明**         |
|-------------------|----------------|
| 200               | 正确返回和 C 接口错误返回 |
| 400               | 参数错误返回         |
| 401               | 鉴权失败           |
| 404               | 接口不存在          |
| 500               | 内部错误           |
| 503               | 系统资源不足         |

### HTTP body 结构

sangshuduo's avatar
sangshuduo 已提交
129
#### 正确执行插入
T
t_max 已提交
130 131

样例:
132 133 134

```json
{
T
t_max 已提交
135 136 137 138
  "code": 0,
  "column_meta": [["affected_rows", "INT", 4]],
  "data": [[0]],
  "rows": 1
139 140 141
}
```

T
t_max 已提交
142 143 144 145 146 147 148
说明:

- code:(`int`)0 代表成功。
- column_meta:(`[1][3]any`)只返回 `[["affected_rows", "INT", 4]]`。
- rows:(`int`)只返回 `1`。
- data:(`[][]any`)返回受影响行数。

sangshuduo's avatar
sangshuduo 已提交
149
#### 正确执行查询
T
t_max 已提交
150 151

样例:
152

T
t_max 已提交
153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205
```json
{
  "code": 0,
  "column_meta": [
    ["ts", "TIMESTAMP", 8],
    ["count", "BIGINT", 8],
    ["endpoint", "VARCHAR", 45],
    ["status_code", "INT", 4],
    ["client_ip", "VARCHAR", 40],
    ["request_method", "VARCHAR", 15],
    ["request_uri", "VARCHAR", 128]
  ],
  "data": [
    [
      "2022-06-29T05:50:55.401Z",
      2,
      "LAPTOP-NNKFTLTG:6041",
      200,
      "172.23.208.1",
      "POST",
      "/rest/sql"
    ],
    [
      "2022-06-29T05:52:16.603Z",
      1,
      "LAPTOP-NNKFTLTG:6041",
      200,
      "172.23.208.1",
      "POST",
      "/rest/sql"
    ],
    [
      "2022-06-29T06:28:14.118Z",
      1,
      "LAPTOP-NNKFTLTG:6041",
      200,
      "172.23.208.1",
      "POST",
      "/rest/sql"
    ],
    [
      "2022-06-29T05:52:16.603Z",
      2,
      "LAPTOP-NNKFTLTG:6041",
      401,
      "172.23.208.1",
      "POST",
      "/rest/sql"
    ]
  ],
  "rows": 4
}
```
206

T
t_max 已提交
207 208 209 210 211 212 213
说明:

- code:(`int`)0 代表成功。
- column_meta:(`[][3]any`) 列信息,每个列会用三个值来说明,分别为:列名(string)、列类型(string)、类型长度(int)。
- rows:(`int`)数据返回行数。
- data:(`[][]any`)具体数据内容(时间格式仅支持 RFC3339,结果集为 0 时区)。

T
t_max 已提交
214
列类型使用如下字符串:
T
t_max 已提交
215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235

- "NULL"
- "BOOL"
- "TINYINT"
- "SMALLINT"
- "INT"
- "BIGINT"
- "FLOAT"
- "DOUBLE"
- "VARCHAR"
- "TIMESTAMP"
- "NCHAR"
- "TINYINT UNSIGNED"
- "SMALLINT UNSIGNED"
- "INT UNSIGNED"
- "BIGINT UNSIGNED"
- "JSON"

#### 错误

样例:
236

T
t_max 已提交
237 238 239 240 241 242 243
```json
{
  "code": 9728,
  "desc": "syntax error near \"1\""
}
```

T
t_max 已提交
244 245 246 247
说明:

- code:(`int`)错误码。
- desc:(`string`)错误描述。
248 249 250 251 252 253 254 255 256 257 258

## 自定义授权码

HTTP 请求中需要带有授权码 `<TOKEN>`,用于身份识别。授权码通常由管理员提供,可简单的通过发送 `HTTP GET` 请求来获取授权码,操作如下:

```bash
curl http://<fqnd>:<port>/rest/login/<username>/<password>
```

其中,`fqdn` 是 TDengine 数据库的 FQDN 或 IP 地址,`port` 是 TDengine 服务的端口号,`username` 为数据库用户名,`password` 为数据库密码,返回值为 JSON 格式,各字段含义如下:

T
t_max 已提交
259 260 261
- status:请求结果的标志位。
- code:返回值代码。
- desc:授权码。
262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283

获取授权码示例:

```bash
curl http://192.168.0.1:6041/rest/login/root/taosdata
```

返回值:

```json
{
  "status": "succ",
  "code": 0,
  "desc": "/KfeAzX/f9na8qdtNZmtONryp201ma04bEl8LcvLUd7a8qdtNZmtONryp201ma04"
}
```

## 使用示例

- 在 demo 库里查询表 d1001 的所有记录:

  ```bash
284
  curl -L -H "Authorization: Basic cm9vdDp0YW9zZGF0YQ==" -d "select * from demo.d1001" 192.168.0.1:6041/rest/sql
285 286 287 288 289 290
  ```

  返回值:

  ```json
  {
T
t_max 已提交
291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328
      "code": 0,
      "column_meta": [
          [
              "ts",
              "TIMESTAMP",
              8
          ],
          [
              "current",
              "FLOAT",
              4
          ],
          [
              "voltage",
              "INT",
              4
          ],
          [
              "phase",
              "FLOAT",
              4
          ]
      ],
      "data": [
          [
              "2022-07-30T06:44:40.32Z",
              10.3,
              219,
              0.31
          ],
          [
              "2022-07-30T06:44:41.32Z",
              12.6,
              218,
              0.33
          ]
      ],
      "rows": 2
329 330 331 332 333 334
  }
  ```

- 创建库 demo:

  ```bash
335
  curl -L -H "Authorization: Basic cm9vdDp0YW9zZGF0YQ==" -d "create database demo" 192.168.0.1:6041/rest/sql
336 337 338 339 340 341
  ```

  返回值:

  ```json
  {
T
t_max 已提交
342 343 344 345 346 347 348 349 350 351 352 353 354 355
      "code": 0,
      "column_meta": [
          [
              "affected_rows",
              "INT",
              4
          ]
      ],
      "data": [
          [
              0
          ]
      ],
      "rows": 1
356 357 358
  }
  ```

T
t_max 已提交
359
## 参考
360

T
t_max 已提交
361
[taosAdapter](/reference/taosadapter/)