tdengine

func (*TdEngine) BatchInsertDeviceData ¶

func (m *TdEngine) BatchInsertDeviceData(deviceKey string, deviceDataList []iotModel.ReportPropertyData) (resultNum int, err error)

BatchInsertDeviceData 批量插入单设备的数据

func (*TdEngine) BatchInsertLogData ¶

func (m *TdEngine) BatchInsertLogData(deviceLogList map[string][]iotModel.DeviceLog) (resultNum int, err error)

BatchInsertLogData 批量插入日志数据

func (*TdEngine) BatchInsertMultiDeviceData ¶

func (m *TdEngine) BatchInsertMultiDeviceData(multiDeviceDataList map[string][]iotModel.ReportPropertyData) (resultNum int, err error)

BatchInsertMultiDeviceData 插入多设备的数据

func (*TdEngine) Close ¶

func (m *TdEngine) Close()

func (*TdEngine) Count ¶

func (m *TdEngine) Count(table string) (int, error)

Count 统计表中数据条数

func (*TdEngine) GetAllDatabaseName ¶

func (m *TdEngine) GetAllDatabaseName(ctx context.Context) (names []string, err error)

GetAllDatabaseName 获取所有数据库名称

func (*TdEngine) GetTableData ¶

func (m *TdEngine) GetTableData(ctx context.Context, tableName string) (table *iotModel.TsdTableDataInfo, err error)

GetTableData 获取指定数据表数据信息

func (*TdEngine) GetTableDataAll ¶

func (m *TdEngine) GetTableDataAll(ctx context.Context, sqlStr string, args ...any) (rs gdb.Result, err error)

GetTableDataAll 获取超级表的多条数据

func (*TdEngine) GetTableDataOne ¶

func (m *TdEngine) GetTableDataOne(ctx context.Context, sqlStr string, args ...any) (rs gdb.Record, err error)

GetTableDataOne 获取超级表的单条数据

func (*TdEngine) GetTableInfo ¶

func (m *TdEngine) GetTableInfo(ctx context.Context, tableName string) (table []*iotModel.TsdTableInfo, err error)

GetTableInfo 获取指定数据表结构信息

func (*TdEngine) GetTableListByDatabase ¶

func (m *TdEngine) GetTableListByDatabase(ctx context.Context, dbName string) (tableList []iotModel.TsdTables, err error)

GetTableListByDatabase 获取指定的数据库下所有的表

func (*TdEngine) Initialization ¶

func (m *TdEngine) Initialization(ctx context.Context) (err error)

Initialization 初始化tsd相关的设备数据

func (*TdEngine) InsertDeviceData ¶

func (m *TdEngine) InsertDeviceData(deviceKey string, data iotModel.ReportPropertyData, subKey ...string) (err error)

InsertDeviceData 插入设备数据

func (*TdEngine) InsertLogData ¶

func (m *TdEngine) InsertLogData(log iotModel.DeviceLog) (result sql.Result, err error)

InsertLogData 插入日志数据

func (*TdEngine) Query ¶

func (m *TdEngine) Query(sql string) (rows *sql.Rows, err error)

Query 查询

func (*TdEngine) WatchDeviceData ¶

func (m *TdEngine) WatchDeviceData(deviceKey string, callback func(data iotModel.ReportPropertyData)) (err error)

WatchDeviceData 监听设备数据日志