mandodb API完全指南从插入到查询的完整操作教程【免费下载链接】mandodb A minimize Time Series Database, written from scratch as a learning project. 从零开始实现一个 TSDB项目地址: https://gitcode.com/gh_mirrors/ma/mandodbmandodb是一个从零开始实现的轻量级时序数据库TSDB专为学习项目设计。本指南将帮助你快速掌握mandodb的核心API操作包括数据库初始化、数据插入、范围查询等关键功能让你轻松上手这个简单而强大的时序数据存储解决方案。一、环境准备与数据库初始化1.1 安装与引入首先需要克隆mandodb仓库到本地环境git clone https://gitcode.com/gh_mirrors/ma/mandodb在Go项目中引入mandodb包import github.com/chenjiandongx/mandodb1.2 创建数据库实例使用OpenTSDB函数创建数据库实例支持多种配置选项来自定义数据库行为// 创建默认配置的TSDB实例 db, err : mandodb.OpenTSDB() if err ! nil { panic(err) } defer db.Close()1.3 高级配置选项mandodb提供丰富的配置选项通过Option模式进行设置// 自定义配置示例 db, err : mandodb.OpenTSDB( mandodb.WithDataPath(./data), // 设置数据存储路径 mandodb.WithRetention(30*24*time.Hour), // 设置数据保留时间为30天 mandodb.WithMetaBytesCompressorType(mandodb.ZstdBytesCompressor), // 使用ZSTD压缩 mandodb.WithMaxRowsPerSegment(1000000), // 设置每个段的最大行数 )二、核心数据结构2.1 Point结构体Point表示一个时序数据点包含时间戳和数值type Point struct { Ts int64 // 时间戳 Unix 时间戳单位秒 Value float64 // 数值 }2.2 Row结构体Row表示一行完整的时序数据包含指标名、标签集和数据点type Row struct { Metric string // 指标名称 Labels LabelSet // 标签集合 Point Point // 数据点 }图1mandodb数据块结构示意图展示了数据在存储中的组织方式三、数据写入操作3.1 插入单条数据虽然mandodb没有专门的单条插入API但可以通过创建包含单条记录的切片来实现// 创建标签集 labels : mandodb.NewLabelSet(map[string]string{ host: server01, region: us-west, }) // 创建数据行 row : mandodb.Row{ Metric: cpu_usage, Labels: labels, Point: mandodb.Point{ Ts: time.Now().Unix(), Value: 0.75, }, } // 插入数据 err : db.InsertRows([]*mandodb.Row{row}) if err ! nil { // 处理错误 }3.2 批量插入数据mandodb优化了批量插入性能推荐使用批量插入来提高效率// 创建多条数据 rows : make([]*mandodb.Row, 0, 100) for i : 0; i 100; i { rows append(rows, mandodb.Row{ Metric: memory_usage, Labels: mandodb.NewLabelSet(map[string]string{host: fmt.Sprintf(server%02d, i%10)}), Point: mandodb.Point{ Ts: time.Now().Unix() - int64(i), Value: 0.3 float64(i%7)/10, }, }) } // 批量插入 err : db.InsertRows(rows) if err ! nil { // 处理错误 }图2mandodb I/O操作流程示意图展示了数据写入的内部处理过程四、数据查询操作4.1 范围查询QueryRangeQueryRange方法用于查询指定时间范围内的时序数据// 创建标签匹配器 matchers : mandodb.NewLabelMatcherSet() matchers.Add(host, mandodb.MatchEqual, server01) // 查询最近1小时的cpu_usage数据 start : time.Now().Add(-1 * time.Hour).Unix() end : time.Now().Unix() result, err : db.QueryRange(cpu_usage, matchers, start, end) if err ! nil { // 处理错误 } // 处理查询结果 for _, metricRet : range result { fmt.Printf(Labels: %v\n, metricRet.Labels) fmt.Println(Points:) for _, p : range metricRet.Points { fmt.Printf( %d: %.2f\n, p.Ts, p.Value) } }4.2 系列查询QuerySeriesQuerySeries方法用于查询符合条件的时序系列// 创建标签匹配器 matchers : mandodb.NewLabelMatcherSet() matchers.Add(region, mandodb.MatchEqual, us-west) // 查询最近24小时内的所有系列 start : time.Now().Add(-24 * time.Hour).Unix() end : time.Now().Unix() series, err : db.QuerySeries(matchers, start, end) if err ! nil { // 处理错误 } // 打印所有匹配的系列标签 for _, s : range series { fmt.Println(s) }4.3 标签值查询QueryLabelValuesQueryLabelValues方法用于查询指定标签的所有可能值// 查询最近7天内所有主机名 start : time.Now().Add(-7 * 24 * time.Hour).Unix() end : time.Now().Unix() hosts : db.QueryLabelValues(host, start, end) fmt.Println(Available hosts:) for _, host : range hosts { fmt.Println(host) }图3mandodb时间序列桶结构展示了数据如何按时间分片存储以优化查询性能五、数据库关闭与资源释放使用完毕后需要正确关闭数据库以确保数据持久化和资源释放// 关闭数据库 db.Close()Close方法会等待所有正在进行的写入操作完成并关闭所有打开的文件句柄和内存映射。六、高级特性与最佳实践6.1 内存模式配置mandodb支持仅内存模式适用于测试和临时数据存储db, err : mandodb.OpenTSDB( mandodb.WithOnlyMemoryMode(true), // 启用仅内存模式 )6.2 数据压缩配置选择合适的压缩算法可以显著减少磁盘占用// 使用Snappy压缩 db, err : mandodb.OpenTSDB( mandodb.WithMetaBytesCompressorType(mandodb.SnappyBytesCompressor), ) // 或使用ZSTD压缩更高压缩率稍高CPU开销 db, err : mandodb.OpenTSDB( mandodb.WithMetaBytesCompressorType(mandodb.ZstdBytesCompressor), )图4mandodb压缩窗口示意图展示了数据压缩的工作原理6.3 处理乱序写入mandodb默认支持乱序写入可通过配置调整// 禁用乱序写入支持提高性能降低数据完整性 db, err : mandodb.OpenTSDB( mandodb.WithEnabledOutdated(false), )总结本指南详细介绍了mandodb的核心API操作包括数据库初始化、数据结构、数据写入、查询操作以及高级特性。通过这些API你可以轻松实现时序数据的存储和查询功能。mandodb的设计简洁而高效适合作为学习时序数据库原理的入门项目也可用于简单的时序数据存储场景。无论是监控数据、传感器读数还是其他时间序列数据mandodb都提供了简单而强大的接口来管理和查询你的数据。开始使用mandodb体验时序数据库的魅力吧【免费下载链接】mandodb A minimize Time Series Database, written from scratch as a learning project. 从零开始实现一个 TSDB项目地址: https://gitcode.com/gh_mirrors/ma/mandodb创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
mandodb API完全指南从插入到查询的完整操作教程【免费下载链接】mandodb A minimize Time Series Database, written from scratch as a learning project. 从零开始实现一个 TSDB项目地址: https://gitcode.com/gh_mirrors/ma/mandodbmandodb是一个从零开始实现的轻量级时序数据库TSDB专为学习项目设计。本指南将帮助你快速掌握mandodb的核心API操作包括数据库初始化、数据插入、范围查询等关键功能让你轻松上手这个简单而强大的时序数据存储解决方案。一、环境准备与数据库初始化1.1 安装与引入首先需要克隆mandodb仓库到本地环境git clone https://gitcode.com/gh_mirrors/ma/mandodb在Go项目中引入mandodb包import github.com/chenjiandongx/mandodb1.2 创建数据库实例使用OpenTSDB函数创建数据库实例支持多种配置选项来自定义数据库行为// 创建默认配置的TSDB实例 db, err : mandodb.OpenTSDB() if err ! nil { panic(err) } defer db.Close()1.3 高级配置选项mandodb提供丰富的配置选项通过Option模式进行设置// 自定义配置示例 db, err : mandodb.OpenTSDB( mandodb.WithDataPath(./data), // 设置数据存储路径 mandodb.WithRetention(30*24*time.Hour), // 设置数据保留时间为30天 mandodb.WithMetaBytesCompressorType(mandodb.ZstdBytesCompressor), // 使用ZSTD压缩 mandodb.WithMaxRowsPerSegment(1000000), // 设置每个段的最大行数 )二、核心数据结构2.1 Point结构体Point表示一个时序数据点包含时间戳和数值type Point struct { Ts int64 // 时间戳 Unix 时间戳单位秒 Value float64 // 数值 }2.2 Row结构体Row表示一行完整的时序数据包含指标名、标签集和数据点type Row struct { Metric string // 指标名称 Labels LabelSet // 标签集合 Point Point // 数据点 }图1mandodb数据块结构示意图展示了数据在存储中的组织方式三、数据写入操作3.1 插入单条数据虽然mandodb没有专门的单条插入API但可以通过创建包含单条记录的切片来实现// 创建标签集 labels : mandodb.NewLabelSet(map[string]string{ host: server01, region: us-west, }) // 创建数据行 row : mandodb.Row{ Metric: cpu_usage, Labels: labels, Point: mandodb.Point{ Ts: time.Now().Unix(), Value: 0.75, }, } // 插入数据 err : db.InsertRows([]*mandodb.Row{row}) if err ! nil { // 处理错误 }3.2 批量插入数据mandodb优化了批量插入性能推荐使用批量插入来提高效率// 创建多条数据 rows : make([]*mandodb.Row, 0, 100) for i : 0; i 100; i { rows append(rows, mandodb.Row{ Metric: memory_usage, Labels: mandodb.NewLabelSet(map[string]string{host: fmt.Sprintf(server%02d, i%10)}), Point: mandodb.Point{ Ts: time.Now().Unix() - int64(i), Value: 0.3 float64(i%7)/10, }, }) } // 批量插入 err : db.InsertRows(rows) if err ! nil { // 处理错误 }图2mandodb I/O操作流程示意图展示了数据写入的内部处理过程四、数据查询操作4.1 范围查询QueryRangeQueryRange方法用于查询指定时间范围内的时序数据// 创建标签匹配器 matchers : mandodb.NewLabelMatcherSet() matchers.Add(host, mandodb.MatchEqual, server01) // 查询最近1小时的cpu_usage数据 start : time.Now().Add(-1 * time.Hour).Unix() end : time.Now().Unix() result, err : db.QueryRange(cpu_usage, matchers, start, end) if err ! nil { // 处理错误 } // 处理查询结果 for _, metricRet : range result { fmt.Printf(Labels: %v\n, metricRet.Labels) fmt.Println(Points:) for _, p : range metricRet.Points { fmt.Printf( %d: %.2f\n, p.Ts, p.Value) } }4.2 系列查询QuerySeriesQuerySeries方法用于查询符合条件的时序系列// 创建标签匹配器 matchers : mandodb.NewLabelMatcherSet() matchers.Add(region, mandodb.MatchEqual, us-west) // 查询最近24小时内的所有系列 start : time.Now().Add(-24 * time.Hour).Unix() end : time.Now().Unix() series, err : db.QuerySeries(matchers, start, end) if err ! nil { // 处理错误 } // 打印所有匹配的系列标签 for _, s : range series { fmt.Println(s) }4.3 标签值查询QueryLabelValuesQueryLabelValues方法用于查询指定标签的所有可能值// 查询最近7天内所有主机名 start : time.Now().Add(-7 * 24 * time.Hour).Unix() end : time.Now().Unix() hosts : db.QueryLabelValues(host, start, end) fmt.Println(Available hosts:) for _, host : range hosts { fmt.Println(host) }图3mandodb时间序列桶结构展示了数据如何按时间分片存储以优化查询性能五、数据库关闭与资源释放使用完毕后需要正确关闭数据库以确保数据持久化和资源释放// 关闭数据库 db.Close()Close方法会等待所有正在进行的写入操作完成并关闭所有打开的文件句柄和内存映射。六、高级特性与最佳实践6.1 内存模式配置mandodb支持仅内存模式适用于测试和临时数据存储db, err : mandodb.OpenTSDB( mandodb.WithOnlyMemoryMode(true), // 启用仅内存模式 )6.2 数据压缩配置选择合适的压缩算法可以显著减少磁盘占用// 使用Snappy压缩 db, err : mandodb.OpenTSDB( mandodb.WithMetaBytesCompressorType(mandodb.SnappyBytesCompressor), ) // 或使用ZSTD压缩更高压缩率稍高CPU开销 db, err : mandodb.OpenTSDB( mandodb.WithMetaBytesCompressorType(mandodb.ZstdBytesCompressor), )图4mandodb压缩窗口示意图展示了数据压缩的工作原理6.3 处理乱序写入mandodb默认支持乱序写入可通过配置调整// 禁用乱序写入支持提高性能降低数据完整性 db, err : mandodb.OpenTSDB( mandodb.WithEnabledOutdated(false), )总结本指南详细介绍了mandodb的核心API操作包括数据库初始化、数据结构、数据写入、查询操作以及高级特性。通过这些API你可以轻松实现时序数据的存储和查询功能。mandodb的设计简洁而高效适合作为学习时序数据库原理的入门项目也可用于简单的时序数据存储场景。无论是监控数据、传感器读数还是其他时间序列数据mandodb都提供了简单而强大的接口来管理和查询你的数据。开始使用mandodb体验时序数据库的魅力吧【免费下载链接】mandodb A minimize Time Series Database, written from scratch as a learning project. 从零开始实现一个 TSDB项目地址: https://gitcode.com/gh_mirrors/ma/mandodb创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
