Apache Drill REST API[编辑 | 编辑源代码]

简介[编辑 | 编辑源代码]

Apache Drill REST API 是 Apache Drill 提供的基于 HTTP 的接口，允许开发者通过标准的 RESTful 请求与 Drill 交互，执行查询、管理配置及监控集群状态。它无需依赖 JDBC 或 ODBC 驱动，适用于任何支持 HTTP 调用的编程语言或工具（如 Python、JavaScript、cURL 等）。

REST API 的核心功能包括：

提交 SQL 查询并获取结果（JSON 格式）
管理存储插件配置
查看查询性能指标
启停集群节点

API 基础[编辑 | 编辑源代码]

端点与认证[编辑 | 编辑源代码]

Drill REST API 默认运行在 Drillbit 节点的 `8047` 端口，基础路径为 `http://<drill-host>:8047`。部分操作需要认证（若 Drill 启用安全配置）。

常用端点：

`POST /query.json` - 执行 SQL 查询
`GET /storage.json` - 获取存储插件列表
`GET /status` - 检查集群状态

请求与响应格式[编辑 | 编辑源代码]

请求需包含 `Content-Type: application/json` 头部，查询请求体为 JSON 格式：

  
{  
  "queryType": "SQL",  
  "query": "SELECT * FROM cp.`employee.json` LIMIT 5"  
}

响应为 JSON，包含 `rows`（结果集）、`columns`（字段信息）和 `metadata`（查询元数据）。

代码示例[编辑 | 编辑源代码]

使用 cURL 查询[编辑 | 编辑源代码]

  
curl -X POST -H "Content-Type: application/json" \  
  -d '{"queryType":"SQL","query":"SELECT * FROM cp.`employee.json` LIMIT 2"}' \  
  http://localhost:8047/query.json

输出示例：

  
{  
  "columns": ["employee_id", "full_name", "position"],  
  "rows": [  
    { "employee_id": 1, "full_name": "John Doe", "position": "Manager" },  
    { "employee_id": 2, "full_name": "Jane Smith", "position": "Engineer" }  
  ],  
  "metadata": { "queryId": "12345-abcde" }  
}

Python 客户端示例[编辑 | 编辑源代码]

  
import requests  

url = "http://localhost:8047/query.json"  
headers = {"Content-Type": "application/json"}  
query = {  
    "queryType": "SQL",  
    "query": "SELECT name, age FROM dfs.`/data/people.csv` WHERE age > 30"  
}  

response = requests.post(url, json=query, headers=headers)  
print(response.json()["rows"])  # 输出查询结果

高级功能[编辑 | 编辑源代码]

分页查询[编辑 | 编辑源代码]

通过 `offset` 和 `limit` 实现分页：

  
SELECT * FROM large_table LIMIT 100 OFFSET 200

异步查询[编辑 | 编辑源代码]

提交查询时设置 `"async": true`，通过 `GET /query/{queryId}` 轮询结果。

修改存储插件[编辑 | 编辑源代码]

更新 HDFS 存储配置示例：

  
{  
  "name": "hdfs",  
  "config": {  
    "type": "file",  
    "connection": "hdfs://namenode:8020",  
    "workspaces": { "root": { "location": "/data" } }  
  }  
}