Vh^ddlmZmZmZeZdZdZdZddl m Z ddl m Z ddl mZddlmcmcmcmcmZGd d e ZGd d eZGd deZGddeZGddeZGddeZdZedk(reyy))absolute_importdivisionprint_functiona&k --- module: zabbix_action short_description: Create/Delete/Update Zabbix actions description: - This module allows you to create, modify and delete Zabbix actions. author: - Ruben Tsirunyan (@rubentsirunyan) - Ruben Harutyunov (@K-DOT) requirements: - "python >= 3.9" options: name: type: str description: - Name of the action required: true event_source: type: str description: - Type of events that the action will handle. - Required when C(state=present). required: false choices: ["trigger", "discovery", "auto_registration", "internal"] state: type: str description: - State of the action. - On C(present), it will create an action if it does not exist or update the action if the associated data is different. - On C(absent), it will remove the action if it exists. choices: ["present", "absent"] default: "present" status: type: str description: - Status of the action. choices: ["enabled", "disabled"] default: "enabled" pause_in_maintenance: description: - Whether to pause escalation during maintenance periods or not. - Can be used when I(event_source=trigger). type: "bool" default: true notify_if_canceled: description: - Weather to notify when escalation is canceled. - Can be used when I(event_source=trigger). type: "bool" default: true esc_period: type: str description: - Default operation step duration. Must be greater than 60 seconds. - Accepts seconds, time unit with suffix and user macro since => Zabbix 3.4 - Required when C(state=present). required: false conditions: type: list elements: dict description: - List of conditions to use for filtering results. - For more information about suboptions of this option please check out Zabbix API documentation U(https://www.zabbix.com/documentation/5.0/manual/api/reference/action/object#action_filter_condition) default: [] suboptions: type: type: str description: - Type (label) of the condition. - "Possible values when I(event_source=trigger):" - " - C(host_group)" - " - C(host)" - " - C(trigger)" - " - C(trigger_name)" - " - C(trigger_severity)" - " - C(time_period)" - " - C(host_template)" - " - C(maintenance_status) known in Zabbix 4.0 and above as 'Problem is suppressed'" - " - C(event_tag)" - " - C(event_tag_value)" - "Possible values when I(event_source=discovery):" - " - C(host_IP)" - " - C(discovered_service_type)" - " - C(discovered_service_port)" - " - C(discovery_status)" - " - C(uptime_or_downtime_duration)" - " - C(received_value)" - " - C(discovery_rule)" - " - C(discovery_check)" - " - C(proxy)" - " - C(discovery_object)" - "Possible values when I(event_source=auto_registration):" - " - C(proxy)" - " - C(host_name)" - " - C(host_metadata)" - "Possible values when I(event_source=internal):" - " - C(host_group)" - " - C(host)" - " - C(host_template)" - " - C(event_type)" required: true value: type: str description: - Value to compare with. - "When I(type=discovery_status), the choices are:" - " - C(up)" - " - C(down)" - " - C(discovered)" - " - C(lost)" - "When I(type=discovery_object), the choices are:" - " - C(host)" - " - C(service)" - "When I(type=event_type), the choices are:" - " - C(item in not supported state)" - " - C(item in normal state)" - " - C(LLD rule in not supported state)" - " - C(LLD rule in normal state)" - " - C(trigger in unknown state)" - " - C(trigger in normal state)" - "When I(type=trigger_severity), the choices are (case-insensitive):" - " - C(not classified)" - " - C(information)" - " - C(warning)" - " - C(average)" - " - C(high)" - " - C(disaster)" - Irrespective of user-visible names being changed in Zabbix. Defaults to C(not classified) if omitted. - Besides the above options, this is usually either the name of the object or a string to compare with. value2: type: str description: - Secondary value to compare with. - Required for trigger actions when condition I(type=event_tag_value). operator: type: str description: - Condition operator. - When I(type) is set to C(time_period), the choices are C(in), C(not in). choices: - "equals" - "=" - "does not equal" - "<>" - "contains" - "like" - "does not contain" - "not like" - "in" - "is greater than or equals" - ">=" - "is less than or equals" - "<=" - "not in" - "matches" - "does not match" - "Yes" - "No" required: true formulaid: type: str description: - Arbitrary unique ID that is used to reference the condition from a custom expression. - Can only contain upper-case letters. - Required for custom expression filters and ignored otherwise. eval_type: type: str description: - Filter condition evaluation method. - Defaults to C(andor) if conditions are less then 2 or if I(formula) is not specified. - Defaults to C(custom_expression) when formula is specified. choices: - "andor" - "and" - "or" - "custom_expression" formula: type: str description: - User-defined expression to be used for evaluating conditions with a custom expression. - The expression must contain IDs that reference each condition by its formulaid. - The IDs used in the expression must exactly match the ones defined in the I(conditions). No condition can remain unused or omitted. - Required when I(eval_type=custom_expression). - Use sequential IDs that start at "A". If non-sequential IDs are used, Zabbix re-indexes them. This makes each module run notice the difference in IDs and update the action. operations: type: list elements: dict description: - List of action operations default: [] suboptions: type: type: str description: - Type of operation. - "Valid choices when setting type for I(recovery_operations) and I(acknowledge_operations):" - " - C(send_message)" - " - C(remote_command)" - " - C(notify_all_involved)" - Choice C(notify_all_involved) only supported in I(recovery_operations) and I(acknowledge_operations). - C(add_host_tags) and C(remove_host_tags) available since Zabbix 7.0. choices: - send_message - remote_command - add_host - remove_host - add_to_host_group - remove_from_host_group - link_to_template - unlink_from_template - enable_host - disable_host - set_host_inventory_mode - notify_all_involved - add_host_tags - remove_host_tags required: true esc_period: type: str description: - Duration of an escalation step in seconds. - Must be greater than 60 seconds. - Accepts seconds, time unit with suffix and user macro. - If set to 0 or 0s, the default action escalation period will be used. default: 0s esc_step_from: type: int description: - Step to start escalation from. default: 1 esc_step_to: type: int description: - Step to end escalation at. - Specify 0 for infinitely. default: 1 send_to_groups: type: list elements: str description: - User groups to send messages to. send_to_users: type: list elements: str description: - Users (usernames or aliases) to send messages to. op_message: type: str description: - Operation message text. - If I(op_message) and I(subject) not defined then "default message" from media type will be used subject: type: str description: - Operation message subject. - If I(op_message) and I(subject) not defined then "default message" from media type will be used media_type: type: str description: - Media type that will be used to send the message. - Can be used with I(type=send_message) or I(type=notify_all_involved) inside I(acknowledge_operations). - Set to C(all) for all media types default: "all" operation_condition: type: "str" description: - The action operation condition object defines a condition that must be met to perform the current operation. choices: - acknowledged - not_acknowledged host_groups: type: list elements: str description: - List of host groups host should be added to. - Required when I(type=add_to_host_group) or I(type=remove_from_host_group). templates: type: list elements: str description: - List of templates host should be linked to. - Required when I(type=link_to_template) or I(type=unlink_from_template). inventory: type: str description: - Host inventory mode. - Required when I(type=set_host_inventory_mode). choices: - manual - automatic command_type: type: str description: - Type of operation command. - Required when I(type=remote_command). choices: - custom_script - ipmi - ssh - telnet - global_script command: type: str description: - Command to run. - Required when I(type=remote_command) and I(command_type!=global_script). execute_on: type: str description: - Target on which the custom script operation command will be executed. - Required when I(type=remote_command) and I(command_type=custom_script). choices: - agent - server - proxy run_on_groups: type: list elements: str description: - Host groups to run remote commands on. - Required when I(type=remote_command) and I(run_on_hosts) is not set. run_on_hosts: type: list elements: str description: - Hosts to run remote commands on. - Required when I(type=remote_command) and I(run_on_groups) is not set. - If set to 0 the command will be run on the current host. ssh_auth_type: type: str description: - Authentication method used for SSH commands. - Required when I(type=remote_command) and I(command_type=ssh). choices: - password - public_key ssh_privatekey_file: type: str description: - Name of the private key file used for SSH commands with public key authentication. - Required when I(ssh_auth_type=public_key). - Can be used when I(type=remote_command). ssh_publickey_file: type: str description: - Name of the public key file used for SSH commands with public key authentication. - Required when I(ssh_auth_type=public_key). - Can be used when I(type=remote_command). username: type: str description: - User name used for authentication. - Required when I(ssh_auth_type in [public_key, password]) or I(command_type=telnet). - Can be used when I(type=remote_command). password: type: str description: - Password used for authentication. - Required when I(ssh_auth_type=password) or I(command_type=telnet). - Can be used when I(type=remote_command). port: type: int description: - Port number used for authentication. - Can be used when I(command_type in [ssh, telnet]) and I(type=remote_command). script_name: type: str description: - The name of script used for global script commands. - Required when I(command_type=global_script). - Can be used when I(type=remote_command). tags: type: list elements: dict description: - Host tags to adt have tag property defined. - The value property is optional. or remove. - upported if operationtype is set to C(add host tags) or C(remove host tags). suboptions: tag: type: str description: Tag name value: type: str description: Tag value (optional) recovery_operations: type: list elements: dict description: - List of recovery operations. - C(Suboptions) are the same as for I(operations). default: [] suboptions: type: type: str description: - Type of operation. choices: - send_message - remote_command - notify_all_involved required: true command_type: type: str required: false description: - Type of operation command. choices: - custom_script - ipmi - ssh - telnet - global_script command: type: str required: false description: - Command to run. execute_on: type: str required: false description: - Target on which the custom script operation command will be executed. choices: - agent - server - proxy ssh_auth_type: type: str description: - Authentication method used for SSH commands. - Required when I(type=remote_command) and I(command_type=ssh). choices: - password - public_key ssh_privatekey_file: type: str description: - Name of the private key file used for SSH commands with public key authentication. - Required when I(ssh_auth_type=public_key). - Can be used when I(type=remote_command). ssh_publickey_file: type: str description: - Name of the public key file used for SSH commands with public key authentication. - Required when I(ssh_auth_type=public_key). - Can be used when I(type=remote_command). run_on_groups: type: list elements: str description: - Host groups to run remote commands on. - Required when I(type=remote_command) and I(run_on_hosts) is not set. run_on_hosts: type: list elements: str description: - Hosts to run remote commands on. - Required when I(type=remote_command) and I(run_on_groups) is not set. - If set to 0 the command will be run on the current host. send_to_groups: type: list elements: str description: - User groups to send messages to. send_to_users: type: list elements: str description: - Users (usernames or aliases) to send messages to. media_type: type: str description: - Media type that will be used to send the message. - Can be used with I(type=send_message) or I(type=notify_all_involved) inside I(acknowledge_operations). - Set to C(all) for all media types default: "all" op_message: type: str description: - Operation message text. - If I(op_message) and I(subject) not defined then "default message" from media type will be used subject: type: str description: - Operation message subject. - If I(op_message) and I(subject) not defined then "default message" from media type will be used username: type: str description: - User name used for authentication. - Required when I(ssh_auth_type in [public_key, password]) or I(command_type=telnet). - Can be used when I(type=remote_command). password: type: str description: - Password used for authentication. - Required when I(ssh_auth_type=password) or I(command_type=telnet). - Can be used when I(type=remote_command). port: type: int description: - Port number used for authentication. - Can be used when I(command_type in [ssh, telnet]) and I(type=remote_command). script_name: type: str description: - The name of script used for global script commands. - Required when I(command_type=global_script). - Can be used when I(type=remote_command). acknowledge_operations: type: list elements: dict description: - List of acknowledge operations. - Action acknowledge operations are known as update operations since Zabbix 4.0. - C(Suboptions) are the same as for I(operations). suboptions: type: type: str description: - Type of operation. choices: - send_message - remote_command - notify_all_involved required: true command_type: type: str description: - Type of operation command. required: false choices: - custom_script - ipmi - ssh - telnet - global_script execute_on: type: str required: false description: - Target on which the custom script operation command will be executed. choices: - agent - server - proxy command: type: str required: false description: - Command to run. ssh_auth_type: type: str description: - Authentication method used for SSH commands. - Required when I(type=remote_command) and I(command_type=ssh). choices: - password - public_key ssh_privatekey_file: type: str description: - Name of the private key file used for SSH commands with public key authentication. - Required when I(ssh_auth_type=public_key). - Can be used when I(type=remote_command). ssh_publickey_file: type: str description: - Name of the public key file used for SSH commands with public key authentication. - Required when I(ssh_auth_type=public_key). - Can be used when I(type=remote_command). run_on_groups: type: list elements: str description: - Host groups to run remote commands on. - Required when I(type=remote_command) and I(run_on_hosts) is not set. run_on_hosts: type: list elements: str description: - Hosts to run remote commands on. - Required when I(type=remote_command) and I(run_on_groups) is not set. - If set to 0 the command will be run on the current host. send_to_groups: type: list elements: str description: - User groups to send messages to. send_to_users: type: list elements: str description: - Users (usernames or aliases) to send messages to. media_type: type: str description: - Media type that will be used to send the message. - Can be used with I(type=send_message) or I(type=notify_all_involved) inside I(acknowledge_operations). - Set to C(all) for all media types default: "all" op_message: type: str description: - Operation message text. - If I(op_message) and I(subject) not defined then "default message" from media type will be used subject: type: str description: - Operation message subject. - If I(op_message) and I(subject) not defined then "default message" from media type will be used username: type: str description: - User name used for authentication. - Required when I(ssh_auth_type in [public_key, password]) or I(command_type=telnet). - Can be used when I(type=remote_command). password: type: str description: - Password used for authentication. - Required when I(ssh_auth_type=password) or I(command_type=telnet). - Can be used when I(type=remote_command). port: type: int description: - Port number used for authentication. - Can be used when I(command_type in [ssh, telnet]) and I(type=remote_command). script_name: type: str description: - The name of script used for global script commands. - Required when I(command_type=global_script). - Can be used when I(type=remote_command). aliases: [ update_operations ] default: [] pause_symptoms: type: bool description: - Whether to pause escalation if event is a symptom event. - I(supported) if C(event_source) is set to C(trigger) - Works only with >= Zabbix 6.4 default: true extends_documentation_fragment: - community.zabbix.zabbix a # If you want to use Username and Password to be authenticated by Zabbix Server - name: Set credentials to access Zabbix Server API ansible.builtin.set_fact: ansible_user: Admin ansible_httpapi_pass: zabbix # If you want to use API token to be authenticated by Zabbix Server # https://www.zabbix.com/documentation/current/en/manual/web_interface/frontend_sections/administration/general#api-tokens - name: Set API token ansible.builtin.set_fact: ansible_zabbix_auth_key: 8ec0d52432c15c91fcafe9888500cf9a607f44091ab554dbee860f6b44fac895 # Trigger action with only one condition - name: Deploy trigger action # set task level variables as we change ansible_connection plugin here vars: ansible_network_os: community.zabbix.zabbix ansible_connection: httpapi ansible_httpapi_port: 443 ansible_httpapi_use_ssl: true ansible_httpapi_validate_certs: false ansible_zabbix_url_path: "zabbixeu" # If Zabbix WebUI runs on non-default (zabbix) path ,e.g. http:///zabbixeu ansible_host: zabbix-example-fqdn.org community.zabbix.zabbix_action: name: "Send alerts to Admin" event_source: "trigger" state: present status: enabled esc_period: 60 conditions: - type: "trigger_severity" operator: ">=" value: "Information" operations: - type: send_message subject: "Something bad is happening" op_message: "Come on, guys do something" media_type: "Email" send_to_users: - "Admin" # Trigger action with multiple conditions and operations - name: Deploy trigger action # set task level variables as we change ansible_connection plugin here vars: ansible_network_os: community.zabbix.zabbix ansible_connection: httpapi ansible_httpapi_port: 443 ansible_httpapi_use_ssl: true ansible_httpapi_validate_certs: false ansible_zabbix_url_path: "zabbixeu" # If Zabbix WebUI runs on non-default (zabbix) path ,e.g. http:///zabbixeu ansible_host: zabbix-example-fqdn.org community.zabbix.zabbix_action: name: "Send alerts to Admin" event_source: "trigger" state: present status: enabled esc_period: 1m conditions: - type: "trigger_name" operator: "like" value: "Zabbix agent is unreachable" formulaid: A - type: "trigger_severity" operator: ">=" value: "disaster" formulaid: B formula: A or B operations: - type: send_message media_type: "Email" send_to_users: - "Admin" - type: remote_command command: "systemctl restart zabbix-agent" command_type: custom_script execute_on: server run_on_hosts: - 0 # Trigger action with recovery and acknowledge operations - name: Deploy trigger action # set task level variables as we change ansible_connection plugin here vars: ansible_network_os: community.zabbix.zabbix ansible_connection: httpapi ansible_httpapi_port: 443 ansible_httpapi_use_ssl: true ansible_httpapi_validate_certs: false ansible_zabbix_url_path: "zabbixeu" # If Zabbix WebUI runs on non-default (zabbix) path ,e.g. http:///zabbixeu ansible_host: zabbix-example-fqdn.org community.zabbix.zabbix_action: name: "Send alerts to Admin" event_source: "trigger" state: present status: enabled esc_period: 1h conditions: - type: "trigger_severity" operator: ">=" value: "Information" operations: - type: send_message subject: "Something bad is happening" op_message: "Come on, guys do something" media_type: "Email" send_to_users: - "Admin" recovery_operations: - type: send_message subject: "Host is down" op_message: "Come on, guys do something" media_type: "Email" send_to_users: - "Admin" acknowledge_operations: - type: send_message media_type: "Email" send_to_users: - "Admin" z msg: description: The result of the operation returned: success type: str sample: "Action Deleted: Register webservers, ID: 0001" ) AnsibleModule) ZabbixBase) LooseVersionNcneZdZdfd ZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZxZS)Zapic<tt| ||||_yN)superr __init__ _zapi_wrapperselfmodulezbx __class__s r/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/zabbix/plugins/modules/zabbix_action.pyrz Zapi.__init__.s dD"63/!c ddddd|gid}|jjj|}|S#t$r,}|jj d|d|Yd}~yd}~wwxYw)zCheck if action exists. Args: name: Name of the action. Returns: The return value. True for success, False otherwise. extendname)selectOperationsselectRecoveryOperationsselectUpdateOperations selectFilterfilterzFailed to check if action 'z ' exists: msgN)_zapiactionget Exception_module fail_json)rr_params_actiones rcheck_if_action_existszZapi.check_if_action_exists2sw `$,,4*2 (!D6* Gjj''++G4GN ` LL " "VZ\]'^ " _ _ `s14 A)"A$$A)c0 |jjjdd|gid}t|dkr |jj d|zy |dS#t $r,}|jj d|d |Yd }~y d }~wwxYw) zGet action by name Args: name: Name of the action. Returns: dict: Zabbix action rroutputrzAction not found: %srrzFailed to get ID of '': N)r!r"r#lenr%r&r$)rr action_listr)s rget_action_by_namezZapi.get_action_by_nameIs S**++//"!D6*1K;!# &&+AD+H&I"1~% S LL " "q'Q " R R SAA A B)"BBc2 |jjjddd|gid}t|dkr |jj d|zy |dS#t $r,}|jj d|d |Yd }~y d }~wwxYw) zGet host by host name Args: host_name: host name. Returns: host matching host name rhost)r-selectInventoryrr.zHost not found: %srrzFailed to get host 'r/N)r!r5r#r0r%r&r$)r host_name host_listr)s rget_host_by_host_namezZapi.get_host_by_host_name_s W ++"#+!I;/-I 9~! &&+?)+K&L |# W LL " " ST'U " V V WsAA!A!! B*"BBc0 |jjjdd|gid}t|dkr |jj d|zy |dS#t $r,}|jj d|d |Yd }~y d }~wwxYw) zGet host group by host group name Args: hostgroup_name: host group name. Returns: host group matching host group name rrr,r.zHost group not found: %srrzFailed to get host group 'r/N)r! hostgroupr#r0r%r&r$)rhostgroup_namehostgroup_listr)s rget_hostgroup_by_hostgroup_namez$Zapi.get_hostgroup_by_hostgroup_namev b!ZZ1155"!N#347N>"Q& &&+E+V&W%a(( b LL " "n^_'` " a a br3c0 |jjjdd|gid}t|dkr |jj d|zy |dS#t $r,}|jj d|d |Yd }~y d }~wwxYw) zGet template by template name Args: template_name: template name. Returns: template matching template name rr5r,r.zTemplate not found: %srrzFailed to get template 'r/N)r!templater#r0r%r&r$)r template_name template_listr)s rget_template_by_template_namez"Zapi.get_template_by_template_names _ JJ//33"!M?35M=!A% &&+Cm+S&T$Q'' _ LL " "M[\'] " ^ ^ _r3c0 |jjjdd|gid}t|dkr |jj d|zy |dS#t $r,}|jj d|d |Yd }~y d }~wwxYw) zGet trigger by trigger name Args: trigger_name: trigger name. Returns: trigger matching trigger name r descriptionr,r.zTrigger not found: %srrzFailed to get trigger 'r/N)r!triggerr#r0r%r&r$)r trigger_name trigger_listr)s rget_trigger_by_trigger_namez Zapi.get_trigger_by_trigger_names ]::--11"(<.93L< 1$ &&+B\+Q&R#A& ] LL " "I!M  " LL " "'FI]'] " ^ m LL " "Sgij'k " l l ms6DE"E"-E"1 E"=E" E"" F+"FFc t|jtdk\rd|gi}nd|gi}|jjj d|d}t |dkr |j jd|zy |d S#t$r,}|j jd |d |Yd }~y d }~wwxYw) zGet proxy by proxy name Args: proxy_name: proxy name. Returns: proxy matching proxy name 7.0rr5rr,r.zProxy not found: %srrzFailed to get proxy 'r/N) r_zbx_api_versionr!proxyr#r0r%r&r$)r proxy_namer proxy_listr)s rget_proxy_by_proxy_namezZapi.get_proxy_by_proxy_names YD112l56II :,/ :,/))--" /J:" &&+@:+M&N!!}$ Y LL " "UV'W " X X YsBB B B>"B99B>ctd|gi} t|jdk(ry|jjj d|d}t |dkr |j jd|zy |d d S#t$r,}|j jd |d |Yd }~y d }~wwxYw)zGet mediatype by mediatype name Args: mediatype_name: mediatype name Returns: mediatype matching mediatype name rallrRrr,r.zMedia type not found: %srr mediatypeidzFailed to get mediatype 'r/N) strlowerr! mediatyper#r0r%r&r$)rmediatype_namermediatype_listr)s rget_mediatype_by_mediatype_namez$Zapi.get_mediatype_by_mediatype_name"s>*+ a>"((*e3!ZZ1155" 7N>"Q& &&+E+V&W%a(77 a LL " "^]^'_ " ` ` as#BAB:B B7 "B22B7c4 d|gi}|jjjd|d}t|dkr |jj d|zy |dS#t $r,}|jj d|d |Yd }~y d }~wwxYw) zGet user by user name Args: user_name: user name Returns: user matching user name usernamerr,r.zUser not found: %srrzFailed to get user 'r/N)r!userr#r0r%r&r$)r user_namer user_listr)s rget_user_by_user_namezZapi.get_user_by_user_name<s W 9+.F ++" -I9~! &&+?)+K&L |# W LL " " ST'U " V V WsAA"A"" B+"BBc0 |jjjdd|gid}t|dkr |jj d|zy |dS#t $r,}|jj d|d |Yd }~y d }~wwxYw) zGet usergroup by usergroup name Args: usergroup_name: usergroup name Returns: usergroup matching usergroup name rrr,r.zUser group not found: %srrzFailed to get user group 'r/N)r! usergroupr#r0r%r&r$)rusergroup_nameusergroup_listr)s rget_usergroup_by_usergroup_namez$Zapi.get_usergroup_by_usergroup_nameSr?r3c8 |iS|jjjdd|gid}t|dkr |jj d|zy|dS#t $r,}|jj d |d |Yd}~yd}~wwxYw) zGet script by script name Args: script_name: script name Returns: script matching script name Nrrr,r.zScript not found: %srrzFailed to get script 'r/)r!scriptr#r0r%r&r$)r script_name script_listr)s rget_script_by_script_namezZapi.get_script_by_script_namejs [" **++//"!K=11K;!# &&+AK+O&P"1~% [ LL " "+WX'Y " Z Z [s#A$AA$A$$ B-"BBr )__name__ __module__ __qualname__rr*r2r9r>rDrJrOr}rrrrr __classcell__rs@rr r -sW"`.S,W.b,_,],k,8mtY4a4W.b.[rr c>eZdZdfd ZdZdZdZdZdZxZ S)Actionc<tt| ||d|_yr )r rr existing_datars rrzAction.__init__s fd$VS1!rc |dtjgd|d|jd|d|d|jd|jdtjd d g|d d }|dd k(rE|drdnd|d<t|jtdk\r |drdnd|d<|drdnd|d<|jd|d<d|vr8t |jddt ds|jddnMt |jddtr|jdg|d<ng|d<|jddd|vr6t |jddt dr|jdd|vrTt |jddt dst|jdgdk(r|jdd|vrTt |jddt dst|jdgdk(r|jd|ddvr|jd|S)zConstruct parameters. Args: **kwargs: Arbitrary keyword parameters. Returns: dict: dictionary of specified parameters rrG discoveryauto_registrationinternal event_source esc_period conditions operationsrecovery_operationsacknowledge_operationsenableddisabledstatus)r eventsourcerrrrrrrGpause_in_maintenancerTrRpause_suppressed6.4pause_symptomsnotify_if_canceledupdate_operationsNrr)r) zabbix_utilshelper_to_numeric_valuer#rr isinstancertpoplistr0)rkwargsr's r_construct_parameterszAction._construct_parameterssr6N'??A$N3 5 !**\2\* .#)::.C#D&,jj1I&J"::<#H-/ " . !Y .178N1O#UXG& 'D112l56II39:J3KCQT()39:N3OCUXG( )'-zz2E'F#$ ' )*W[[I\^b=ceijneo2p KK0$ 7  $K{+A. . a LL " "VTZ^]^'_ " ` ` asA1A44 B,=%B''B,c& |jjr|jjdd|jjj |gS#t $r,}|jjd|d|Yd}~yd}~wwxYw)z|Delete action. Args: action_id: Action id Returns: action: deleted action z7Action would be deleted if check mode was not specifiedTrzFailed to delete action 'r/rN)r%rrr!r"deleter$r&)rrr)s r delete_actionzAction.delete_actions{ \||&& &&+dnr&s::$$++YK8 8 \ LL " "YXY'Z " [ [ \sAA B$"B  Br ) rrrrrrrrrrrs@rrrs%"8t e"a$\rrcTeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zy ) Operationsc tjgd|dS#t$r%|jj d|dzYywxYw)zConstruct operation type. Args: operation: operation to construct Returns: str: constructed operation ) send_messageremote_commandadd_host remove_hostadd_to_host_groupremove_from_host_grouplink_to_templateunlink_from_template enable_host disable_hostset_host_inventory_modenoner add_host_tagsremove_host_tagsrtz*Unsupported value '%s' for operation type.rNrrr$r%r&r operations r_construct_operationtypez#Operations._construct_operationtypes_ i779$ &!! $ i LL " "'SV_`fVg'g " h i+A  A cv |jd|jddnd|jd*|jj|jdnd|jd|jddS#t$r)}|jj d|z Yd}~yd}~wwxYw) zConstruct operation message. Args: operation: operation to construct the message Returns: dict: constructed operation message op_messageNsubjectrRrT media_type) default_msgrmessagerz8Failed to construct operation message. The error was: %sr)r#rrr$r%r&)rrr)s r_construct_opmessagezOperations._construct_opmessage%s g&/mmL&A&MQZQ^Q^_hQiQus{~]]<0< $11QQMM,/ BE$==6$==3   g LL " "'ade'e " f f gsBB B8B33B8c|jdy|jdDcgc]"}d|jj|di$c}Scc}w)zConstruct operation message user. Args: operation: operation to construct the message user Returns: list: constructed operation message user or None if operation not found send_to_usersNuserid)r#rr)rr_users r_construct_opmessage_usrz#Operations._construct_opmessage_usr:s^ == ) 1!}}_57 d((>>uEhO 7 77'Ac|jdy|jdDcgc]"}d|jj|di$c}Scc}w)zConstruct operation message group. Args: operation: operation to construct the message group Returns: list: constructed operation message group or None if operation not found send_to_groupsNusrgrpid)r#rrrr_groups r_construct_opmessage_grpz#Operations._construct_opmessage_grpIsa ==) * 2" &679 **JJ6RS]^ 9 99rc d|jj|jdjdi}|S#t$r)}|jj d|zYd}~yd}~wwxYw)zConstruct operation command. Args: operation: operation to construct command Returns: list: constructed operation command scriptidrz8Failed to construct operation command. The error was: %srN)rrr#r$r%r&)rr opcommandr)s r_construct_opcommandzOperations._construct_opcommandXss gD..HHMM-0#j/I   g LL " "'ade'e " f f gs>uEhO %-sO4` ``s9A"c|jdy|jdDcgc]"}d|jj|di$c}Scc}w)zConstruct operation command group. Args: operation: operation to construct command group Returns: list: constructed operation command group run_on_groupsNgroupidr#rr>rs r_construct_opcommand_grpz#Operations._construct_opcommand_grp|s_ == ) 1" o68 t))II&QR[\ 8 88rc|jdgDcgc]"}d|jj|di$c}Scc}w)zConstruct operation group. Args: operation: operation to construct group Returns: list: constructed operation group host_groupsrrrs r_construct_opgroupzOperations._construct_opgroupsM" mR8: t))II&QR[\ : ::'?c|jdgDcgc]"}d|jj|di$c}Scc}w)zConstruct operation template. Args: operation: operation to construct template Returns: list: constructed operation template templates templateid)r#rrD)rr _templates r_construct_optemplatez Operations._construct_optemplatesM%==b9; $,,JJ9UVbc ; ;;rcTdtjddg|jdiS)zConstruct operation inventory. Args: operation: operation to construct inventory Returns: dict: constructed operation inventory inventory_modemanual automatic inventory)rrr#rs r_construct_opinventoryz!Operations._construct_opinventorys8 lBBD}}[)+  rcX|jd}||dk(rd}n|dk(rd}dddgSgS)zConstruct operation conditions. Args: operation: operation to construct the conditions Returns: list: constructed operation conditions operation_condition acknowledgedrTnot_acknowledgedrRrn) conditiontypeoperatorvalue)r#)rr_opcond_values r_construct_opconditionsz"Operations._construct_opconditionssS-- 56  .(..!%   rc(g}|D]}|j|}||jd|jd|jdd}|ddk(rU|j||d<|j||d<|j ||d <|d k(r|j ||d <|dd k(rU|j ||d <|j||d<|j||d<|d k(r|j ||d <|ddvr|j||d<t|jtdk\r|ddvr|d|d<|ddvr|j||d<|ddk(r|j||d<|dvr*t|jdtdr9d|d<n3|j!d|j!d|j!d|j#|t%j&|S)zConstruct the operation data using helper methods. Args: operation: operation to construct Returns: list: constructed operation data r esc_step_from esc_step_to) operationtyperr/r0r1r opmessage opmessage_usr opmessage_grprG opconditionsr.r  opcommand_hst opcommand_grp)opgroupr) tagsoptag) optemplate opinventory)rGrN)rr#rrrr-r rrrrrrr#rrtrappendrr)rrrconstructed_dataopoperation_typeconstructed_operations rconstruct_the_datazOperations.construct_the_datas`4 ;B!::2>N!/ ff\2!#!8!vvm4 % !%_5:595N5Nr5R%k29=9V9VWY9Z%o69=9V9VWY9Z%o69,<@g* 7 9g* ` 8 : ; ,@BrrceZdZdZdZdZy)RecoveryOperationszc Restructures the user defined recovery operations data to fit the Zabbix API requirements c tjgd|dS#t$r%|jj d|dzYywxYw)Construct operation type. Args: operation: operation to construct type Returns: str: constructed operation type ) rrNNNNNNNNNnotify_all_involvedrtz3Unsupported value '%s' for recovery operation type.rNrrs rrz+RecoveryOperations._construct_operationtypes_ r77 9')2&(9   r LL " "'\_hio_p'p " q rrcg}|D]}|j|}d|i}|ddk(r<|j||d<|j||d<|j||d<|ddk(r(|j||d<|dj d|ddk(r<|j ||d <|j ||d <|j||d <|j|tj|S) zConstruct the recovery operations data using helper methods. Args: operation: operation to construct Returns: list: constructed recovery operations data r1rr2r3r4 rr.r r6r7 rrrrrr rrrDrrrrrErFrGrHs rrIz%RecoveryOperations.construct_the_data.5 ;B!::2>N% ! %_5:595N5Nr5R%k29=9V9VWY9Z%o69=9V9VWY9Z%o6$_5;595N5Nr5R%k2%k266}E%_5:595N5Nr5R%k29=9V9VWY9Z%o69=9V9VWY9Z%o6  # #$9 :- ;0//0@AArNrrr__doc__rrIrrrrKrKsr6"BrrKceZdZdZdZdZy)AcknowledgeOperationszf Restructures the user defined acknowledge operations data to fit the Zabbix API requirements c tjgd|dS#t$r%|jj d|dzYywxYw)rM) rrNNNNNNNNNNrNrtz6Unsupported value '%s' for acknowledge operation type.rNrrs rrz.AcknowledgeOperations._construct_operationtypeXs_ u77 9')2&(9  u LL " "'_bklrbs's " t urcg}|D]}|j|}d|i}|ddk(r<|j||d<|j||d<|j||d<|ddk(r(|j||d<|dj d|ddk(r<|j ||d <|j ||d <|j||d <|j|tj|S) zConstruct the acknowledge operations data using helper methods. Args: operation: operation to construct Returns: list: constructed acknowledge operations data r1rr2r3r4 rr.r r6r7rQrRs rrIz(AcknowledgeOperations.construct_the_datatrSrNrTrrrrWrWSsu8"BrrWc*eZdZdZdZdZdZdZy)Filterct|dkrdddS|dk(rdddS|dk(rdddS|dk(rd ddS|d k(r#|d |dS|jjd |d |dSdddS)zConstruct the eval type Args: _formula: zabbix condition evaluation formula _conditions: list of conditions to check Returns: dict: constructed acknowledge operations data r.rRN)evaltypeformulaandorandrTorrVcustom_expressionrXzD'formula' is required when 'eval_type' is set to 'custom_expression'r)r0r%r&)r _eval_type_formula _conditionss r_construct_evaltypezFilter._construct_evaltypes { q            , ,# #'  &&+q&r  #    rc tjgd|dS#t$r%|jj d|dzYywxYw)zConstruct the condition type Args: _condition: condition to check Returns: str: constructed condition type data ) host_groupr5rGrHtrigger_severity trigger_value time_periodhost_ipdiscovered_service_typediscovered_service_portdiscovery_statusuptime_or_downtime_durationreceived_value host_templateNNmaintenance_statusNdiscovery_rulediscovery_checkrdiscovery_objectr7 event_type host_metadata event_tagevent_tag_valuertz*Unsupported value '%s' for condition type.rNrr _conditions r_construct_conditiontypezFilter._construct_conditiontypes_ j779#6%/v$67 : j LL " "'SV`agVh'h " i jrc tjddgddgddgddgd d d gd d gdddddg |dS#t$r%|jj d|dzYywxYw)zConstruct operator Args: _condition: condition to construct Returns: str: constructed operator equals=does not equal<>containslikedoes not containnot likeinis greater than or equals>=is less than or equals<=not inmatchesdoes not matchYesNor)z$Unsupported value '%s' for operator.rNrr|s r_construct_operatorzFilter._construct_operators h773!4(V$#Z0,d3)40  9"*-   h LL " "'MPZ[ePf'f " g hs03+A! A!c |dk(r|jj|dS|dk(r|jj|dS|dk(r|jj|dS|dk(rt j gd|xsd S|d k(rt j d d g|xsd S|d k(rt j gd|S|dk(rt j gd|S|dk(r|jj |dS|dk(rt j ddg|S|dk(r|jj|dS|dk(r|jj|dS|dk(r|jj|dS|dk(rt j gd|S|dk(rt j gd|S|S#t$r&|jjd |d!|d"#Yy$wxYw)%zConstruct operator Args: conditiontype: type of condition to construct value: value to construct Returns: str: constructed value rrr.r  triggeridr8)not classified informationwarningaveragehighdisasterrr9okproblem)rQrSrUrWrYr[r]r_rarcrergrirkrmrorB)updown discoveredlostr;rrrdruleiddcheckidproxyid) pchldrfor0r5service)zitem in not supported statezitem in normal statezLLD rule in not supported statezLLD rule in normal stateztrigger in unknown stateztrigger in normal statezUnsupported value 'z' for specified condition type. Check out Zabbix API documentation for supported values for condition type 'z' at https://www.zabbix.com/documentation/3.4/manual/api/reference/action/object#action_filter_conditionrN) rr>r9rJrrrDrOr}rr$r%r&)rr(r*s r_construct_valuezFilter._construct_valuesm_ !))II%PQZ[[!))??FxPP!))EEeL[YY!#;;= "'!:*: !#;;= % !#;;= %!("#;;=#  "))GGN|\\"#;;= "))SSTYZ[dee"))UUV[\]ghh"))AA%HSS"#;;=!& "#;;=/ 16 L  LL " "BGIVW #  sd"G "G "G + G G -G G '"G G '"G "G -"G G -G G ,G;:G;c |yi}g|d<|D]y}|j|}|dj||j||jd|jd|jd|j |d{|j |||d}|d|d<|d|d<t j|S) aDConstruct the user defined filter conditions to fit the Zabbix API requirements operations data using helper methods. Args: _formula: zabbix condition evaluation formula _conditions: conditions to construct Returns: dict: user defined filter conditions Nrr*value2 formulaid)r(r*rrr)r^r_)r~rDrr#rrgrr)rrdrerfrEcondcondition_type_constructed_evaltypes rrIzFilter.construct_the_datazs  )+& D!::4@N \ * 1 1!/..~txx?PQ((8,!XXk2 44T: 3  !% 8 8   \ *!  (=Z'H$&;I&F#//0@AArN)rrrrgr~rrrIrrrr\r\s". `(jTh6iVBrr\c(tj}|jttddtddtddgdtdddddg tddd d d g td dd tddgdttddtddgdtddtddtdddddgggtddd tdddgd tddgdtdoidtddgddtddd dtddd dtddd dtdddd d!g d"tddgd#d$tddd%tddgd&d'tddd(d)tddd*tddd+d,tddd+d-tddd.tddd'd/gd0tddd1tddd2tddd3tddd4 d5tddd6tddd7tddd+d8tddd+d9tddd+d:tddd;dtddd+dd?d"ggdd?d*d,gdgd"d@d$d%ggd"dAd$ggd"dBd$d.ggd.d'd2d'ggd.d/gdCgd"dDgdEgd"dFd-ggddGd9ggddHd9ggddId=ggddJd=ggddKd:ggddLd8d7gdgddMd>gdgddNd>gdggtddgdtdoidtddgdOd"tddgd#d$tddd%tddgd&d'tddd(d)tddd*tddd+d,tddd+d-tddd.tddd'd/gd0tddd1tddd2tddd3tddd4 d5tddd6tddd7tddd+d8tddd+dd?d"ggdd?d*d,gdgd"d@d$d%ggd"dAd$ggd"dBd$d.ggd.d'd2d'ggd.d/gdCgd"dDgdEgd"dFd-ggddLd8d7gdgg tddgddPgtdoidtddgdOd"tddgd#d$tddd%tddgd&d'tddd(d)tddd*tddd+d,tddd+d-tddd.tddd'd/gd0tddd1tddd2tddd3tddd4 d5tddd6tddd7tddd+d8tddd+dd?d"ggdd?d*d,gdgd"d@d$d%ggd"dAd$ggd"dBd$d.ggd.d'd2d'ggd.d/gdCgd"dDgdEgd"dFd-ggddLd8d7gdgg Qtd dd td dd Rt |dSddTgggdU}|j dV}|j d}|j dT}|j dS}|j dW}|j dX}|j dY}|j dZ} |j d[} |j d\} |j d]} |j d^} |j d_}|j d`}t |}t|}|j|}t||}t||}t||}t||}|r(|j|da}|dk(r+|j|}|jddb|dc|dyt|||||||j!| ||j!| |j!| | ||e }t#|j$t#dfk\r||d_<|j!| ||d^dgdh<|j&doi|}|ik(r|jddi|zdy|j(dodj|i|}|jddk|dc|dy|dk(r|jdlyt||||||j!| ||j!| |j!| | ||m }|j!| ||d^dgdh<t#|j$t#dfk\r||d_<|j*doi|}|jddn|dc|dy)pz!Main ansible module function rF)rtrequiredTr)rtrchoicespresentabsent)rtrdefaultrrrbool)rtrrrdict)rrrrrrrrrrrrrrrrrr)rr)rtr*rrtr{r)rtrrelementsoptions required_ifN)r`rarbrc)rrrrrrrrrrrrNrrr0sr/intr.r0r%r&r' command_type) custom_scriptipmisshtelnet global_scriptcommand execute_on)agentserverrpassword)rtrno_logportr)rtrrr r ssh_auth_type public_keyssh_privatekey_filessh_publickey_filerrrrrrrrr"r r!rr=rrrr)rrrr)rrrrrrrrrrrr)rrrNr)rtrrraliasesrr)rrrstaterrrr_ eval_typerrrrrrr) argument_specrsupports_check_moderrrrr_rrrrrrrzAction Deleted: z, ID: )rr ) rrrrrrrrrrrrrzAction is up to date: %srzAction Updated: )r) rrrrrrrrrzAction created: r)rzabbix_common_argument_specrrrparamsr rr*rrKrWr\r2rrrIrrrrr)rrrrrrrrrr_rrrrrr zapi_wrapperr" action_existsops recovery_opsacknowledge_opsfltrrresultr differences rmainrs !<<>MUU3 ut ,uu>wxy9V^J_` IWaKbc!vtLEE:!0ut4679>*XJ7G& N%%>EE4ItuF!F* UUDI+F,#qI-F.!eeQG/F0%)" +-?@ %1F>"" ?FT%%8UFV "8WF`55FaFbuu5cFd#OeFf"vNgFh!ee1M?C+k];/+?2[MB/;K)LdS6(D9+fXt<#Y_ @!+!+"" +,%%8-+. "8/+855F9+:uu5;+<#O=+>"vN?+@!ee"vN?+@!ee#]]+CD]]#34N';<QQ+9'(L[LnLnpFMGF=!9:9EaH I000:6:JR  4NRV4W X---'   SWY_3` a H    U  +)%%911*lK$0$C$CDW$X229gzR#5 FM\LnLnpFMGF=!9:9EaH IL99:l5>QQ+9'()))3F3I   TtU^/_  `r__main__) __future__rrrrt __metaclass__ DOCUMENTATIONEXAMPLESRETURNansible.module_utils.basicr>ansible_collections.community.zabbix.plugins.module_utils.baser#ansible.module_utils.compat.versionrAansible_collections.community.zabbix.plugins.module_utils.helpers communityzabbixplugins module_utilshelpersrr rrrKrWr\rrrrrrsA@ T  ly v 5U<XXXS[:S[l \T\DFBFBRBBBBJCBJCBL@BT@BF{a|  zFr