많은 프로그램 개발자들이 주로 OMI(운영 지표 지표) 및 이벤트 데이터를 저장하는 데 사용되는 오픈 소스 분산 시계열 데이터 저장소인 InfluxDB에 대해 들어본 적이 있을 것입니다. InfluxDB의 핵심 기능에는 고성능, 확장성 및 강력한 쿼리 언어가 포함됩니다. 또한 InfluxDB는 Go를 포함한 여러 언어로 클라이언트 SDK도 제공합니다.
Go 언어는 매우 강력한 프로그래밍 언어입니다. 효율적이고 동시성이 있으며 마이크로서비스 작성에도 적합합니다. 이번 글에서는 InfluxDB를 사용하여 Go 언어로 시계열 데이터를 연산하는 방법을 소개하겠습니다. 다음 내용을 다룰 것입니다:
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 중국어 웹사이트의 기타 관련 기사를 참조하세요!