1

zhang

8 天以前 3cf258f4eff5e5c197a3026398281b2e63ccb002

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
Êþº¾4—
J    KLM
NO
NP
NQ
RS
RT
UV    WX
NYZ[    \]^
_`a    \bc
dLefghi
jk    lm
logger
Lorg/slf4j/Logger;
influxDBClient
$Lcom/influxdb/client/InfluxDBClient;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
)Lcom/zy/influxdb/service/InfluxDBService;
    writeData
3(Ljava/lang/String;Ljava/util/Map;Ljava/util/Map;)V

e
Ljava/lang/Exception;
measurement
Ljava/lang/String;
tags
Ljava/util/Map;
fields
writeApiBlocking
&Lcom/influxdb/client/WriteApiBlocking;
point
!Lcom/influxdb/client/write/Point;
LocalVariableTypeTable
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
 StackMapTableinopqa
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;
sql
D(Ljava/lang/String;)Ljava/util/List<Lcom/influxdb/query/FluxTable;>;
<clinit>

SourceFile
InfluxDBService.java
(Lorg/springframework/stereotype/Service;!"rstq,uvwxwyz{|}~€‚ƒ„…p†‡ˆ‰Š
Data written to the database.‹Œ
java/lang/ExceptionŽŠ
%Failed to write data to the database."‘’“C
'Failed to query data from the database.
'com/zy/influxdb/service/InfluxDBService”•–
java/lang/Object
java/lang/String
 java/util/Map
$com/influxdb/client/WriteApiBlocking
com/influxdb/client/write/Point
"com/influxdb/client/InfluxDBClient
getWriteApiBlocking
(()Lcom/influxdb/client/WriteApiBlocking;
5(Ljava/lang/String;)Lcom/influxdb/client/write/Point;
addTags
2(Ljava/util/Map;)Lcom/influxdb/client/write/Point;
    addFields
java/time/Instant
now
()Ljava/time/Instant;
toEpochMilli
()J
java/lang/Long
valueOf
(J)Ljava/lang/Long;
)com/influxdb/client/domain/WritePrecision
MS
+Lcom/influxdb/client/domain/WritePrecision;
time
^(Ljava/lang/Long;Lcom/influxdb/client/domain/WritePrecision;)Lcom/influxdb/client/write/Point;

writePoint
$(Lcom/influxdb/client/write/Point;)V
java/lang/System
out
Ljava/io/PrintStream;
java/io/PrintStream
println
(Ljava/lang/String;)V
err
printStackTrace
getQueryApi
 ()Lcom/influxdb/client/QueryApi;
com/influxdb/client/QueryApi
query
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!

 
!"
#/

*·
±$
%
&'
()#
'L*´¹
:+¸,¶-¶¸¶¸    ²
¶:¹² ¶§:²¶¶±
(9<$2()*+,(.1/94<1>2F3K5%H> *+L&'L,-
L./L0/A12($345L.6L078ÿ<9:;;<=
>? ,.0@A
BC#*´¹
+¹°M²¶,¶
°
$>?@AC% *+&'D-
8
P>?
D@EF"
#!
    ¸³±
$
GH
I