Menggunakan InfluxDB dalam Go: Panduan Lengkap

Saya percaya ramai pembangun program telah mendengar tentang InfluxDB, yang merupakan sumber terbuka, storan data siri masa teragih, terutamanya digunakan untuk menyimpan penunjuk metrik operasi (OMI) dan data peristiwa. Ciri teras InfluxDB termasuk prestasi tinggi, kebolehskalaan dan bahasa pertanyaan yang berkuasa. Selain itu, InfluxDB juga menyediakan SDK pelanggan dalam pelbagai bahasa, termasuk Go.

Bahasa Go ialah bahasa pengaturcaraan yang sangat berkuasa. Ia cekap dan selaras, dan juga sesuai untuk menulis perkhidmatan mikro. Dalam artikel ini, kami akan memperkenalkan cara menggunakan InfluxDB untuk mengendalikan data siri masa dalam bahasa Go. Kami akan meliputi perkara berikut:

• Cara memasang InfluxDB dan mulakan InfluxDB
• Cara memasang SDK klien InfluxDB dalam bahasa Go
• Cara mencipta pangkalan data InfluxDB
• Cara melaksanakan operasi pertanyaan InfluxDB asas
• Cara menulis dan membaca pangkalan data InfluxDB melalui bahasa Go

Pasang InfluxDB

Sebelum anda bermula menggunakan InfluxDB, Kita perlu memasang dan memulakan InfluxDB terlebih dahulu. Laman web rasmi InfluxDB menyediakan panduan pemasangan terperinci untuk pelbagai sistem pengendalian. Sila pilih panduan pemasangan yang sesuai berdasarkan versi sistem pengendalian semasa anda.

Selepas pemasangan selesai, anda boleh memulakan InfluxDB dengan arahan berikut:

$ influxd

Pasang InfluxDB Go SDK

Bahasa Go mempunyai SDK pelanggan InfluxDB rasmi yang boleh kami guna. Gunakan SDK Pelanggan InfluxDB dalam aplikasi anda untuk menyambung dengan mudah ke pangkalan data InfluxDB untuk menulis dan membaca data daripada pangkalan data. Kita boleh memasang InfluxDB SDK dalam projek bahasa Go menggunakan arahan berikut:

go get github.com/influxdata/influxdb1-client/v2

Buat pangkalan data InfluxDB

Sebelum kita mula menulis data, kita perlu mencipta pangkalan data InfluxDB. Anda boleh menggunakan antara muka web InfluxDB, atau anda boleh menggunakan kemasukan alat CLI:

$ influx
Connected to http://localhost:8086 version 1.8.0
InfluxDB shell version: 1.8.0

> create database mydb

Setelah selesai, kami boleh menggunakan arahan berikut untuk menyenaraikan semua pangkalan data:

> show databases
name: databases
-----------
name
_internal
mydb

Laksanakan pertanyaan InfluxDB

Selain menyambung ke InfluxDB dalam bahasa Go, kami juga boleh menggunakan influx untuk melaksanakan pertanyaan InfluxDB secara manual. Berikut ialah contoh mudah:

$ influx
Connected to http://localhost:8086 version 1.8.0
InfluxDB shell version: 1.8.0

> use mydb
Using database mydb

> insert temperature value=25.5
> insert temperature value=28.0

> select * from temperature
name: temperature
time                value
----                -----
1623102590352798368 25.5
1623102590981854175 28

Dalam contoh ini, kami sedang memasukkan dua nilai suhu ke dalam pangkalan data yang dipanggil mydb. Kami kemudiannya melaksanakan pertanyaan mudah untuk mendapatkan semua data suhu.

Menggunakan InfluxDB dalam Go

Berikut ialah beberapa contoh penggunaan asas InfluxDB Go SDK:

package main

import (
    "fmt"
    "time"
    "github.com/influxdata/influxdb1-client/v2"
)

func main() {
    // 初始化 InfluxDB 客户端
    c, err := client.NewHTTPClient(client.HTTPConfig{
        Addr: "http://localhost:8086",
    })
    if err != nil {
        fmt.Println("Error creating InfluxDB Client: ", err.Error())
    }
    defer c.Close()

    // 创建新的 InfluxDB 数据点
    tags := map[string]string{"test": "test123"}
    fields := map[string]interface{}{
        "value": 35.6,
    }
    pt, err := client.NewPoint("temperature", tags, fields, time.Now())
    if err != nil {
        fmt.Println("Error: ", err.Error())
    }

    // 写入数据点到 InfluxDB
    bp, err := client.NewBatchPoints(client.BatchPointsConfig{
        Database:  "mydb",
        Precision: "s",
    })
    if err != nil {
        fmt.Println("Error: ", err.Error())
    }
    bp.AddPoint(pt)
    err = c.Write(bp)
    if err != nil {
        fmt.Println("Error: ", err.Error())
    }

    // 查询 InfluxDB 数据点
    q := client.Query{
        Command:  `SELECT "value" FROM "temperature"`,
        Database: "mydb",
    }
    res, err := c.Query(q)
    if err != nil {
        fmt.Println("Error: ", err.Error())
    }

    var value float64
    for _, row := range res.Results[0].Series[0].Values {
        value = row[1].(float64)
    }
    fmt.Printf("%+v
", value)
}

Dalam contoh ini, kami mula-mula memulakan klien InfluxDB Go SDK. Seterusnya, kami mencipta titik data InfluxDB baharu secara manual dan menambahkannya pada kumpulan data. Akhir sekali, kami menggunakan InfluxDB Go SDK untuk menanyakan titik data dan mencetak nilai pulangannya ke konsol.

Kesimpulan

Dalam artikel ini, kami memperkenalkan cara menggunakan InfluxDB untuk mengendalikan data siri masa dalam bahasa Go dan menunjukkan cara menggunakan InfluxDB Go SDK. Kami belajar cara memasang dan memulakan InfluxDB, dan mencipta pangkalan data InfluxDB. Kami juga mempelajari cara melaksanakan pertanyaan InfluxDB asas dan menunjukkan cara menulis dan membaca daripada pangkalan data InfluxDB melalui bahasa Go. Kami berharap artikel ini membantu pembangun Go yang ingin menggunakan InfluxDB.

Atas ialah kandungan terperinci Menggunakan InfluxDB dalam Go: Panduan Lengkap. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!