Vh^dZdZdZ ddlZddlmZddlmZddl m Z ddl m Z dd l mZdd l mZdd l mZdd lmZd ZdZe j,dZe j,dZe j,dgdZe j,dgdZdZdZdZdZdZe dk(reyy#e$rYwxYw)a --- author: - "Jens Carl (@j-carl), Hothead Games Inc." - "Rafael Driutti (@rafaeldriutti)" module: redshift version_added: 1.0.0 short_description: create, delete, or modify an Amazon Redshift instance description: - Creates, deletes, or modifies Amazon Redshift cluster instances. options: command: description: - Specifies the action to take. required: true choices: [ 'create', 'facts', 'delete', 'modify' ] type: str identifier: description: - Redshift cluster identifier. required: true type: str node_type: description: - The node type of the cluster. - Require when I(command=create). choices: ['ds1.xlarge', 'ds1.8xlarge', 'ds2.xlarge', 'ds2.8xlarge', 'dc1.large','dc2.large', 'dc1.8xlarge', 'dw1.xlarge', 'dw1.8xlarge', 'dw2.large', 'dw2.8xlarge'] type: str username: description: - Master database username. - Used only when I(command=create). type: str password: description: - Master database password. - Used only when I(command=create). type: str cluster_type: description: - The type of cluster. choices: ['multi-node', 'single-node' ] default: 'single-node' type: str db_name: description: - Name of the database. type: str availability_zone: description: - Availability zone in which to launch cluster. aliases: ['zone', 'aws_zone'] type: str number_of_nodes: description: - Number of nodes. - Only used when I(cluster_type=multi-node). type: int cluster_subnet_group_name: description: - Which subnet to place the cluster. aliases: ['subnet'] type: str cluster_security_groups: description: - In which security group the cluster belongs. type: list elements: str aliases: ['security_groups'] vpc_security_group_ids: description: - VPC security group aliases: ['vpc_security_groups'] type: list elements: str skip_final_cluster_snapshot: description: - Skip a final snapshot before deleting the cluster. - Used only when I(command=delete). aliases: ['skip_final_snapshot'] default: false type: bool final_cluster_snapshot_identifier: description: - Identifier of the final snapshot to be created before deleting the cluster. - If this parameter is provided, I(skip_final_cluster_snapshot) must be C(false). - Used only when I(command=delete). aliases: ['final_snapshot_id'] type: str preferred_maintenance_window: description: - 'Maintenance window in format of C(ddd:hh24:mi-ddd:hh24:mi). (Example: C(Mon:22:00-Mon:23:15))' - Times are specified in UTC. - If not specified then a random 30 minute maintenance window is assigned. aliases: ['maintance_window', 'maint_window'] type: str cluster_parameter_group_name: description: - Name of the cluster parameter group. aliases: ['param_group_name'] type: str automated_snapshot_retention_period: description: - The number of days that automated snapshots are retained. aliases: ['retention_period'] type: int port: description: - Which port the cluster is listening on. type: int cluster_version: description: - Which version the cluster should have. aliases: ['version'] choices: ['1.0'] type: str allow_version_upgrade: description: - When I(allow_version_upgrade=true) the cluster may be automatically upgraded during the maintenance window. aliases: ['version_upgrade'] default: true type: bool publicly_accessible: description: - If the cluster is accessible publicly or not. default: false type: bool encrypted: description: - If the cluster is encrypted or not. default: false type: bool elastic_ip: description: - An Elastic IP to use for the cluster. type: str new_cluster_identifier: description: - Only used when command=modify. aliases: ['new_identifier'] type: str wait: description: - When I(command=create), I(command=modify) or I(command=restore) then wait for the database to enter the 'available' state. - When I(command=delete) wait for the database to be terminated. type: bool default: false wait_timeout: description: - When I(wait=true) defines how long in seconds before giving up. default: 300 type: int enhanced_vpc_routing: description: - Whether the cluster should have enhanced VPC routing enabled. default: false type: bool notes: - Support for I(tags) and I(purge_tags) was added in release 1.3.0. extends_documentation_fragment: - amazon.aws.common.modules - amazon.aws.region.modules - amazon.aws.tags - amazon.aws.boto3 ab - name: Basic cluster provisioning example community.aws.redshift: command: create node_type: ds1.xlarge identifier: new_cluster username: cluster_admin password: 1nsecure - name: Cluster delete example community.aws.redshift: command: delete identifier: new_cluster skip_final_cluster_snapshot: true wait: true a cluster: description: dictionary containing all the cluster information returned: success type: complex contains: identifier: description: Id of the cluster. returned: success type: str sample: "new_redshift_cluster" create_time: description: Time of the cluster creation as timestamp. returned: success type: float sample: 1430158536.308 status: description: Status of the cluster. returned: success type: str sample: "available" db_name: description: Name of the database. returned: success type: str sample: "new_db_name" availability_zone: description: Amazon availability zone where the cluster is located. "None" until cluster is available. returned: success type: str sample: "us-east-1b" maintenance_window: description: Time frame when maintenance/upgrade are done. returned: success type: str sample: "sun:09:30-sun:10:00" private_ip_address: description: Private IP address of the main node. returned: success type: str sample: "10.10.10.10" public_ip_address: description: Public IP address of the main node. "None" when enhanced_vpc_routing is enabled. returned: success type: str sample: "0.0.0.0" port: description: Port of the cluster. "None" until cluster is available. returned: success type: int sample: 5439 url: description: FQDN of the main cluster node. "None" until cluster is available. returned: success type: str sample: "new-redshift_cluster.jfkdjfdkj.us-east-1.redshift.amazonaws.com" enhanced_vpc_routing: description: status of the enhanced vpc routing feature. returned: success type: bool tags: description: aws tags for cluster. returned: success type: dict N)snake_dict_to_camel_dict)is_boto3_error_code)get_aws_account_info)AWSRetry)ansible_dict_to_boto3_tag_listboto3_tag_list_to_ansible_dict)compare_aws_tags)AnsibleCommunityAWSModulect|\}}|j}d|d|d|d|}|jjd}|jjd} t t ||| \} } | r |j |t| | r |j|| t| xs| } | S#tjjtjjf$r} |j| d Yd } ~ vd } ~ wwxYw#tjjtjjf$r} |j| d Yd } ~ d } ~ wwxYw) z!Compares and update resource tagszarn:z :redshift::z :cluster:tags purge_tags) ResourceNameTagszFailed to add tags to clustermsgN)rTagKeysz Failed to delete tags on cluster)rregionparamsgetr r create_tagsrbotocore exceptions BotoCoreError ClientError fail_json_aws delete_tagsbool)redshift identifier existing_tagsmodule account_id partitionr resource_arnrr tags_to_addtags_to_removeechangeds j/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/aws/plugins/modules/redshift.py _ensure_tagsr,sd18J ]]F)Jvha |9ZLYL ==  V $D""<0J"23QR_3`bfhr"sK I  lA_`kAl m L  lN S;0.1G N##1183F3F3R3RS I  (G H H I ##1183F3F3R3RS L  (J K K Ls0;B>D>7D5D  D7E) E$$E)cL|d|d|d|d|d|dd}|dD](}|d d vs |d |d <|d dur |d|d<nd|d<nd|d<d|d<d|d<d|d<i|d<|ddk7r7|d|d<|dd|d<|dd|d<|d|d<t|d|d<|S)z&Transform cluster information to dict.ClusterIdentifier ClusterStatusMasterUsernameDBNamePreferredMaintenanceWindowEnhancedVpcRouting)r!statususernamedb_namemaintenance_windowenhanced_vpc_routing ClusterNodesNodeRole)SHAREDLEADERPrivateIPAddressprivate_ip_addressr8FPublicIPAddresspublic_ip_addressN create_timeurlportavailability_zonercreatingClusterCreateTimeEndpointAddressPortAvailabilityZonerr)resourcefactsnodes r+_collect_factsrN.s?23?+-.H%&'CD ()= >  E(  3 3*./A*BE& '+,5-12C-D)*-1)*  E-E%LE&M!%E E&M J.'(;<m +I6e  ,V4f %-.@%A!"6x7GHf Lc2|j|ddS)zE Basic wrapper around describe_clusters with a retry applied r.Clustersr)describe_clusters)r r!s r+_describe_clusterrTTs#  % % % CJ OPQ RRrOc &|jdi|S)zB Basic wrapper around create_cluster with a retry applied )create_clusterr kwargss r+_create_clusterrZ\s #8 " " ,V ,,rOInvalidClusterState)catch_extra_error_codesc &|jdi|S)z Basic wrapper around delete_cluster with a retry applied. Explicitly catches 'InvalidClusterState' (~ Operation in progress) so that we can still delete a cluster if some kind of change operation was in progress. rV)delete_clusterrXs r+_delete_clusterr_fs #8 " " ,V ,,rOc &|jdi|S)z Basic wrapper around modify_cluster with a retry applied. Explicitly catches 'InvalidClusterState' (~ Operation in progress) for cases where another modification is still in progress rV)modify_clusterrXs r+_modify_clusterrbqs #8 " " ,V ,,rOc |jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd}|jjd} d } i} d D]<} |jj| |jj| | | <>|r|| d <| rt| } | | d< t||d } |r4|dz}|jd} |j|t| t||}| rt||d|rd } t||}| t!fS#t d$rx t |f||||dt | d nW#tjjtjjf$r} |j| dYd } ~ nd } ~ wwxYwYtjjtjjf$r} |j| dYd } ~ Ed } ~ wwxYw#tjjtjjf$r} |j| dYd } ~ gd } ~ wwxYw#tjjtjjf$r} |j| dYd } ~ d } ~ wwxYw)z Create a new cluster module: AnsibleAWSModule object redshift: authenticated redshift connection object Returns: r! node_typer5passwordr6wait wait_timeoutrT) cluster_typecluster_security_groupsvpc_security_group_idscluster_subnet_group_namerDpreferred_maintenance_windowcluster_parameter_group_name#automated_snapshot_retention_periodrCcluster_versionallow_version_upgradenumber_of_nodespublicly_accessible encrypted elastic_ipr8Nd_b_nameFClusterNotFound)r.NodeTyper0MasterUserPasswordcapitalize_firstzFailed to create clusterrzFailed to describe cluster<cluster_available MaxAttemptsr. WaiterConfigz(Timeout waiting for the cluster creationr)rrrrTrrZrrrrrr get_waiterrfdictr,rN)r#r r!rdr5rerurfrgrr*rpr)attemptswaiterrKs r+rWrW{s""<0J !!+.I}}  ,H}}  ,H}}  +H ==  V $D==$$^4L ==  V $DG F-& ==  Q  + ))!,F1I)-,%z -d3vB(J/$ 2%$$%89 T KK*4T\C]K ^B$Xz: *hv.> GG(:>H N8, ,,E 0 1 D D  ","'#+   +6DI  ##1183F3F3R3RS D  (B C C D ))'' B Q$@AA B##//1D1D1R1RS T  (R S S T    - -x/B/B/N/N OBQ$@AABsx8F7J= K+7JG#"J#7H7H2-J2H77J<6J2J  J7K( K##K(+7M"L;;Mc|jjd} t||}dtfS#tjj tjj f$r}|j|dYd}~\d}~wwxYw)z Collect data about the cluster. module: Ansible module object redshift: authenticated redshift connection object r!zError describing clusterrNT) rrrTrrrrrrN)r#r r!rKr)s r+describe_clusterrs""<0J@$Xz: ) ))    - -x/B/B/N/N O@Q$>??@s 67B -BB c|jjd}|jjd}|jjd}i}dD]K}||jvs|jj|.|jj|||<M t|fd|it|d|r8|d z}|jd} | j|t|difSdifS#t d $rd ifcYSt j jt j jf$r}|j|d Yd}~d}~wwxYw#t j jt j jf$r }|j|d Yd}~difSd}~wwxYw)zu Delete a cluster. module: Ansible module object redshift: authenticated redshift connection object r!rfrg)skip_final_cluster_snapshot!final_cluster_snapshot_identifierNr.TryrvFzFailed to delete clusterrr{cluster_deletedr}rzTimeout deleting the cluster) rrr_rrrrrrrrrfr) r#r r!rfrgrrr)rrs r+r^r^s""<0J ==  V $D==$$^4L F Q1  }}  #/"MM--a0q 1 @  (2 6Nvhl6m  2%$$%67 H KK*4T\C]K ^ 8O48O! 0 1by'')) @ Q$>?? @##//1D1D1R1RS H  (F G G 8O Hs6%C<E&<E#6E#EE#&7F=F88F=c6|jjd}|jjd}|jjd}i}dD]<}|jj||jj|||<>|jjd( t|||jjd|r4|d z}|jd } | j|t|  t|fd|it|d|jjdr|jjd}|r4|d z}|jd } | j|t|  t||} t|| d|r|j|dd} dt| fS#tjj tjj f$r"}|j|d|d  Yd}~Sd}~wwxYw#tjj tjj f$r}|j|d Yd}~ud}~wwxYw#tjj tjj f$r"}|j|d|d  Yd}~d}~wwxYw#tjj tjj f$r}|j|d Yd}~d}~wwxYw#tjj tjj f$r"}|j|d|d  Yd}~d}~wwxYw)z Modify an existing cluster. module: Ansible module object redshift: authenticated redshift connection object r!rfrg) rhrirjrkrDrlrmrnrCrorprqnew_cluster_identifierNr8)r.r3z!Couldn't modify redshift cluster  rr{r|r}rz=Timeout waiting for cluster enhanced vpc routing modificationr.Tryrz(Timeout waiting for cluster modificationrrQrRr)rrrbrrrrrrrfrrrTr,rSrN) r#r r!rfrgrrr)rrwaiter2rKs r+rarase""<0J ==  V $D==$$^4LF- ==  Q  + ))!,F1I#-(}}/0< [ J6==K\K\]sKt   2%$$%89 i KK*4T\C]K ^ W  (2 6Nvhl6m }}12]]&&'?@  2%%%&9: T LL:DU]D^L _W$Xz:Hj(6*:FC-- -KJWXYZ ) ))I##1183F3F3R3RS [  *KJtdd 9d?tdd 9d@td-dA9dBtdCdDgEdFtdd9}ddGdgfddHgdIfg}t||J}|jjd}|jjd}|jjd}|dGk(r|d ur||j dKL|j dM}d}|dHk(rt ||\}}n>|dNk(rt||\}}n)|dGk(rt||\}}n|dOk(rt||\}}|j|Py)RNcommand)createrLdeletemodifyT)choicesrequiredr!)rrd) z ds1.xlargez ds1.8xlargez ds2.xlargez ds2.8xlargez dc1.largez dc2.largez dc1.8xlargez dw1.xlargez dw1.8xlargez dw2.largez dw2.8xlargeFr5re)no_logrr6rhz multi-nodez single-node)rdefaultrisecurity_groupsliststr)aliasestypeelementsrjvpc_security_groupsrskip_final_snapshotr)rrrrfinal_snapshot_id)rrrksubnet)rrDaws_zonezonerlmaintance_window maint_windowrmparam_group_namernretention_periodint)rrrC)rroversionz1.0)rrrpversion_upgraderqrr)rrrsrtrnew_identifierr8rfrgi,rr resource_tags)rrrrr)rdr5re) argument_spec required_ifzYNeed to specify final_cluster_snapshot_identifier if skip_final_cluster_snapshot is Falserr rLr)r*clusterrV) rAnsibleAWSModulerr fail_jsonclientrWrr^ra exit_json) rrr#rrrconnr*rs r+mainr^sx-DtT-&-  -&u%'-(TE2)-*e$+-,<"?W--.!%.?-@vX] ^/-0 $-B,C&[`a1-2%)2G1Hv_d$e3-4+/8K7LW\*]5-6#'z":7-8 F';<9-:&*3E~2V%W;-<&*3E2F%G=->-1:L9MTY,Z?-@u A-Bi[5'BC-D#,=+>VUYZE-F%(G-H!fe?O-P"vu=Q-Rvu -S-Tuc2U-Vv'8 9W-XVT2Y-M` H<=> HCDK #F mm *G"(--"3"34Q"R(. (9(9:](^%(:eCHiHqk   == $DG(+FD9' G -fd;' H +FD9' H +FD9' Wg6rO__main__)! DOCUMENTATIONEXAMPLESRETURNr ImportError0ansible.module_utils.common.dict_transformationsransible_collections.community.aws.plugins.module_utils.modulesr rr,rNjittered_backoffrTrZr_rbrWrr^rar__name__rVrOr+rs!f P "@ D V\XPffXx6#LSS--4I3JK-L-4I3JK-L-W-t*"'TK*\R7j zF_   sCC C