@@ -565,9 +565,9 @@ func (ds *DataSync) syncbucketdata(mqlfrom string, cifrom, cito *dbo.ClassInfoHe
dat := cast.ToSlice(data[i])
if len(dat) >= 3 {
m := map[string]any{}
- m["timestamp"] = dat[0]
- m["name"] = dat[1]
- m["value"] = dat[2]
+ m["__timestamp__"] = dat[0]
+ m["__name__"] = dat[1]
+ m["__value__"] = dat[2]
if len(dat) >= 4 {
tm := cast.ToStringMap(dat[3])
for k, v := range tm {