w~ojj 4 d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZm Z d dl
m Z d dl m
Z
mZ ddlmZ ddlmZmZ dd lmZ dd
lmZ dd lmZmZ ej6 e Z d Z d
ede e e!e f fdZ"d
ede e!e f fdZ#d
ede$e fdZ%d
ede!de&ddfdZ'y) N)BaseHTTPRequestHandlerThreadingHTTPServer)EventThread)Any)parse_qsurlparse )build_alert_summary)parse_agent_registrationparse_remote_event)_row)utc_now)Watcherbuild_collectoruPn
Worker-Überwachung · Agent Solutions
Zentrale Infrastruktur
Lade Daten …
Projekt-Worker
Lade Daten …
Automationen und Hintergrund-Worker
Lade Daten …
Weitere überwachte Aufgaben
Lade Daten …
Ausführungsorte und Remote-Agenten
Lade Daten …
Letzte Ereignisse
Lade Daten …
watcherreturnc ` g }| j j D ] }| j j d|j f j } t
|j j }|j |j |j |j t |j |d}|8|j |d |d t |d |d |d |d |d
d n|j d d d d d d d d |j! | |S # t $ r d}Y w xY w)
NzLSELECT * FROM collector_runs WHERE collector_name=? ORDER BY id DESC LIMIT 1unknown)nametypeenabledtimeout_secondsdefinitions_countversion
started_at finished_atsuccess
error_type
error_message jobs_seenobservations_created) last_run_atlast_finished_at last_successlast_error_typelast_error_messager! r" r )config
collectors
connectionexecuter fetchoner r r
ValueErrorr r len definitionsupdateboolappend)r rowsr( latestr items G/opt/struktur/hermes-workspace/worker-watcher/src/worker_watcher/api.pycollector_config_rowsr7 sG !#D..++ ##++ Z]c]h]h\j
(* %fkk2::G KKKK ~~ % 5 5!$V%7%7!8
KK %l 3$*=$9 $VI%6 7#),#7&,_&= #K 0(./E(F
KK$X\,0[\124
5
D= > K3 G s D D-,D-c b | j }| j j D cg c]
}t | }}| j j d D cg c]
}t | }}t
|||t | j j j S c c}w c c}w )Nz4SELECT * FROM status_events ORDER BY occurred_at ASC) health
repository status_rowsr r* r+ r r r( r cycle_interval_seconds)r r9 rowjobseventss r6
alert_summaryr@ s
^^
F!(!3!3!?!?!A B#DI BD B#*#5#5#=#=>t#u
vCd3i
vF
v vtVWY@V@V@m@m nn C
vs B' B,c * G fddt }|S )Nc e Zd ZdededdfdZdededdfdZded eddfd
Zde eef dz f fd Z
de f fd Z d fd
Z
d fd Zy) create_handler..Handlerformatargsr Nc y )N )selfrD rE s r6 log_messagez+create_handler..Handler.log_message s statuspayloadc > t j |dt j d }| j | | j dd | j dt t
| | j | j j | y )NF) ensure_asciidefaultutf-8 Content-Typez application/json; charset=utf-8Content-Length)
jsondumpsstrencode
send_response send_headerr. end_headerswfilewrite)rH rK rL bodys r6 send_jsonz)create_handler..Handler.send_json su ::gE3GNNwWD v & ^-N O -s3t9~ > JJ T "rJ r\ c
|j d }| j | | j dd | j dt t | | j | j j | y )NrP rQ ztext/html; charset=utf-8rR )rV rW rX rU r. rY rZ r[ )rH rK r\ encodeds r6 send_htmlz)create_handler..Handler.send_html sg kk'*G v & ^-G H -s3w.Handler.read_json s
T\\ - -.> DEQ;&7>>+A+A+X+X"X **TZZ__V%<=",Wd";wEE 4 45
s A
B ?B B B/.B/c t j j j j j
}|sy| j j dd }t j |d| S )NT
Authorization zBearer ) osenvironre r( r agent_auth_token_envrd secretscompare_digest)rH expectedprovidedr s r6 authorized_agent_requestz8create_handler..Handler.authorized_agent_request s[ zz~~gnn&<&<&Q&QRH||''z9create_handler..Handler.do_GET.. s lScRXk]kNkS ls
r zcollector not foundz/api/v1/remote-eventsz
/api/v1/jobs/zinstance not foundz4SELECT * FROM job_status_current WHERE instance_id=?z/api/v1/events2 not found) r pathrstripr` WATCHER_HTMLr] r* r+ r, r Exceptionr __name__r9 r@ r queryr: r; re r worker_rows
agent_rowsr7 rc collector_rows
startswithrsplitnextremote_event_rowsr- r? )
rH parsedr excr r3 rK r= r r5 instance_idr r s
@r6 do_GETz&create_handler..Handler.do_GET s dii(F;;%%c*1cDs{sL1 'sXv$67 (^&&..z:CCENN37gNdNd(ef "d.>&>sGNN$4511sM'$:; ' . ))557 8dV4Q7+/xC33G63QUXYlUmqwUwCxDxsWD.IStCy.I$JK**sWGDVDVDbDbDd.eStCy.e$fg))sWGDVDVDaDaDc.dStCy.d$ef--sW.CG.L$MN22HV\\ 2 6 6w Fq IJsWGDVDVDeDefkDl.mStCy.m$no !67!%S!!4Q!7 l,A',J lnrs<NN32G(HINN3-00HV\\ 2 6 6w Fq IJsWGDVDVDhDhinDo.pStCy.p$qr 1"%dkk#q&9!&<"=K ((001gjuiwx B B D^asDI7DX:YZgkguguvy }D FZ |[ h\))HV\\ 2 6 6w Ea HIsWGDVDVD]D]^cDd.eStCy.e$fgsWk$:;Y ! ^NN3;cI[I[(\]]^ y.I.e.d
/n /q " NN32F(GH /fs[ 3AS T .T T# T( T- 6T2 T7
T< 0U T)(TT< U U c t | j j j d xs d}|dvr| j dddi y | j s| j dddi y j
j j s| j dddi y | j }|| j d dd
i y |j d r=t | }j | }| j d d
||j d y t | }| j dj | y # t t t" f$ r'}| j ddt% | i Y d }~y d }~ww xY w)Nr{ > /api/v1/agents/events/api/v1/agents/registerr r r i z agent authentication requiredzremote ingest disabledi z+JSON object required and limited to 512 KiBz /register T)acceptedagent_id agent_keyr| i )r r r r] ry r( r remote_ingest_enabledrn endswithr register_remote_agentr r
ingest_remote_eventKeyError TypeErrorr- rU )rH r rL registrationr eventr r s r6 do_POSTz'create_handler..Handler.do_POST sV DII&++2237>3DOOsWk$:;002sW.M$NO>>))??sW.F$GHnn&GsW.[$\]
9==-#;G#DL & < <\ JHNN3Tx^j^t^t(uv .w 7ENN3(C(CE(JK i4
9sWc#h$788
9s A
E
,E
F F Fr N)r
__module__ __qualname__rU r rI rc r] r` rk rn r1 ry r r )r s r6 HandlerrC s c # $ #C ## #$ # &C &s &t & tCH~ 4 Jd J7 .scan_loop) sf ++-
9 "
IIgnn,,CC D ++-
9 !78
9s A% % BBz
watcher-cycleT)targetr daemon )timeoutr ) r r startr r
serve_foreversetjoin server_close)r r r r scan_threadserverr s ` @r6 server & s 7DE MK
$ ~g/F
GF
#
# s
B
4C)(rS loggingrr ru http.serverr r threadingr r typingr urllib.parser r alertsr remoter r
reportsr timeutilr r r r getLoggerr r r listrk rU r7 r@ r r rc r rG rJ r6 r s C # + ' @ - 8 $i X !7 !tDcN/C !Ho7 otCH~ oyG y-C(D yx 7 # S T rJ