Vh)ddlmZmZmZeZddgddZeddZed d d Z ed Z edZ dZ dZ dZddlmZddlmZmZmZdZdZdZdZdZdZedk(reyy))absolute_importdivisionprint_functionz1.1stableinterface certified)metadata_versionstatus supported_byz pipeline/v1zcore/v2)v1v2HandlerTCPStreamHandlerSumoLogicMetricsHandlerhandlertcp_stream_handlersumo_logic_metrics_handlerMutator)mutator EventFilter) event_filteraj module: pipeline author: - Domen Dobnikar (@domen_dobnikar) short_description: Manage Sensu pipeline description: - Create, update or delete a Sensu pipeline. - For more information, refer to the Sensu documentation at U(https://docs.sensu.io/sensu-go/latest/observability-pipeline/observe-process/pipelines/). version_added: 1.14.0 extends_documentation_fragment: - sensu.sensu_go.auth - sensu.sensu_go.name - sensu.sensu_go.namespace - sensu.sensu_go.state - sensu.sensu_go.labels seealso: - module: sensu.sensu_go.socket_handler - module: sensu.sensu_go.handler_info - module: sensu.sensu_go.pipe_handler - module: sensu.sensu_go.filter - module: sensu.sensu_go.filter_info - module: sensu.sensu_go.mutator - module: sensu.sensu_go.mutator_info options: workflows: description: - Array of workflows (by names) to use when filtering, mutating, and handling observability events with a pipeline. type: list elements: dict suboptions: name: description: - Name of the Sensu pipeline workflow. type: str required: true filters: description: - Reference for the Sensu event filters to use when filtering events for the pipeline. - Each pipeline workflow can reference more than one event filter. - If a workflow has more than one filter, Sensu applies the filters in a series, starting with the filter that is listed first. type: list elements: dict suboptions: name: description: - Name of the Sensu event filter to use for the workflow. - You can use the built-in event filters, as well as your existing event filters, in pipeline workflows. type: str required: true type: description: - The sensuctl create resource type for the event filter. - Event filters should always be type EventFilter. type: str default: event_filter choices: [ event_filter ] mutator: description: - Reference for the Sensu mutator to use to mutate event data for the workflow. - Each pipeline workflow can reference only one mutator. type: dict suboptions: name: description: - Name of the Sensu mutator to use for the workflow. - You can use your existing mutators in pipeline workflows. type: str required: true type: description: - The sensuctl create resource type for the mutator. - Mutators should always be type Mutator. type: str default: mutator choices: [ mutator ] handler: description: - Reference for the Sensu handler to use for event processing in the workflow. - Each pipeline workflow must reference one handler. - Pipelines ignore any filters and mutators specified in handler definitions. type: dict required: true suboptions: name: description: - Name of the Sensu handler to use for the workflow. - You can use your existing handlers in pipeline workflows. - Pipelines ignore any filters and mutators specified in handler definitions. type: str required: true type: description: - The sensuctl create resource type for the handler. type: str required: true choices: [ handler, tcp_stream_handler, sumo_logic_metrics_handler ] a - name: Create a pipeline sensu.sensu_go.pipeline: name: this_pipeline workflows: - name: this-wf handler: name: this_handler type: tcp_stream_handler filters: - name: this_filter - name: this_filter_2 mutator: name: this_mutator - name: Delete pipeline sensu.sensu_go.pipeline: name: this_pipeline state: absent a object: description: Object representing Sensu pipeline. returned: success type: dict sample: metadata: created_by: admin name: this_pipeline namespace: default workflows: - filters: - api_version: core/v2 name: this_filter type: EventFilter - api_version: core/v2 name: this_filter_2 type: EventFilter handler: api_version: pipeline/v1 name: this_handler type: TCPStreamHandler mutator: api_version: core/v2 name: this_mutator type: Mutator name: this-wf ) AnsibleModule) argumentserrorsutilsc0tj||dS)N pipelines)r do_differ)currentdesireds k/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/sensu/sensu_go/plugins/modules/pipeline.pyrrs +6c:t|d|d<td|d<y)Ntyper api_version) MUTATOR_TYPE API_VERSION)payload_mutators r"handle_mutator_api_and_typer*s%*?6+BCOF%0%6OM"r#chd}|dD](}t|d||d<td||d<|dz }*y)Nrfiltersr%r r&) FILTER_TYPEr()payload_filtersworkflow filter_countfilters r"handle_filter_api_and_typer3sQL9%0;F6N0K %f-7B47H %m4 r#cb|ddvr td|d<n td|d<t|d|d<y)Nr%)rrr r&r )r( HANDLER_TYPE)payload_handlers r"handle_handler_api_and_typer7sBv"VV)4T): &)4T): &*?6+BCOFr#cd}|jdD]}t|d|d|jdrt|d|dn!d|d|vr|d|j d|jdrt |d|d|n!d|d|vr|d|j d|dz }y)Nr workflowsrrr,r-)paramsr7getr*popr3)modulepayload payload_countr0s r"handle_api_version_and_typesr@sMMM+.#GK$8$G $RS << " ' (<](KI(V W '+.}= = K  / 3 3I > << " & $]3I> J '+.}= = K  / 3 3I > !r#cdddgfg}t|dttjdddddtd d ttd d td d ttd d td d d gtd ttd d td ddgtd dttd d td dgd}tj|j d}t j|j dd|j d}tj|j d}|j ddk(r t|| t j|j d||||jt\}}|j||y#tj$r%}|j!t#|Yd}~yd}~wwxYw)Nstatepresentr9Tauthname namespacelabelslistdictstr)r%requiredr)r%defaultchoices)rEr%)r%elementsoptionsr)r%rOr)r%rKrM)r%rKrO)rEr,rr)r9) required_ifsupports_check_mode argument_specr)changedobject)msg)rrIrget_specget_sensu_clientr:rbuild_core_v2_pathget_mutation_payloadr@sync check_moder exit_jsonrError fail_jsonrJ)rPr=clientpathr>rSres r"mainrbs )k]+K    h "!%!#!' $!%%*)-""&%*(6$2)"" !"!# $!%%*)-""&%*(1$-)"" ! !#!% $!%%*)-""&%*)-)"" !M9= B FFN ' ' f(= >F  # # k"Kv1F D,, {G}}W*$VW5% :: MM' "FD'6;L;L   9 <<%SV$$%s;A GG?G::G?__main__N) __future__rrrr% __metaclass__ANSIBLE_METADATArIr(r5r'r. DOCUMENTATIONEXAMPLESRETURNansible.module_utils.basicr module_utilsrrrrr*r3r7r@rb__name__r#r"rnsA@  ! m 2 I:LjCD I&  . a F * :533 7 D*[%| zFr#