VhwBdZdZdZddlZ ddlZddlmZddlmZddl m Z ddl m Z dd l mZdd lmZdd lmZdd Zej*d ZdZdZdZdZdZdZedk(reyy#e$rYlwxYw)a --- module: sqs_queue version_added: 1.0.0 short_description: Creates or deletes AWS SQS queues description: - Create or delete AWS SQS queues. - Update attributes on existing queues. author: - Alan Loi (@loia) - Fernando Jose Pando (@nand0p) - Nadir Lloret (@nadirollo) - Dennis Podkovyrin (@sbj-ss) options: state: description: - Create or delete the queue. choices: ['present', 'absent'] default: 'present' type: str name: description: - Name of the queue. required: true type: str queue_type: description: - Standard or FIFO queue. - I(queue_type) can only be set at queue creation and will otherwise be ignored. choices: ['standard', 'fifo'] default: 'standard' type: str deduplication_scope: description: - Deduplication scope for FIFO queues. - C(messageGroup) is required for high throughput FIFO. - Defaults to C(queue) on creation. choices: ['queue', 'messageGroup'] type: str version_added: 5.3.0 fifo_throughput_limit: description: - Throughput limit for FIFO queues. - C(perMessageGroupId) is required for high throughput FIFO. - Defaults to C(perQueue) on creation. choices: ['perQueue', 'perMessageGroupId'] type: str version_added: 5.3.0 visibility_timeout: description: - The default visibility timeout in seconds. aliases: [default_visibility_timeout] type: int message_retention_period: description: - The message retention period in seconds. type: int maximum_message_size: description: - The maximum message size in bytes. type: int delay_seconds: description: - The delivery delay in seconds. aliases: [delivery_delay] type: int receive_message_wait_time_seconds: description: - The receive message wait time in seconds. aliases: [receive_message_wait_time] type: int policy: description: - Policy to attach to the queue. - Policy body can be YAML or JSON. - This is required for certain use cases for example with S3 bucket notifications. type: dict redrive_policy: description: - JSON dict with the redrive_policy (see example). type: dict kms_master_key_id: description: - The ID of an AWS-managed customer master key (CMK) for Amazon SQS or a custom CMK. - Specifying a valid I(kms_master_key_id) will enable encryption automatically. type: str kms_data_key_reuse_period_seconds: description: - The length of time, in seconds, for which Amazon SQS can reuse a data key to encrypt or decrypt messages before calling AWS KMS again. aliases: [kms_data_key_reuse_period] type: int content_based_deduplication: type: bool description: - Enables content-based deduplication. Used for FIFOs only. - Defaults to C(false). extends_documentation_fragment: - amazon.aws.common.modules - amazon.aws.region.modules - amazon.aws.tags - amazon.aws.boto3 a content_based_deduplication: description: Enables content-based deduplication. Used for FIFOs only. type: bool returned: always sample: True fifo_throughput_limit: description: Which throughput limit strategy is applied. type: str returned: always sample: perQueue deduplication_scope: description: The deduplication setting. type: str returned: always sample: messageGroup visibility_timeout: description: The default visibility timeout in seconds. type: int returned: always sample: 30 delay_seconds: description: The delivery delay in seconds. type: int returned: always sample: 0 kms_master_key_id: description: The ID of an AWS-managed customer master key (CMK) for Amazon SQS or a custom CMK. type: str returned: if value exists sample: alias/MyAlias kms_data_key_reuse_period_seconds: description: The length of time, in seconds, for which Amazon SQS can reuse a data key to encrypt or decrypt messages before calling AWS KMS again. type: int returned: always sample: 300 maximum_message_size: description: The maximum message size in bytes. type: int returned: always sample: 262144 message_retention_period: description: The message retention period in seconds. type: int returned: always sample: 345600 name: description: Name of the SQS Queue type: str returned: always sample: "queuename-987d2de0" queue_arn: description: The queue's Amazon resource name (ARN). type: str returned: on success sample: 'arn:aws:sqs:us-east-1:123456789012:queuename-987d2de0' queue_url: description: URL to access the queue type: str returned: on success sample: 'https://queue.amazonaws.com/123456789012/MyQueue' receive_message_wait_time_seconds: description: The receive message wait time in seconds. type: int returned: always sample: 0 region: description: Region that the queue was created within type: str returned: always sample: 'us-east-1' tags: description: List of queue tags type: dict returned: always sample: '{"Env": "prod"}' a= - name: Create SQS queue with redrive policy community.aws.sqs_queue: name: my-queue region: ap-southeast-2 default_visibility_timeout: 120 message_retention_period: 86400 maximum_message_size: 1024 delivery_delay: 30 receive_message_wait_time: 20 policy: "{{ json_dict }}" redrive_policy: maxReceiveCount: 5 deadLetterTargetArn: arn:aws:sqs:eu-west-1:123456789012:my-dead-queue - name: Drop redrive policy community.aws.sqs_queue: name: my-queue region: ap-southeast-2 redrive_policy: {} - name: Create FIFO queue community.aws.sqs_queue: name: fifo-queue region: ap-southeast-2 queue_type: fifo content_based_deduplication: true - name: Tag queue community.aws.sqs_queue: name: fifo-queue region: ap-southeast-2 tags: example: SomeValue - name: Configure Encryption, automatically uses a new data key every hour community.aws.sqs_queue: name: fifo-queue region: ap-southeast-2 kms_master_key_id: alias/MyQueueKey kms_data_key_reuse_period_seconds: 3600 - name: Example queue allowing s3 bucket notifications sqs_queue: name: "S3Notifications" default_visibility_timeout: 120 message_retention_period: 86400 maximum_message_size: 1024 delivery_delay: 30 receive_message_wait_time: 20 policy: Version: 2012-10-17 Id: s3-queue-policy Statement: - Sid: allowNotifications Effect: Allow Principal: Service: s3.amazonaws.com Action: - SQS:SendMessage Resource: "arn:aws:sqs:*:*:S3Notifications" Condition: ArnLike: aws:SourceArn: "arn:aws:s3:*:*:SomeBucket" - name: Delete SQS queue community.aws.sqs_queue: name: my-queue region: ap-southeast-2 state: absent N)camel_dict_to_snake_dict)snake_dict_to_camel_dict)is_boto3_error_code)compare_policies)AWSRetry)compare_aws_tags)AnsibleCommunityAWSModulecl|jjd}|r|jdr|S|dzS)Nnamez.fifo)paramsgetendswith)moduleis_fifor s k/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/aws/plugins/modules/sqs_queue.pyget_queue_namers3 ==  V $D dmmG, '>cV |j|dS#td$rYywxYw)N) QueueNameQueueUrl'AWS.SimpleQueueService.NonExistentQueue) get_queue_urlr)clientr s rrrs8##d#3J?? H Is ((c:|j|dgdd}t|}|jdd|jddt|}|j dd|d<|j dd|d <|j D]a\}}| |d vrt j|}|||<(|d k(r t|||< |tt|k(rt|||<c|S#ttf$rY;wxYw#ttf$rYwxYw) z- Description a queue in snake format AllTrAttributeNames aws_retry AttributesPolicyN RedrivePolicypolicyredrive_policy)r"r#content_based_deduplication) get_queue_attributesdictpoprr itemsjsonloadsbool TypeError ValueErrorstrint)r queue_url attributes descriptionkeyvaluer"s rdescribe_queuer5'sD,,iQVPWcg,hiuvJz"KOOHd#OOOT**;7K&NN8T:K$.NN?D$IK !"'') U =  . .ZZ&F%K   / / #'; C  CJ'#&u: C #* z*   :&   s$;C3 %D3DDDDc|jjddk(}|jjd}t||}t||jjdd}t ||}||d<i}|s8|rd|d <|r||d <d |d <|j r|S|j ||d d}t|||\}} |d xx|zcc<| |d<t|||\}} |d xx|zcc<| |d<|jt||tdddd} t|jD]*} | j| } | s|j| || <,|S)N queue_typefifokms_master_key_idregionFr r:changedr0True FifoQueueKmsMasterKeyIdTr<)rrrr queue_arntagsdelivery_delayreceive_message_wait_timedefault_visibility_timeoutkms_data_key_reuse_period) delay_seconds!receive_message_wait_time_secondsvisibility_timeout!kms_data_key_reuse_period_seconds) r r rr&r check_mode create_queueupdate_sqs_queue update_tagsupdater5listkeys)rrrr9 queue_nameresultr0create_attributesr<arnrACOMPATABILITY_KEYSr3 return_names rcreate_or_update_sqs_queuerWMsmm -7G ))*=>0J  }}  *F fj1I#F;  -3 k * 2C . / y   M''*IZfj'klvw #FFI>LGS 9 F; 6:MGT 9 F6N MM.34&*E7*E  FKKM"2),,S1 "(**S/F;  2 MrcT|j}d}|j|dgdd}t|jd}t }|jj dh|jj d}|j dd } t j| } t| |rt j||d<d}|jj d h|jj d }|j d d } t j| } t| |rt j||d <d}|jD]\} } | d vr | |jvr|j | 0|| } t| tr2t| j} t| j} t| t| k(rt| || <d}|r|s|j!||d ||j dfS)NFrTrr)capitalize_firstr"r z{}r#r!)r r!)rrrr@)rJr%rr r&r r)r*rdumpsr(rP isinstancer+r.lowerset_queue_attributes)rrr0rJr<existing_attributesnew_attributesattributes_to_setr" current_valuecurrent_policy attributer4 new_values rrLrLs""JG 55yZ_Y`lp5q.fmmdSN}}".""8,+//$? M2 NF 3*.**V*< h 'G }})*6""#34+//F M2 NF 315F1C o .G/557 5 3 3  N//1 1    i ( 0 "9- i &I,,.IJ$$&E y>SZ ' (+9~)$-0z##YCT`d#e '++K8 88rcR|jjddk(}t||}t||jjdd}t ||}|s|St ||d<|j s+tj|j||S)Nr7r8r:Fr;r<)r) r r rr&rr+rJrjittered_backoff delete_queue)rrrrQrRr0s rdelete_sqs_queuerhsmm -7G0J z&--*;*;H*Eu UFfj1I  YF9   8#!!#F$7$78)L MrcD|jjd}|jjd}|difS |j|dd}t|||\}}|jsO|r|j||d|r|j|| |j|djdi}n|}t|xs t|}||fS#tjj tjj tf$ri}YwxYw) NrA purge_tagsFT)rrTags)rj)rTagKeysr)rrk) r r list_queue_tagsbotocore exceptions ClientError BotoCoreErrorKeyErrorrrJ untag_queue tag_queuer+) rr0rnew_tagsrj existing_tags tags_to_addtags_to_remover<s rrMrMs&}}  (H""<0Jby.. T.RSYZ #3=(Wa"bK        >UY  Z    ik  B.. T.RVVW]_ab  >"7d;&7G M !!    + +X-@-@-N-NPX Y sC>DDc td3idtddddgdtddd tdd d d gd td dgdtd dtd dtddtd dgdtddtd dgdtddtdddgdtdd d!gd"td d#gd$%d&td'd(tdd)gd*td'd+}t|d,}|jjd}t j d-g.} |j d/|0}|dk(r t||}n|dk(r t||}|jd3iy#tjjtjjf$r}|j|d12Yd}~yd}~wwxYw)4Nstater.presentabsent)typedefaultchoicesr T)r}requiredr7standardr8rFr/rB)r}aliasesmaximum_message_size)r}message_retention_periodr"r&rGrCr#rHrDr9fifo_throughput_limitperQueueperMessageGroupId)r}rdeduplication_scopequeue messageGrouprIrEF)r}rno_logr$r+rA resource_tagsrj)r}r~) argument_specsupports_check_moder)catch_extra_error_codessqs)retry_decoratorzFailed to control sqs queue)msg)r&AnsibleAWSModuler r rrfrrWrh exit_jsonrnrorprq fail_json_aws)rrrzrrrRes rmainrsy9h:OP ut ,UJV@TU0@/AB  "u-  "&5!1  +/ED_C`*a( U5Q4RSE*# DW7XY!eg~5NO+/ED_C`in*o%)f$5 v'8 9!"VT2#M&Mt TF MM  g &E//IrHstO #uoF I /?F h %ff5F "6"    + +X-@-@-N-N OCQ$ABBCs6F 7GGG__main__)F) DOCUMENTATIONRETURNEXAMPLESr)rn ImportError0ansible.module_utils.common.dict_transformationsrransible_collections.community.aws.plugins.module_utils.modulesr rrrfrr5rWrLrhrMr__name__rrrrsf PL \F P  VU\WPXx#L1h59p  "4!#H zF}  sA55A=<A=