o i@sddlZddlZddlZddlZddlZddlmZddlmZm Z e dZ ddZ ddZ d d Zd d Zd dZGdddeZdS)N)api) report_errorsreport_warningsz)(?P[0-9]*\.?[0-9]+)(?P[mhd])cCs|dpd}|ddp d}|ddpd}|d}tj|}|d}t|d|dd|d t|dd |dS) Ntitletexthandle date_happenedurl z ()z | )getdatetime fromtimestampprintstrip isoformat)eventrrrdatedtlinkrJ/home/ubuntu/.local/lib/python3.10/site-packages/datadog/dogshell/event.pyprettyprint_events  $rcC t|dSNrrrrr print_event  rcCrrrrrrrprettyprint_event_details$rr cCrrrrrrrprint_event_details(rr!cCsttj}|dur|}t|Sz t|}Wt|Stydt|}|dur/tt | d}| d}|dkrC|d}|dkrM|dd}|dkrY|ddd}|t|}Yt|Sw)Ndeltaunitm<hd) timemktimernow timetupleint Exceptiontime_patmatchfloatgroup) timestringr+tr0r"r#rrr parse_time,s,    r5c@s<eZdZeddZeddZeddZeddZd S) EventClientcCs|jddd}|jddd}d|_|jdd d}|jd d d|jd td d|jddd|jdddd|jddd|jddd|jdddd|jdddd|jd d!d|jd"d#d|jd$d%d|jd&d'd|jd(d)d*d+|j|jd,|jd-d.d}|jd/d0d|j|jd,|jd1d2d3d4}|jd5d6d|jd7d8d*d+|jdd9d|jd:d;d|jddevent to post as a child of. if unset, posts a top-level eventz--tagszcomma separated list of tagsz--hostz-related host (default to the local host name)rz --no_hostz8no host is associated with the event (overrides --host)) store_true)r7actionz--devicez%related device (e.g. eth0, /dev/sda1)z--aggregation_keyzkey to aggregate the event withz--typez)type of event, e.g. nagios, jenkins, etc.z --alert_typez;"error", "warning", "info" or "success". defaults to "info"messagez/event message body. if unset, reads from stdin.?)r7nargs)funcshowzShow event details.event_idz event to showstreamz%Retrieve events from the Event StreamzStream start and end times can be specified as either a POSIX timestamp (e.g. the output of `date +%s`) or as a period of time in the past (e.g. '5m', '6h', '3d').)r7 descriptionstartz!start date for the stream requestendz3end date for the stream request (defaults to 'now')z;filter by priority. 'normal' or 'low'. defaults to 'normal'z --sourcesz,comma separated list of sources to filter byz)comma separated list of tags to filter by) add_parseradd_subparsersrequired add_argumentr- set_defaults_post_show_stream)cls subparsersparser verb_parsers post_parser show_parser stream_parserrrr setup_parserDsPzEventClient.setup_parsercCs|jt_|j}|j}|durtj}|jdur$dd|j dD}nd}|j r+dn|j }tj j |j||j|j|j|j|||j|j|j|jd }t|t||dkr]t|ddS|dkrjtt|dSt|ddS) z Post an event. NcSg|]}|qSrr.0r4rrr z%EventClient._post..,) rrr rpriorityrelated_event_idtagshostdeviceaggregation_keysource_type_name alert_typeprettyrraw)timeoutr_timeoutformatrAsysstdinreadrdsplitno_hostreEventcreaterr rrbrcrfrgr<rirrrrjsondumpsr)rSargsrnrArdreresrrrrPts<  zEventClient._postcCsn|jt_|j}tj|j}t|t||dkr"t |ddS|dkr/t t |dSt |ddS)Nrjrrk)rlrrmrnrtr rFrrr rrvrwr!)rSrxrnryrrrrQszEventClient._showc Cs|jt_|j}|jdurdd|jdD}nd}|jdur+dd|jdD}nd}t|j}t|j }tj j |||j ||d}t |t||dkr_|dD] }t|tqSdS|dkrltt|dS|dD] }t|tqpdS) NcSr[rr\)r^srrrr_r`z'EventClient._stream..racSr[rr\r]rrrr_r`)rIrJrbsourcesrdrjeventsrk)rlrrmrnr{rrrdr5rIrJrtqueryrbrrrrrvrwr) rSrxrnr{rdrIrJryrrrrrRs0      zEventClient._streamN)__name__ __module__ __qualname__ classmethodrZrPrQrRrrrrr6Cs / *  r6)rr)rerorvdatadogrdatadog.dogshell.commonrrcompiler/rrr r!r5objectr6rrrrs