Vh:dZdZdZddlZddlZ ddlZddlmZddl m Z ddl m Z ddl mZdd lmZd Zd Zd Zd ZdZdZedk(reyy#e$rYEwxYw)a! --- module: glue_connection version_added: 1.0.0 short_description: Manage an AWS Glue connection description: - Manage an AWS Glue connection. See U(https://aws.amazon.com/glue/) for details. - Prior to release 5.0.0 this module was called C(community.aws.aws_glue_connection). The usage did not change. author: - "Rob White (@wimnat)" options: availability_zone: description: - Availability Zone used by the connection - Required when I(connection_type=NETWORK). type: str version_added: 1.5.0 catalog_id: description: - The ID of the Data Catalog in which to create the connection. If none is supplied, the AWS account ID is used by default. type: str connection_properties: description: - A dict of key-value pairs used as parameters for this connection. - Required when I(state=present). type: dict connection_type: description: - The type of the connection. Currently, SFTP is not supported. default: JDBC choices: [ 'CUSTOM', 'JDBC', 'KAFKA', 'MARKETPLACE', 'MONGODB', 'NETWORK' ] type: str description: description: - The description of the connection. type: str match_criteria: description: - A list of UTF-8 strings that specify the criteria that you can use in selecting this connection. type: list elements: str name: description: - The name of the connection. required: true type: str security_groups: description: - A list of security groups to be used by the connection. Use either security group name or ID. - Required when I(connection_type=NETWORK). type: list elements: str state: description: - Create or delete the AWS Glue connection. required: true choices: [ 'present', 'absent' ] type: str subnet_id: description: - The subnet ID used by the connection. - Required when I(connection_type=NETWORK). type: str extends_documentation_fragment: - amazon.aws.common.modules - amazon.aws.region.modules - amazon.aws.boto3 a. # Note: These examples do not set authentication details, see the AWS Guide for details. # Create an AWS Glue connection - community.aws.glue_connection: name: my-glue-connection connection_properties: JDBC_CONNECTION_URL: jdbc:mysql://mydb:3306/databasename USERNAME: my-username PASSWORD: my-password state: present # Create an AWS Glue network connection - community.aws.glue_connection: name: my-glue-network-connection availability_zone: us-east-1a connection_properties: JDBC_ENFORCE_SSL: "false" connection_type: NETWORK description: Test connection security_groups: - sg-glue subnet_id: subnet-123abc state: present # Delete an AWS Glue connection - community.aws.glue_connection: name: my-glue-connection state: absent a connection_type: description: The type of the connection. returned: when state is present type: str sample: JDBC creation_time: description: The time this connection definition was created. returned: when state is present type: str sample: "2018-04-21T05:19:58.326000+00:00" description: description: Description of the job being defined. returned: when state is present type: str sample: My first Glue job last_updated_time: description: The last time this connection definition was updated. returned: when state is present type: str sample: "2018-04-21T05:19:58.326000+00:00" match_criteria: description: A list of criteria that can be used in selecting this connection. returned: when state is present type: list sample: [] name: description: The name of the connection definition. returned: when state is present type: str sample: my-glue-connection physical_connection_requirements: description: A dict of physical connection requirements, such as VPC and SecurityGroup, needed for making this connection successfully. returned: when state is present type: dict sample: {'subnet-id':'subnet-aabbccddee'} raw_connection_properties: description: A dict of key-value pairs used as parameters for this connection. returned: when state is present type: dict sample: {'JDBC_CONNECTION_URL':'jdbc:mysql://mydb:3306/databasename','USERNAME':'x','PASSWORD':'y'} N)camel_dict_to_snake_dict)is_boto3_error_code)%get_ec2_security_group_ids_from_names)AWSRetry)AnsibleCommunityAWSModulec|jjd}|jjd}d|i}|||d< |jd ddi|dS#td $rYywxYw) z Get an AWS Glue connection based on name. If not found, return None. :param connection: AWS boto3 glue connection :param module: Ansible module :return: boto3 Glue connection dict or None if not found name catalog_idNameN CatalogId aws_retryT ConnectionEntityNotFoundException)paramsgetget_connectionr) connectionmoduleconnection_nameconnection_catalog_idrs q/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/aws/plugins/modules/glue_connection.py_get_glue_connectionrsmm''/O"MM--l;o &F(3{(z((B4B6B<PP 8 9sAA+*A+c:d|vrd|d<d|vr t|d<d|vrt|d<g|dd<d|dd<d|dvr|dd|dk7ry d |dvr|dd |d k7ry d|dvr|dd|dk7ry d|dvr!t|ddt|dk7ry d|dvrod|ddvr't|dddt|ddk7ry d|ddvr|ddd|ddk7ry d |ddvr|ddd |dd k7ry y ) aC Compare Glue connection params. If there is a difference, return True immediately else return False :param user_params: the Glue connection parameters passed by the user :param current_params: the Glue connection parameters currently configured :return: True if any parameter is mismatched else False Description MatchCriteriaPhysicalConnectionRequirementsSecurityGroupIdListSubnetIdConnectionPropertiesConnectionInputTConnectionTypeAvailabilityZoneF)listdictset) user_paramscurrent_paramss r_compare_glue_connection_paramsr*sN*(*}%n,*.&''~=;?678RT789NOGI78D +.?"@@ ) *+A BnUkFl lK(9:: ) *+; <O_@` `%677 ) *= 9^M=Z Z+&788S%&7> ^O , ->.';7H+II K0A$BCc$d dil ) *+K LMb cj  @ABWX YjZ +&789YZ Z-./OPQ[\>? KL +.?"@Aa"b b-./OPQcd>?@RST c`tj}|dz}d}|tjkDrNt||}|r|jdr|Stj||tjkDrN|j d|j jdy)Nr z$Timeout waiting for Glue connection r )msg)timerrsleep fail_jsonr)rr start_time wait_timeoutcheck_intervalglue_connections r_await_glue_connectionr7sJ?LN  $.z6B 226:" " >"  $  ? @Q@QRX@Y?Z[\r+cld}t}t|d<|jjd|dd<|jjd|dd<|jjd|dd<|jjd |jjd |d <|jjd !|jjd |dd <|jjd!|jjd|dd<|jjd|jjdt|dd<|jjd0t|jjd|}||ddd<|jjd$|jjd|ddd<|jjd$|jjd|ddd<|rPt ||rg t j |}|dd|d<|js|jdddi|d}n# |js|jdddi|d}|r|js t||}|r|d|d<|j!d|j"dd|it%|xsidgy #tjjtjjf$r}|j|Yd }~d }~wwxYw#tjjtjjf$r}|j|Yd }~d }~wwxYw)z Create or update an AWS Glue connection :param connection: AWS boto3 glue connection :param module: Ansible module :param glue_connection: a dict of AWS Glue connection parameters or None :return: Fr"r r connection_typer#connection_propertiesr!r Nr descriptionrmatch_criteriarsecurity_groups subnet_idrrr availability_zoner$r TRawConnectionPropertieschanged) ignore_listr)r&rrrr*copydeepcopy check_modeupdate_connectionbotocore exceptions ClientError BotoCoreError fail_json_awscreate_connectionr7pop exit_jsonr) rconnection_ec2rr6rArsecurity_group_ids update_paramses r create_or_update_glue_connectionrS sG VF $F (. (9(9&(AF f%28--2C2CDU2VF ./8> 8I8IJa8bF 45 }}&2$mm// ={ }}'339==3D3D]3S !-0 }})*65;]]5F5FGW5X !/2 }}*+76==;L;L[;Y;eFJf !"BC }}*+7B6==CTCTUfCgiwx]o !"BCDYZ }}%1RXR_R_RcRcdoRp !"BCJO }},-9Z`ZgZgZkZk [  !"BCDVW  *6? C ( $ f 5 (56G(H(P f%((0J00Q4Q=Q $$$, ,,FtFvFG v((0VD5DE[5\1223F3O4IrXqWrs%''33X5H5H5V5VW ($$Q'' (##//1D1D1R1RS $   # # $s1 AL "M! 7MMM!7N3N..N3cd}d|jjdi}|jjd|jjd|d<|r# |js|jd ddi|d}|j| y#tj j tj jf$r}|j|Yd}~`d}~wwxYw) z Delete an AWS Glue connection :param connection: AWS boto3 glue connection :param module: Ansible module :param glue_connection: a dict of AWS Glue connection parameters or None :return: FConnectionNamer r Nr r T)rAr) rrrEdelete_connectionrGrHrIrJrKrN)rrr6rArrRs rdelete_glue_connectionrWPsG 1 1& 9 :F }}&2$mm// ={ $$$, ,,FtFvFG W%##//1D1D1R1RS $   # # $s"B7C#CC#cBttdtdtdtddgdtdtddtd d tddtd d d gd td }t|dd dgfddgdfgd }tjd}|j d|}|j d|}t ||}|j jdd k(rt||||yt|||y)Nstr)typer&JDBC)CUSTOMr[KAFKA MARKETPLACEMONGODBNETWORK)rZdefaultchoicesr%)rZelementsT)requiredrZpresentabsent)rdrbrZ) r?r r:r9r;r<r r=stater>rgr:r9r`)r?r=r>) argument_spec required_ifsupports_check_mode )retriesglue)retry_decoratorec2) r&AnsibleAWSModulerjittered_backoffclientrrrrSrW)rhrrnconnection_gluerOr6s rmainrtjsE*U#"/0p e$%8 4e ,&59D9h*?eLE" M# i"9!: ;  +` a ! F//;OmmFOmLO]]5/]JN*?FCO }}!Y.(.&RabHr+__main__) DOCUMENTATIONEXAMPLESRETURNrCr0rG ImportError0ansible.module_utils.common.dict_transformationsransible_collections.community.aws.plugins.module_utils.modulesrrprr*r7rSrWrt__name__rr+rrsE N >* X  V\iPx,:| ]AH&4"IJ zFc  sAAA