1

zhang

23 小时以前 d35e2accdca4b3762359231f4fe479c9538b6f6f

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
Êþº¾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/System
out
Ljava/io/PrintStream;A
Data written to the database.
CDEFG
java/io/PrintStream
println
(Ljava/lang/String;)VI
java/lang/Exception    /KLM
logger
Lorg/slf4j/Logger;O
%Failed to write data to the database.QRSTG
org/slf4j/Logger
error
HVW
printStackTrace5YZ[
query
-(Ljava/lang/String;)Ljava/util/stream/Stream;]
查询数据：{}Q_`a
info
'(Ljava/lang/String;Ljava/lang/Object;)Vcde
apply
()Ljava/util/function/Function;ghijk
java/util/stream/Stream
map
8(Ljava/util/function/Function;)Ljava/util/stream/Stream;
mnopq
java/util/stream/Collectors
toList
()Ljava/util/stream/Collector;gstu
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;w
java/util/Listy
'Failed to query data from the database.{
java/util/LinkedHashMap
z~
java/lang/String€‚ƒ„
 java/util/Map
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
†‡ˆ‰Š
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
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;
Ljava/util/stream/Stream;
Ljava/util/List;
sql
.Ljava/util/stream/Stream<[Ljava/lang/Object;>;
GLjava/util/List<Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;>;
[(Ljava/lang/String;)Ljava/util/List<Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;>;
lambda$queryData$0
$([Ljava/lang/Object;)Ljava/util/Map;

i

I
record
[Ljava/lang/Object;
<clinit>

SourceFile
InfluxDBService.java
(Lorg/springframework/stereotype/Service;
BootstrapMethods·
¸¹º»¼
"java/lang/invoke/LambdaMetafactory
metafactory
Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;¾
&(Ljava/lang/Object;)Ljava/lang/Object;À
/Á«¬¬
InnerClassesÅ
%java/lang/invoke/MethodHandles$LookupÇ
java/lang/invoke/MethodHandles
Lookup!/LM23
‹
Œ

/

*·
±Ž

‘
’“
E+¸,¶ -¶¸¶¸²$¶*:*´.¹4²:@¶B§:²JN¹P¶U±
03HŽ.%&    '(*(+0/3,5-?.D0>5”•E‘E–
E—˜E™˜(š›œE—E™žŸÿ3/}€€
H  —™¡¢
£¤â@*´.+¹XM²J\,¹^,ºb¹f¸l¹rÀvN-°M²Jx¹P,¶U
°
./HŽ&    ;<>!E-F/G0H:I>K4$Z¥-t¦0”•@‘@§–
œ$Z¨-t©Ÿ
oH 
§¡ª
«¬
œ*»zY·|L=*¾¢+*2À}*`2¹W„§ÿå+°Ž?@A"@(C 
­®*¯°"j˜
œ
"jž
Ÿý
€
ú±
!
    /¸…³J±
Ž
²³‹
´µ
¶½¿ÂÃ

ÄÆÈ