deviceMsg

Documentation

Overview

Package device 设备发送来的消息解析

Package device 设备操作日志

Package repo 本文件是提供设备模型数据存储的信息

Package device 设备操作日志

Index

• type ConnectMsg
  • func GetDevConnMsg(ctx context.Context, data []byte) (*ConnectMsg, error)
• type EventData
• type FilterOpt
  • func (f FilterOpt) Check() error
• type HubFilter
• type HubLog
• type HubLogRepo
• type PropertyData
• type PublishMsg
  • func GetDevPublish(ctx context.Context, data []byte) (*PublishMsg, error)
  • func (p *PublishMsg) String() string
• type SDKLog
• type SDKLogRepo
• type SchemaDataRepo

Types

type ConnectMsg

type ConnectMsg struct {
	ClientID  string
	Username  string
	Timestamp time.Time
	Address   string
	Action    string
	Reason    string
}

连接和断连消息信息

func GetDevConnMsg

func GetDevConnMsg(ctx context.Context, data []byte) (*ConnectMsg, error)

type EventData

type EventData struct {
	ID        string         `json:"id" `        //事件id
	Type      string         `json:"type" `      //事件类型: 信息:info  告警alert  故障:fault
	Params    map[string]any `json:"params" `    //事件参数
	TimeStamp time.Time      `json:"timeStamp" ` //时间戳
}

EventData 事件数据

type FilterOpt

type FilterOpt struct {
	Page        def.PageInfo2
	ProductID   string
	DeviceNames []string
	DataID      string
	Types       []string //事件类型: 信息:info  告警alert  故障:fault
	Order       int32    //0:aes(默认,从久到近排序) 1:desc(时间从近到久排序)
	Interval    int64    //间隔(单位毫秒) 如果这个值不为零值 则时间的开始和结束必须有效及聚合函数不应该为空
	Fill        string   //指定窗口区间数据缺失的情况下的填充模式
	ArgFunc     string   //聚合函数 avg:平均值 first:第一个参数 last:最后一个参数 count:总数 twa: 时间加权平均函数 参考:https://docs.taosdata.com/taos-sql/function
}

FILL 语句指定某一窗口区间数据缺失的情况下的填充模式。填充模式包括以下几种： 不进行填充：NONE（默认填充模式）。 VALUE 填充：固定值填充，此时需要指定填充的数值。例如：FILL(VALUE, 1.23)。这里需要注意，最终填充的值受由相应列的类型决定，如 FILL(VALUE, 1.23)，相应列为 INT 类型，则填充值为 1。 PREV 填充：使用前一个非 NULL 值填充数据。例如：FILL(PREV)。 NULL 填充：使用 NULL 填充数据。例如：FILL(NULL)。 LINEAR 填充：根据前后距离最近的非 NULL 值做线性插值填充。例如：FILL(LINEAR)。 NEXT 填充：使用下一个非 NULL 值填充数据。例如：FILL(NEXT)。

func (FilterOpt) Check

func (f FilterOpt) Check() error

type HubFilter

type HubFilter struct {
	ProductID  string   // 产品id
	DeviceName string   // 设备名称
	Actions    []string //过滤操作类型 connected:上线 disconnected:下线  property:属性 event:事件 action:操作 thing:物模型提交的操作为匹配的日志
	Topics     []string //过滤主题
	Content    string   //过滤内容
	RequestID  string   //过滤请求ID
}

type HubLog

type HubLog struct {
	ProductID  string    `json:"productID"`  // 产品id
	DeviceName string    `json:"deviceName"` // 设备名称
	Content    string    `json:"content"`    // 具体信息
	Topic      string    `json:"topic"`      // 主题
	Action     string    `json:"action"`     // 操作类型
	Timestamp  time.Time `json:"timestamp"`  // 操作时间
	RequestID  string    `json:"requestID"`  // 请求ID
	TranceID   string    `json:"tranceID"`   // 服务器端事务id
	ResultType int64     `json:"resultType"` // 请求结果状态,0为成功
}

type HubLogRepo

type HubLogRepo interface {
	GetDeviceLog(ctx context.Context, filter HubFilter, page def.PageInfo2) ([]*HubLog, error)
	GetCountLog(ctx context.Context, filter HubFilter, page def.PageInfo2) (int64, error)
	Insert(ctx context.Context, data *HubLog) error
}

type PropertyData

type PropertyData struct {
	ID        string    `json:"id"`         //属性的id
	Param     any       `json:"property" `  //一个属性的参数
	TimeStamp time.Time `json:"timeStamp" ` //时间戳
}

PropertyData 属性数据

type PublishMsg

type PublishMsg struct {
	Topic      string
	Payload    []byte
	Timestamp  time.Time
	ProductID  string
	DeviceName string
}

func GetDevPublish

func GetDevPublish(ctx context.Context, data []byte) (*PublishMsg, error)

func (*PublishMsg) String

func (p *PublishMsg) String() string

type SDKLog

type SDKLog struct {
	ProductID   string    `json:"productID"`  // 产品id
	DeviceName  string    `json:"deviceName"` // 设备名称
	Content     string    `json:"content"`    // 具体信息
	Timestamp   time.Time `json:"timestamp"`  // 操作时间
	ClientToken string    `json:"clientToken"`
	LogLevel    int64     `json:"log_level"`
}

type SDKLogRepo

type SDKLogRepo interface {
	GetDeviceSDKLog(ctx context.Context, productID, deviceName string, page def.PageInfo2) ([]*SDKLog, error)
	Insert(ctx context.Context, data *SDKLog) error
}

type SchemaDataRepo

type SchemaDataRepo interface {
	// InsertEventData 插入事件数据
	InsertEventData(ctx context.Context, productID string, deviceName string, event *EventData) error
	// InsertPropertyData 插入一条属性数据
	InsertPropertyData(ctx context.Context, t *schema.Model, productID string, deviceName string, property *PropertyData) error
	// InsertPropertiesData 插入多条属性数据 params key为属性的id,val为属性的值
	InsertPropertiesData(ctx context.Context, t *schema.Model, productID string, deviceName string, params map[string]any, timestamp time.Time) error
	// GetEventDataWithID 根据事件id获取事件信息
	GetEventDataByFilter(ctx context.Context, filter FilterOpt) ([]*EventData, error)
	GetEventCountByFilter(ctx context.Context, filter FilterOpt) (int64, error)
	// GetPropertyDataByID 根据属性id获取属性信息
	GetPropertyDataByID(ctx context.Context, filter FilterOpt) ([]*PropertyData, error)
	GetPropertyCountByID(ctx context.Context, filter FilterOpt) (int64, error)
}