1

zhang

2 天以前 49bd72038d6bae30a34c096f2cba8c5b11dbad8c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
Êþº¾4

java/lang/Object
<init>
()V
    

com/influxdb/v3/client/Point
measurement
2(Ljava/lang/String;)Lcom/influxdb/v3/client/Point;

setTags
/(Ljava/util/Map;)Lcom/influxdb/v3/client/Point;

    setFields

java/time/Instant
now
()Ljava/time/Instant;

toEpochMilli
()J
 !"#
java/lang/Long
valueOf
(J)Ljava/lang/Long;    %&'()
+com/influxdb/v3/client/write/WritePrecision
MS
-Lcom/influxdb/v3/client/write/WritePrecision;
+,-
setTimestamp
](Ljava/lang/Long;Lcom/influxdb/v3/client/write/WritePrecision;)Lcom/influxdb/v3/client/Point;    /0123
1com/zy/component/influxdb/service/InfluxDBService
influxDBClient
'Lcom/influxdb/v3/client/InfluxDBClient;56789
%com/influxdb/v3/client/InfluxDBClient

writePoint
!(Lcom/influxdb/v3/client/Point;)V;
java/lang/Exception    /=>?
logger
Lorg/slf4j/Logger;A
%Failed to write data to the database.CDEFG
org/slf4j/Logger
error
(Ljava/lang/String;)V
:IJ
printStackTrace5LMN
    queryRows
-(Ljava/lang/String;)Ljava/util/stream/Stream;P
查询数据：{}
RSTUV
java/util/stream/Collectors
toList
()Ljava/util/stream/Collector;XYZ[\
java/util/stream/Stream
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;C^_`
info
'(Ljava/lang/String;Ljava/lang/Object;)Vb
'Failed to query data from the database.
defgh
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
Code
LineNumberTable
LocalVariableTable
this
3Lcom/zy/component/influxdb/service/InfluxDBService;
    writeData
3(Ljava/lang/String;Ljava/util/Map;Ljava/util/Map;)V

e
Ljava/lang/Exception;
Ljava/lang/String;
tags
Ljava/util/Map;
fields
point
Lcom/influxdb/v3/client/Point;
LocalVariableTypeTable
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
 StackMapTable
java/lang/String
 java/util/Map
MethodParameters
    Signature
(Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)V
    queryData
$(Ljava/lang/String;)Ljava/util/List;
    mapStream
Ljava/util/stream/Stream;
sql
PLjava/util/stream/Stream<Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;>;
[(Ljava/lang/String;)Ljava/util/List<Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;>;
<clinit>

SourceFile
InfluxDBService.java
(Lorg/springframework/stereotype/Service;!/>?23
i
j

k/

*·
±l
m
no
pqk
=+¸,¶ -¶¸¶¸²$¶*:*´.¹4§:²<@¹B¶H±
(+:l*
$%    &')(-+*-+7,<.m>-rs=no=t
=uv=wv xyz=u{=w|}ÿ+/~€€
:‚ uwƒ„
…†k·1*´.+¹KM²<O,¸Q¹W¹]
°M²<a¹B,¶H
°
 :l9:E F!G+H/Jm*‡ˆ!rs1no1‰t
z
‡Š}
`:‚
‰ƒ‹Œ
k!
    /¸c³<±
l
Ži
