| | |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.Random; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | import org.apache.iotdb.isession.pool.SessionDataSetWrapper; |
|---|
| | |
|---|
| | | import com.qianwen.mdc.collect.domain.TelemetryData; |
|---|
| | | import com.qianwen.mdc.collect.domain.TelemetryDataItem; |
|---|
| | | import com.qianwen.mdc.collect.mqtt.MqttMessageSender; |
|---|
| | | import com.qianwen.mdc.collect.utils.redis.RedisUtil; |
|---|
| | | |
|---|
| | | import cn.hutool.json.JSONUtil; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 采集数据处理入库 |
|---|
| | |
|---|
| | | int rowIndex = 0; |
|---|
| | | |
|---|
| | | Map<String, List<TypedTelemetryData>> processParamsMap = parseTelemetryToTypedMapList(dt); |
|---|
| | | |
|---|
| | | |
|---|
| | | String[] nameArr = processParamsMap.keySet().toArray(new String[0]); |
|---|
| | | String name; |
|---|
