소스 검색

优化data-tsdb服务中消费mq消息的方法中超级表写入逻辑;

james 1 주 전
부모
커밋
40612873a9
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      data-tsdb-proxy/data-tsdb-proxy-biz/src/main/java/com/usky/demo/service/rocketmq/tdengine/tdengine.java

+ 1 - 1
data-tsdb-proxy/data-tsdb-proxy-biz/src/main/java/com/usky/demo/service/rocketmq/tdengine/tdengine.java

@@ -36,7 +36,7 @@ public class tdengine implements MqttStrategy {
             String productCode = map_data.get("productCode").toString().toLowerCase();
             Long timestamp = Long.valueOf(map_data.get("timestamp").toString());
             String tableName = "_"+deviceUUId;
-            String STableName = "sup_"+productCode;
+            String STableName = "super_"+productCode;
 
             StringBuilder tagValue = new StringBuilder();
             Object tg = JSONObject.toJSONString(map_data.get("tags"));