summaryrefslogtreecommitdiff
path: root/staging/src
diff options
context:
space:
mode:
authorcai6489 <caichunbo@beyondcent.com>2023-10-11 17:38:48 +0800
committercai6489 <caichunbo@beyondcent.com>2023-10-11 17:38:48 +0800
commitddde7b4554788cc8f799542a8cff9e33f3d532a8 (patch)
tree0013e0c551a2cba05d953c3e783861ddff740008 /staging/src
parentupdate tdengine config (diff)
downloadkubeedge-ddde7b4554788cc8f799542a8cff9e33f3d532a8.tar.gz
modify tdengine client
Signed-off-by: cai6489 <caichunbo@beyondcent.com>
Diffstat (limited to 'staging/src')
-rw-r--r--staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/client.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/client.go b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/client.go
index 19bfefef6..6cfa01fd0 100644
--- a/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/client.go
+++ b/staging/src/github.com/kubeedge/mapper-framework/_template/mapper/data/dbmethod/tdengine/client.go
@@ -65,7 +65,7 @@ func (d *DataBaseConfig) AddData(data *common.DataModel) error {
stabel := fmt.Sprintf("CREATE STABLE %s (ts timestamp, devicename binary(64), propertyname binary(64), data binary(64),type binary(64)) TAGS (localtion binary(64));", legal_table)
- datatime := time.Unix(data.TimeStamp/1e3, 0).Format("2006-01-02 15:04:05")
+ datatime := time.Unix(data.TimeStamp, 0).Format("2006-01-02 15:04:05")
insertSQL := fmt.Sprintf("INSERT INTO %s USING %s TAGS ('%s') VALUES('%v','%s', '%s', '%s', '%s');",
legal_tag, legal_table, legal_tag, datatime, data.DeviceName, data.PropertyName, data.Value, data.Type)