一、InfluxDB客戶端介紹

InfluxDB客戶端是InfluxData公司開(kāi)發(fā)的一款用于連接InfluxDB數(shù)據(jù)庫(kù)的軟件開(kāi)發(fā)工具包，易于使用，使得開(kāi)發(fā)者能夠快速地進(jìn)行InfluxDB數(shù)據(jù)庫(kù)的讀寫和數(shù)據(jù)查詢。目前有多種語(yǔ)言的客戶端可供選擇，例如Java、Python、Go和JavaScript等等。

要使用InfluxDB客戶端，需要建立一個(gè)連接并指定數(shù)據(jù)庫(kù)名稱。一旦連接建立成功，開(kāi)發(fā)者可以使用API或SQL語(yǔ)言與InfluxDB進(jìn)行交互。InfluxDB客戶端可以執(zhí)行寫入數(shù)據(jù)、查詢數(shù)據(jù)、創(chuàng)建新的數(shù)據(jù)庫(kù)以及管理現(xiàn)有數(shù)據(jù)庫(kù)等操作。

// Java代碼示例
InfluxDB influxDB = InfluxDBFactory.connect("http://localhost:8086", "root", "root");
influxDB.createDatabase("mydb");
BatchPoints batchPoints = BatchPoints.database("mydb").build();
Point point = Point.measurement("cpu")
    .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
    .addField("idle", 90L)
    .addField("user", 9L)
    .addField("system", 1L)
    .build();
batchPoints.point(point);
influxDB.write(batchPoints);

InfluxDB influxDB = InfluxDBFactory.connect("http://localhost:8086", "root", "root");
influxDB.createDatabase("mydb");
BatchPoints batchPoints = BatchPoints.database("mydb").build();
Point point = Point.measurement("cpu")
    .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
    .addField("idle", 90L)
    .addField("user", 9L)
    .addField("system", 1L)
    .build();
batchPoints.point(point);
influxDB.write(batchPoints);

InfluxDB influxDB = InfluxDBFactory.connect("http://localhost:8086", "root", "root");
Query query = new Query("SELECT * FROM cpu", "mydb");
QueryResult result = influxDB.query(query);

InfluxDB influxDB = InfluxDBFactory.connect("http://localhost:8086", "root", "root");
influxDB.createDatabase("mydb");

from influxdb import InfluxDBClient

client = InfluxDBClient('localhost', 8086, 'root', 'root', 'mydb')
json_body = [
    {
        "measurement": "cpu_load_short",
        "tags": {
            "host": "server01",
            "region": "us-west"
        },
        "time": "2009-11-10T23:00:00Z",
        "fields": {
            "value": 0.64
        }
    }
]
client.write_points(json_body)