Vh1ddlmZmZmZeZddgddZdZdZdZ dd l m Z d d l m Z mZmZd Zd ZdZdZdZdZdZedk(reyy))absolute_importdivisionprint_functionz1.1stableinterface certified)metadata_versionstatus supported_bya module: check author: - Paul Arthur (@flowerysong) - Aljaz Kosir (@aljazkosir) - Miha Plesko (@miha-plesko) - Tadej Borovsak (@tadeboro) short_description: Manage Sensu checks description: - Create, update or delete Sensu Go check. - For more information, refer to the Sensu Go documentation at U(https://docs.sensu.io/sensu-go/latest/reference/checks/). version_added: 1.0.0 extends_documentation_fragment: - sensu.sensu_go.requirements - sensu.sensu_go.auth - sensu.sensu_go.name - sensu.sensu_go.namespace - sensu.sensu_go.state - sensu.sensu_go.labels - sensu.sensu_go.annotations - sensu.sensu_go.secrets seealso: - module: sensu.sensu_go.check_info options: command: description: - Check command to run. - Required if I(state) is C(present). type: str subscriptions: description: - List of subscriptions which receive check requests. - Required if I(state) is C(present). type: list elements: str handlers: description: - List of handlers which receive check results. type: list elements: str interval: description: - Check request interval. - Cannot be used when I(cron) option is used. type: int cron: description: - Schedule check requests using crontab syntax. - Cannot be used when I(interval) option is used. type: str publish: description: - Enables or disables scheduled publication of check requests. type: bool timeout: description: - Check execution timeout. type: int ttl: description: - Amount of time after which a check result is considered stale. type: int stdin: description: - Enables writing of serialized JSON data to the check command's stdin. - Only usable with checks written specifically for Sensu Go. type: bool low_flap_threshold: description: - Low flap threshold. type: int high_flap_threshold: description: - High flap threshold. type: int runtime_assets: description: - List of runtime assets required to run the check. type: list elements: str check_hooks: description: - A mapping of response codes to hooks which will be run by the agent when that code is returned. - Note that the structure of this parameter is a bit different from the one described at U(https://docs.sensu.io/sensu-go/latest/reference/checks/#check-hooks-attribute). - See check hooks example below for more information on exact mapping structure. type: dict proxy_entity_name: description: - Entity name to associate this check with instead of the agent it ran on. type: str proxy_requests: description: - Allows you to assign the check to run for multiple entities according to their entity_attributes. type: dict suboptions: entity_attributes: description: - List of attribute checks for determining which proxy entities this check should be scheduled against. type: list elements: str splay: description: - Enables or disables splaying of check request scheduling. type: bool splay_coverage: description: - Percentage of the C(interval) over which to splay checks. type: int output_metric_format: description: - Enable parsing of metrics in the specified format from this check's output. type: str choices: - graphite_plaintext - influxdb_line - nagios_perfdata - opentsdb_line output_metric_handlers: description: - List of handlers which receive check results. I'm not sure why this exists. type: list elements: str round_robin: description: - An array of environment variables to use with command execution. type: bool env_vars: description: - A mapping of environment variable names and values to use with command execution. type: dict a_ - name: Check executing command every 30 seconds sensu.sensu_go.check: name: check command: check-cpu.sh -w 75 -c 90 subscriptions: - checks interval: 30 publish: yes - name: Check executing command with cron scheduler sensu.sensu_go.check: name: check command: check-cpu.sh -w 75 -c 90 subscriptions: - systems handlers: - slack cron: "* * * * *" publish: yes - name: Ad-hoc scheduling sensu.sensu_go.check: name: check command: check-cpu.sh -w 75 -c 90 subscriptions: - systems handlers: - slack interval: 60 publish: no - name: Report events under proxy entity name instead of agent entity sensu.sensu_go.check: name: check command: http_check.sh https://sensu.io subscriptions: - proxy handlers: - slack interval: 60 proxy_entity_name: sensu-site round_robin: yes publish: yes - name: Event that triggers hooks sensu.sensu_go.check: name: check command: http_check.sh https://sensu.io subscriptions: [ proxy ] # The upstream JSON payload for the hooks below would look like this: # # "check_hooks": [ # {"0": ["passing-hook", "always-run-this-hook"]}, # {"critical": ["failing-hook", "always-run-this-hook"]} # ] # # Ansible task simplifies this structure into a simple mapping: check_hooks: "0": - passing-hook - always-run-this-hook critical: - failing-hook - always-run-this-hook - name: Remove check sensu.sensu_go.check: name: my-check state: absent a object: description: Object representing Sensu check. returned: success type: dict sample: metadata: name: check_minimum namespace: default command: collect.sh handlers: - slack interval: 10 publish: true subscriptions: - system ) AnsibleModule) argumentserrorsutilsc|j}|d}|r5|jddr#|jd|jd|ddk(r|d s|d s|jd yyyy) Nproxy_requestssplayFsplay_coveragezBsplay is true but all of the following are missing: splay_coveragemsgstatepresentintervalcronz0one of the following is required: interval, cron)paramsget fail_json)modulerrs h/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/sensu/sensu_go/plugins/modules/check.pyvalidate_module_paramsrs ]]F,-N>--gu=   / 0 8ab g)#VJ-?6&>OPDR-?#c|t|j|xsgt|j|xsgk7SN)setr)currentdesiredkeys rdo_sets_differr's3 w{{3%2 &#gkk#.>.D"*E EEr cd|vry|jdxsi}|d}d|vxr t||dxstj||dS)NrFentity_attributes)rr'r do_differr$r%s rdo_proxy_requests_differr, sfw&kk*+1rG&'G 7 * B 7G-@ A ? *=> r cd|vrytj|jdxsg}td|j D}tj|d}td|j D}||k7S)N check_hooksFc3<K|]\}}|t|fywr"r#.0kvs r z(do_check_hooks_differ..!;41aAs1v;;c3<K|]\}}|t|fywr"r0r1s rr5z(do_check_hooks_differ..$r6r7)rsingle_item_dicts_to_dictrdictitemsr+s rdo_check_hooks_differr<swG#--gkk-.H.NBOG;7==?;;G--gm.DEG;7==?;;G g r c <tj||dddddddd xs}tj||xset||xsWt ||dxsHt ||dxs9t ||dxs*t ||xst ||dxs t ||dS) Nr subscriptionshandlersruntime_assetsr.output_metric_handlersenv_varssecrets)rr*do_secrets_differr,r'r<r+s rr*r*)s  W. m-E   5 1 5 !'2 5 w9 5 w4 5 w)9: 5 gw/ 5 w)AB 5 w4r ctj|ddddddddd d d d d dddd}|drtj|dddd|d<|drtj|d|d<|drtj |d|d<|S)Ncommandrr?high_flap_thresholdrlow_flap_thresholdoutput_metric_formatrAproxy_entity_namepublish round_robinr@rCstdinr>timeoutttlrr)rrr.rB)r get_mutation_payloadget_spec_payloadrdict_to_single_item_dictsdict_to_key_value_strings)rpayloads rbuild_api_payloadrU;s,,  %G*$-$>$> # $ *:%  ! m!&!@!@ AV!W  j#==fZ>PQ  Nr cddddgfg}dg}td||ttjdddd d d d fidtdtd ddtd ddtddtdtddtddtddtddtddtddtddtd ddtdd td!tdttd dtdtd"#d$tgd%&d'td dd(td)}t |tj |j d}tj|j d d*|j d}t|j } tj|j d||||jt\}}|j||+y#tj$r%}|j!t#|,Yd}~yd}~wwxYw)-Nrrr>rF)rrTauthnamelabels annotations namespacerCliststr)typeelementsr?rint)r^rrKboolrNrOrMrBr:rHrGr@r.rJr)r)rr)r^optionsrI)nagios_perfdatagraphite_plaintext influxdb_line opentsdb_line)choicesrArL)supports_check_mode required_ifmutually_exclusive argument_specchecks)changedobjectr)r r:r get_specrget_sensu_clientrrbuild_core_v2_pathrUsync check_moder* exit_jsonrErrorrr]) rirjrclientpathrTrmcheckes rmainrz`s )oy9:K//  -   =+ C F C e C eC C C !C &'C ,-C 23C 89C > $ ?C D!%!EC J eKC PQC V#fWC X &*#e'#$("$  YC t"&c"uC z$(e${C @AC HFR6"  ' ' f(= >F  # # k"HfmmF.C D  .G% MM' "FD'6;L;L   7 <<%SV$$%sA HI2II__main__N) __future__rrrr^ __metaclass__ANSIBLE_METADATA DOCUMENTATIONEXAMPLESRETURNansible.module_utils.basicr module_utilsr rrrr'r,r<r*rUrz__name__r rrsA@  ! I VF P $533 QF  $"J]%@ zFr