Go에서 InfluxDB 사용: 전체 가이드

많은 프로그램 개발자들이 주로 OMI(운영 지표 지표) 및 이벤트 데이터를 저장하는 데 사용되는 오픈 소스 분산 시계열 데이터 저장소인 InfluxDB에 대해 들어본 적이 있을 것입니다. InfluxDB의 핵심 기능에는 고성능, 확장성 및 강력한 쿼리 언어가 포함됩니다. 또한 InfluxDB는 Go를 포함한 여러 언어로 클라이언트 SDK도 제공합니다.

Go 언어는 매우 강력한 프로그래밍 언어입니다. 효율적이고 동시성이 있으며 마이크로서비스 작성에도 적합합니다. 이번 글에서는 InfluxDB를 사용하여 Go 언어로 시계열 데이터를 연산하는 방법을 소개하겠습니다. 다음 내용을 다룰 것입니다:

• InfluxDB를 설치하고 InfluxDB를 시작하는 방법
• Go 언어로 InfluxDB 클라이언트 SDK를 설치하는 방법
• InfluxDB 데이터베이스를 만드는 방법
• 기본 InfluxDB 쿼리 작업을 수행하는 방법
• 작성 방법 Go 언어를 통해 그리고 InfluxDB 데이터베이스를 읽어보세요

InfluxDB 설치

InfluxDB를 사용하기 전에 InfluxDB를 설치하고 시작해야 합니다. InfluxDB 공식 웹사이트에서는 다양한 운영 체제에 대한 자세한 설치 가이드를 제공합니다. 현재 운영 체제 버전에 따라 적절한 설치 가이드를 선택하십시오.

설치가 완료된 후 다음 명령을 사용하여 InfluxDB를 시작할 수 있습니다.

$ influxd

InfluxDB Go SDK 설치

Go 언어에는 우리가 사용할 수 있는 공식 InfluxDB 클라이언트 SDK가 있습니다. 애플리케이션에서 InfluxDB 클라이언트 SDK를 사용하면 InfluxDB 데이터베이스에 쉽게 연결하여 데이터베이스에 데이터를 쓰고 읽을 수 있습니다. 다음 명령을 사용하여 Go 언어 프로젝트에 InfluxDB SDK를 설치할 수 있습니다.

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

InfluxDB 데이터베이스 만들기

데이터 쓰기를 시작하기 전에 InfluxDB 데이터베이스를 만들어야 합니다. InfluxDB의 웹 인터페이스를 사용하거나 CLI 도구 influx를 사용할 수 있습니다.

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

> create database mydb

완료 후 다음 명령을 사용하여 모든 데이터베이스를 나열할 수 있습니다.

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

Execute InfluxDB query

Go 언어로 InfluxDB에 연결하는 것 외에도 , influx를 사용하여 InfluxDB 쿼리를 수동으로 실행할 수도 있습니다. 다음은 간단한 예입니다.

$ 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

이 예에서는 mydb라는 데이터베이스에 두 개의 온도 값을 삽입했습니다. 그런 다음 모든 온도 데이터를 얻기 위해 간단한 쿼리를 실행했습니다.

Go에서 InfluxDB 사용

다음은 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)
}

이 예에서는 먼저 InfluxDB Go SDK를 사용하여 클라이언트를 초기화합니다. 다음으로, 새로운 InfluxDB 데이터 포인트를 수동으로 생성하여 데이터 배치에 추가했습니다. 마지막으로 InfluxDB Go SDK를 사용하여 데이터 포인트를 쿼리하고 반환 값을 콘솔에 인쇄합니다.

결론

이 글에서는 InfluxDB를 사용하여 Go 언어로 시계열 데이터를 조작하는 방법을 소개하고 InfluxDB Go SDK를 사용하는 방법을 시연했습니다. InfluxDB를 설치 및 시작하고 InfluxDB 데이터베이스를 생성하는 방법을 배웠습니다. 또한 기본 InfluxDB 쿼리를 수행하는 방법을 배웠고 Go 언어를 통해 InfluxDB 데이터베이스에서 쓰고 읽는 방법을 시연했습니다. 이 글이 InfluxDB를 사용하려는 Go 개발자에게 도움이 되기를 바랍니다.

위 내용은 Go에서 InfluxDB 사용: 전체 가이드의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!