influxdb

func BatchInsert ¶

func BatchInsert[T any](ctx context.Context, c *Client, data []*T, mapper Mapper[T]) error

BatchInsert 批量插入数据

func BoolToString ¶

func BoolToString(value *bool) string

func BuildQuery ¶

func BuildQuery(
	table string,
	filters map[string]interface{},
	operators map[string]string,
	fields []string,
) (string, []interface{})

func BuildQueryWithParams ¶

func BuildQueryWithParams(
	table string,
	filters map[string]interface{},
	operators map[string]string,
	fields []string,
) string

func ConvertAnyToPointsSafe ¶

func ConvertAnyToPointsSafe(pts []any) ([]*influxdb3.Point, error)

ConvertAnyToPointsSafe 将 []any 逐元素断言为 []*influxdb3.Point

func GetBoolPointTag ¶

func GetBoolPointTag(point *influxdb3.Point, name string) *bool

func GetEnumPointTag ¶

func GetEnumPointTag[T ~int32](point *influxdb3.Point, name string, valueMap map[string]int32) *T

func GetPointTag ¶

func GetPointTag(point *influxdb3.Point, name string) *string

func GetTimestampField ¶

func GetTimestampField(point *influxdb3.Point, name string) *timestamppb.Timestamp

func GetUint32Field ¶

func GetUint32Field(point *influxdb3.Point, name string) *uint32

func GetUint32PointTag ¶

func GetUint32PointTag(point *influxdb3.Point, name string) *uint32

func GetUint64PointTag ¶

func GetUint64PointTag(point *influxdb3.Point, name string) *uint64

func Insert ¶

func Insert[T any](ctx context.Context, c *Client, data *T, mapper Mapper[T]) error

Insert 插入数据

func ProtoMessageToPoint ¶

func ProtoMessageToPoint(msg proto.Message, overrides map[string]string) (*influxdb3.Point, error)

ProtoMessageToPoint 将 protobuf message 转为 influxdb3.Point。 参数 overrides 可选：map[key]=role，key 为 protobuf 字段的 JSON 名称（例如 "deviceId"），role 为 "measurement"/"tag"/"field"/"time"。 约定识别规则（在无 overrides 时）：

• 字段名为 "measurement" -> measurement
• 名称以 "_tag" 或以 "tag_" 前缀 -> tag
• 字段类型为 google.protobuf.Timestamp 或名为 "time"/"timestamp" -> time
• 其它标量 -> field

example.proto:

syntax = "proto3"; import "google/protobuf/timestamp.proto";

message SensorProto {
		string measurement = 1;           // 当作为 measurement 使用
		string device_id = 2;             // 作为 tag
		string location = 3;              // 作为 tag
		double temperature = 4;           // field
		int64 battery = 5;                // field
		google.protobuf.Timestamp ts = 6; // time
}

Go 使用示例（将 pb 替换为实际生成包路径，例如 `github.com/you/project/pb`）

package influxdb_test

import (

"fmt"
"time"

"github.com/InfluxCommunity/influxdb3-go/v2/influxdb3"
"google.golang.org/protobuf/types/known/timestamppb"

// 替换为你的 protobuf 生成包
pb "path/to/your/generated/pb"

// 假设 ProtoMessageToPoint 位于本模块的 influxdb 包
"your/module/path/influxdb"

)

func ExampleProtoMessageToPoint_basic() {
	// 构造 protobuf message
	msg := &pb.SensorProto{
		Measurement: "sensors",
		DeviceId:    "dev-1",
		Location:    "room1",
		Temperature: 23.5,
		Battery:     95,
		Ts:          timestamppb.New(time.Now().UTC()),
	}

	// 不传 overrides：按约定自动分类（字段名 measurement -> measurement，ts -> time，带 tag hint 的字段 -> tag）
	pt, err := influxdb.ProtoMessageToPoint(msg, nil)
	if err != nil {
		fmt.Println("err:", err)
		return
	}
	// 打印示例：measurement/tags/fields/time
	fmt.Println("measurement:", pt.GetMeasurement())
	fmt.Println("tag device_id:", pt.GetTag("device_id"))
	fmt.Println("field temperature:", pt.GetField("temperature"))
}

func ExampleProtoMessageToPoint_withOverrides() {
	msg := &pb.SensorProto{
		// 假设 proto 中没有 measurement 字段或你希望使用其它字段作为 measurement
		DeviceId:    "dev-1",
		Location:    "room1",
		Temperature: 23.5,
		Battery:     95,
		Ts:          timestamppb.New(time.Now().UTC()),
	}

	// overrides 的 key 使用 protobuf 字段的 JSON 名称（例如 proto 字段 device_id 的 json 名称通常为 "deviceId"）
	overrides := map[string]string{
		"deviceId":    "measurement", // 把 deviceId 当作 measurement
		"location":    "tag",         // 强制 location 为 tag
		"battery":     "field",
		"ts":          "time",
		"temperature": "field",
	}

	pt, err := influxdb.ProtoMessageToPoint(msg, overrides)
	if err != nil {
		fmt.Println("err:", err)
		return
	}
	fmt.Println("measurement:", pt.GetMeasurement())
	fmt.Println("tags:", pt.GetTags())
	fmt.Println("fields:", pt.GetFields())
}

func Query ¶

func Query[T any](ctx context.Context, c *Client, query string, mapper Mapper[T]) ([]*T, error)

Query 查询数据

func StructToPoint ¶

func StructToPoint(s interface{}) (*influxdb3.Point, error)

StructToPoint 通用转换函数：将带 influx tag 的 struct 转为 influxdb3.Point 参数：s 带 tag 的 struct 实例（不能是指针）

func Uint64ToString ¶

func Uint64ToString(value *uint64) string