02-influxdb执行命令方式

influxdb执行命令方式

1. 三种操作方法

InfluxDB提供三种操作方式:

1)客户端命令行方式

2)HTTP API接口

3)各语言API库

2. 客户端命令行方式

查看influxdb占用端口情况

influx
或

InfluxDB HTTP API 8086默认在端口上运行。因此,influx将连接到端口8086和localhost默认。如果您需要更改这些默认值,请运行influx --help。
该-precision参数指定任何返回的时间戳的格式/精度。在上面的示例中,rfc3339告诉InfluxDB以RFC3339格式(YYYY-MM-DDTHH:MM:SS.nnnnnnnnnZ)返回时间戳。
$ influx -precision rfc3339
Connected to http://localhost:8086 version 1.4.x
InfluxDB shell 1.4.x

3. HTTP API接口

influxdb HTTP API提供了与数据库交互的简单方法。它使用HTTP响应代码、HTTP认证、JWT令牌和基本身份验证,并以JSON形式返回响应。

influxdb HTTP地址参考

地址类路径 描述
/debug/pprof 故障诊断生成概要文件
/debug/requests 跟踪HTTP客户端对/write和/query地址的请求
/debug/vars 收集统计信息
/ping 检查influxdb实例的状态和版本
/query 查询数据和管理数据库、保留策略和用户
/write 将数据吸入已存在的数据库

3.1. /debug/pprof

生成一个内置概要文件和超链接列表的HTML页面

 

 概要  描述
 block  堆栈跟踪同步阻塞
 goroutine  堆栈跟踪堆叠所有当前goroutines
 heap  堆栈跟踪堆分配的采样
 mutex  堆栈跟踪争用互斥锁
 threadcreate   堆栈跟踪创建新的OS线程
 all  是一个自定义/debug/pprof,influxdb支持的主要的概要文件。生成profile.tar.gz包含文本文件,其中包含标准分析信息和其他调试数据,使用该cpu=true选项时会生成可选的CPU配置文件(默认值为false)

 

3.2. /debug/requests 

使用此地址来跟踪客户端/write和/query的HTTP请求。该/debug/requests返回写入和查询的数量每用户名和IP地址InfluxDB

http://192.168.17.101:8086/debug/requests
# 添加seconds参数,默认值为10s
http://192.168.17.101:8086/debug/requests?seconds=60

3.3. /debug/vars

influxDB通过/debug/vars地址公开有关其运行时的统计信息和信息

http://192.168.17.101:8086/debug/vars

3.4. /ping

ping地址接受两个GET和HEAD HTTP请求。使用此地址检查InfluxDB实例的状态以及InfluxDB的版本

http://192.168.17.101:8086/ping

3.5. /query

 /query地址接受GET和POST HTTP请求。使用此地址可以查询数据并管理数据库,保留策略和用户

类型 方法
GET SELECT
SHOW
POST ALTER
CREATE
DELETE
DROP
GRANT
KILL
REVOKE

使用范例

# 浏览器
http://192.168.17.101:8086/query?db=mydb&q=SELECT * FROM meas01
# 返回具有指定精度的纪元时间戳 
http://192.168.17.101:8086/query?db=mydb&epoch=s&q=SELECT * FROM meas01
# 返回json格式数据
http://192.168.17.101:8086/query?db=mydb&pretty=true&q=SELECT * FROM meas01
# 以json格式返回具有指定精度的纪元时间戳
http://192.168.17.101:8086/query?db=mydb&epoch=s&pretty=true&q=SELECT * FROM meas01
# 添加用户、密码参数
http://192.168.17.101:8086/query?db=mydb&u=admin&p=123456&q=select * from meas01

# curl
curl -G 'http://192.168.17.101:8086/query?db=mydb' --data-urlencode 'q=SELECT * FROM "meas01"'
# 返回json格式数据
curl -G 'http://192.168.17.101:8086/query?db=mydb&pretty=true' --data-urlencode 'q=SELECT * FROM "meas01"'
# 返回具有指定精度的纪元时间戳 
curl -G 'http://192.168.17.101:8086/query?db=mydb&epoch=s' --data-urlencode 'q=SELECT * FROM "meas01"'
# 添加用户、密码参数
curl -G 'http://192.168.17.101:8086/query?db=mydb&u=admin&p=123456' --data-urlencode 'q=SELECT * FROM "meas01"' 

3.6. /write

/write地址接受POST HTTP请求。使用此地址将数据写入预先存在的数据库

POST http://localhost:8086/write?参数

使用范例

# 插入单条数据
curl -i -XPOST 'http://localhost:8086/write?db=mydb' --data-binary 'cpu_load_short,host=server01,region=us-west value=0.64 1434055562000000000'


# 插入多条数据
curl -i -XPOST 'http://localhost:8086/write?db=mydb' --data-binary 'cpu_load_short,host=server02 value=0.67
cpu_load_short,host=server02,region=us-west value=0.55 1422568543702900257
cpu_load_short,direction=in,host=server01,region=us-west value=2.0 1422568543702900257'

# 通过文件插入多条数据
curl -i -XPOST "http://localhost:8086/write?db=mydb" --data-binary @data.txt

4. 各语言API库

python操作influxdb

安装influxdb模块

pip install influxdb

使用范例

from influxdb import InfluxDBClient

json_body = [
    {
        "measurement": "meas01",
        "tags": {
            "name": "s1-2",
            "addr": "10-2"
        },
        "fields": {
            "id": 2
        }
    },
    {
        "measurement": "meas02",
        "tags": {
            "name": "s1-3",
            "addr": "10-3"
        },
        "fields": {
            "id": 3
        }
    }
]

print(json_body)

client = InfluxDBClient('192.168.17.101', 8086, 'root', '', 'mydb') # 初始化(指定要操作的数据库)
client.write_points(json_body) # 写入数据,同时创建表

 

原文地址:https://www.cnblogs.com/gongniue/p/12496866.html