Merge branch 'server-165' of uskycloud/usky-data into master

data-tsdb-proxy/data-tsdb-proxy-biz/src/main/java/com/usky/demo/service/rocketmq/SimpleContext.java

@@ -29,6 +29,7 @@ public class SimpleContext {
         Map map_data = JsonUtils.fromJson(message,Map.class);
         String deviceId = map_data.get("device_id").toString();
         String productId = map_data.get("product_code").toString().toLowerCase();
+        Long timestamp = Long.valueOf(map_data.get("timestamp").toString());
         String tableName = productId+'_'+deviceId;
 
         Object tg = JSONObject.toJSONString(map_data.get("tags"));
@@ -43,7 +44,7 @@ public class SimpleContext {
             fields.put(entry.toLowerCase(),metrics.get(entry));
         }
 
-        influxDBUtils.insertOne(tableName,tags,fields);
+        influxDBUtils.insertOne1(tableName,tags,fields,timestamp);
     }
 }
 

data-tsdb-proxy/data-tsdb-proxy-biz/src/main/java/com/usky/demo/service/utils/TsdbUtils.java

@@ -46,6 +46,23 @@ public class TsdbUtils extends InfluxDbUtils {
         influxDB.write(builder.build());
     }
 
+    /**
+     * 插入单条数据写法2
+     *
+     * @param measurement
+     */
+    public void insertOne1(String measurement, Map<String, String> tags, Map<String, Object> fields, Long timestamp) {
+        //构建
+        Point.Builder builder = Point.measurement(measurement);
+        //可指定时间戳
+        builder.time(timestamp, TimeUnit.MILLISECONDS);
+        //tag属性只能存储String类型
+        builder.tag(tags);
+        //设置field
+        builder.fields(fields);
+        influxDB.write(builder.build());
+    }
+
     /**
      * 插入单条数据
      * influxDB开启UDP功能, 默认端口:8089,默认数据库:udp,没提供代码传数据库功能接口