B `1@sddlmZmZmZeZddgddZdZdZdZ dd l m Z d d l m Z mZmZd d ZddZddZddZddZddZddZedkredS))absolute_importdivisionprint_functionz1.1ZstableinterfaceZ certified)metadata_versionstatusZ 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) argumentserrorsutilscCsd|j}|d}|r8|ddr8|ddkr8|jdd|ddkr`|d s`|d s`|jd ddS) Nproxy_requestssplayFsplay_coveragezBsplay is true but all of the following are missing: splay_coverage)msgstatepresentintervalcronz0one of the following is required: interval, cron)paramsget fail_json)modulerr rg/home/dcms/DCMS/lib/python3.7/site-packages/ansible_collections/sensu/sensu_go/plugins/modules/check.pyvalidate_module_paramss rcCs$t||pgt||pgkS)N)setr)currentdesiredkeyrrrdo_sets_differsrcCsDd|kr dS|dpi}|d}d|kr6t||dpBt||dS)Nr Fentity_attributes)rrr do_differ)rrrrrdo_proxy_requests_differ s r"cCsbd|kr dSt|dpg}tdd|D}t|d}tdd|D}||kS)N check_hooksFcss|]\}}|t|fVqdS)N)r).0kvrrr !sz(do_check_hooks_differ..css|]\}}|t|fVqdS)N)r)r$r%r&rrrr'$s)r Zsingle_item_dicts_to_dictrdictitems)rrrrrdo_check_hooks_differsr*c Csxt||dddddddd pvt||pvt||pvt||dpvt||dpvt||dpvt||pvt||dpvt||dS) Nr subscriptionshandlersruntime_assetsr#output_metric_handlersenv_varssecrets)r r!Zdo_secrets_differr"rr*)rrrrrr!)s        r!cCst|ddddddddd d d d d dddd}|drLt|dddd|d<|drft|d|d<|drt|d|d<|S)Ncommandrr,high_flap_thresholdrlow_flap_thresholdoutput_metric_formatr.proxy_entity_namepublish round_robinr-r0stdinr+timeoutttlr r r rr#r/)r Zget_mutation_payloadZget_spec_payloadr Zdict_to_single_item_dictsZdict_to_key_value_strings)rpayloadrrrbuild_api_payload;s8r<c Csddddgfg}dg}td||ttdddd d d d ttd ddtd ddtddttddtddtddtddtddtddtddtd ddtddttdttd ddtddtddddtddddgdtd ddtdddd}t|t|jd}t|jd d|jd}t |j}y2t |jd||||j t \}}|j ||dWn6tjk r}z|jt|dWdd}~XYnXdS) Nrrr+r1)rrTauthnamelabels annotations namespacer0liststr)typeelementsint)rDboolr()r r r)rDoptionsZnagios_perfdataZgraphite_plaintextZ influxdb_lineZ opentsdb_line)choices)r1r+r,rrr6r9r:r8r/r3r2r-r#r5r r4r.r7)Zsupports_check_mode required_ifmutually_exclusiveZ argument_specZchecks)changedobject)r)rr(r Zget_specrZget_sensu_clientrr Zbuild_core_v2_pathr<syncZ check_moder!Z exit_jsonr ErrorrrC) rJrKrclientpathr;rLcheckerrrmain`s   rT__main__N) __future__rrrrD __metaclass__ZANSIBLE_METADATAZ DOCUMENTATIONZEXAMPLESZRETURNZansible.module_utils.basicrZ module_utilsr r r rrr"r*r!r<rT__name__rrrrs& H   %`