VhXZldZdZdZ ddlZddlmZddlmZddl m Z ddl m Z dd l m Z dd l mZdd lmZed d dZe j(d"iedZe j(d"iedZdZe j(d"iedZe j(d"iedZe j(d"iedZe j(d"iedZe j(d"iedZe j(d"iedZdZdZdZ dZ!dZ"dZ#dZ$d Z%e&d!k(re%yy#e$rY&wxYw)#a --- module: dms_endpoint version_added: 1.0.0 short_description: Creates or destroys a data migration services endpoint description: - Creates or destroys a data migration services endpoint, that can be used to replicate data. options: state: description: - State of the endpoint. default: present choices: ['present', 'absent'] type: str endpointidentifier: description: - An identifier name for the endpoint. type: str required: true endpointtype: description: - Type of endpoint we want to manage. - Required when I(state=present). choices: ['source', 'target'] type: str enginename: description: - Database engine that we want to use, please refer to the AWS DMS for more information on the supported engines and their limitations. - Required when I(state=present). choices: ['mysql', 'oracle', 'postgres', 'mariadb', 'aurora', 'redshift', 's3', 'db2', 'azuredb', 'sybase', 'dynamodb', 'mongodb', 'sqlserver'] type: str username: description: - Username our endpoint will use to connect to the database. type: str password: description: - Password used to connect to the database this attribute can only be written the AWS API does not return this parameter. type: str servername: description: - Servername that the endpoint will connect to. type: str port: description: - TCP port for access to the database. type: int databasename: description: - Name for the database on the origin or target side. type: str extraconnectionattributes: description: - Extra attributes for the database connection, the AWS documentation states " For more information about extra connection attributes, see the documentation section for your data store." type: str kmskeyid: description: - Encryption key to use to encrypt replication storage and connection information. type: str tags: description: - A list of tags to add to the endpoint. type: dict certificatearn: description: - Amazon Resource Name (ARN) for the certificate. type: str sslmode: description: - Mode used for the SSL connection. default: none choices: ['none', 'require', 'verify-ca', 'verify-full'] type: str serviceaccessrolearn: description: - Amazon Resource Name (ARN) for the service access role that you want to use to create the endpoint. type: str externaltabledefinition: description: - The external table definition. type: str dynamodbsettings: description: - Settings in JSON format for the target Amazon DynamoDB endpoint if source or target is dynamodb. type: dict s3settings: description: - S3 buckets settings for the target Amazon S3 endpoint. type: dict dmstransfersettings: description: - The settings in JSON format for the DMS transfer type of source endpoint. type: dict mongodbsettings: description: - Settings in JSON format for the source MongoDB endpoint. type: dict kinesissettings: description: - Settings in JSON format for the target Amazon Kinesis Data Streams endpoint. type: dict elasticsearchsettings: description: - Settings in JSON format for the target Elasticsearch endpoint. type: dict wait: description: - Whether Ansible should wait for the object to be deleted when I(state=absent). type: bool default: false timeout: description: - Time in seconds we should wait for when deleting a resource. - Required when I(wait=true). type: int retries: description: - number of times we should retry when deleting a resource - Required when I(wait=true). type: int author: - "Rui Moreira (@ruimoreira)" extends_documentation_fragment: - amazon.aws.common.modules - amazon.aws.region.modules - amazon.aws.boto3 - amazon.aws.tags ay # Note: These examples do not set authentication details - name: Endpoint Creation community.aws.dms_endpoint: state: absent endpointidentifier: 'testsource' endpointtype: source enginename: aurora username: testing1 password: testint1234 servername: testing.domain.com port: 3306 databasename: 'testdb' sslmode: none wait: false aY endpoint: description: - A description of the DMS endpoint. returned: success type: dict contains: database_name: description: - The name of the database at the endpoint. type: str returned: success example: "exampledb" endpoint_arn: description: - The ARN that uniquely identifies the endpoint. type: str returned: success example: "arn:aws:dms:us-east-1:123456789012:endpoint:1234556789ABCDEFGHIJKLMNOPQRSTUVWXYZ012" endpoint_identifier: description: - The database endpoint identifier. type: str returned: success example: "ansible-test-12345678-dms" endpoint_type: description: - The type of endpoint. Valid values are C(SOURCE) and C(TARGET). type: str returned: success example: "SOURCE" engine_display_name: description: - The expanded name for the engine name. type: str returned: success example: "Amazon Aurora MySQL" engine_name: description: - The database engine name. type: str returned: success example: "aurora" kms_key_id: description: - An KMS key ID that is used to encrypt the connection parameters for the endpoint. type: str returned: success example: "arn:aws:kms:us-east-1:123456789012:key/01234567-abcd-12ab-98fe-123456789abc" port: description: - The port used to access the endpoint. type: str returned: success example: 3306 server_name: description: - The name of the server at the endpoint. type: str returned: success example: "ansible-test-123456789.example.com" ssl_mode: description: - The SSL mode used to connect to the endpoint. type: str returned: success example: "none" tags: description: - A dictionary representing the tags attached to the endpoint. type: dict returned: success example: {"MyTagKey": "MyTagValue"} username: description: - The user name used to connect to the endpoint. type: str returned: success example: "example-username" dms_transfer_settings: description: - Additional transfer related settings. type: dict returned: when additional DMS Transfer settings have been configured. s3_settings: description: - Additional settings for S3 endpoints. type: dict returned: when the I(endpoint_type) is C(s3) mongo_db_settings: description: - Additional settings for MongoDB endpoints. type: dict returned: when the I(endpoint_type) is C(mongodb) kinesis_settings: description: - Additional settings for Kinesis endpoints. type: dict returned: when the I(endpoint_type) is C(kinesis) kafka_settings: description: - Additional settings for Kafka endpoints. type: dict returned: when the I(endpoint_type) is C(kafka) elasticsearch_settings: description: - Additional settings for Elasticsearch endpoints. type: dict returned: when the I(endpoint_type) is C(elasticsearch) neptune_settings: description: - Additional settings for Amazon Neptune endpoints. type: dict returned: when the I(endpoint_type) is C(neptune) redshift_settings: description: - Additional settings for Redshift endpoints. type: dict returned: when the I(endpoint_type) is C(redshift) postgre_sql_settings: description: - Additional settings for PostgrSQL endpoints. type: dict returned: when the I(endpoint_type) is C(postgres) my_sql_settings: description: - Additional settings for MySQL endpoints. type: dict returned: when the I(endpoint_type) is C(mysql) oracle_settings: description: - Additional settings for Oracle endpoints. type: dict returned: when the I(endpoint_type) is C(oracle) sybase_settings: description: - Additional settings for Sybase endpoints. type: dict returned: when the I(endpoint_type) is C(sybase) microsoft_sql_server_settings: description: - Additional settings for Microsoft SQL Server endpoints. type: dict returned: when the I(endpoint_type) is C(sqlserver) i_b_m_db_settings: description: - Additional settings for IBM DB2 endpoints. type: dict returned: when the I(endpoint_type) is C(db2) doc_db_settings: description: - Additional settings for DocumentDB endpoints. type: dict returned: when the I(endpoint_type) is C(documentdb) redis_settings: description: - Additional settings for Redis endpoints. type: dict returned: when the I(endpoint_type) is C(redshift) N)camel_dict_to_snake_dict)is_boto3_error_code)AWSRetry)ansible_dict_to_boto3_tag_list)boto3_tag_list_to_ansible_dict)compare_aws_tags)AnsibleCommunityAWSModuleg?)retriesdelaybackoffc \|jdi|jdg}t|S)checks if the endpoint existsTagList)list_tags_for_resourcegetr) connectionparamstagss n/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/aws/plugins/modules/dms_endpoint.pydms_describe_tagsrZs1 -: , , 6v 6 : :9b ID )$ //c t |jdi|}|jddS#td$rYywxYw)NResourceNotFoundFault Endpointsr)describe_endpointsrr)rr endpointss rdms_describe_endpointsr asI1J11;F;  ==d ++ 6 7s &77ctd|g} t||g}sy|d} t||d }||d <|S#tjjtjj f$r!}t j|dYd}~sd}~wwxYw#tjjtjj f$r"}t j|d Yd}~|Sd}~wwxYw) rz endpoint-idNameValues)Filtersz$Failed to describe the DMS endpoint.msgNr EndpointArn ResourceArnrz(Failed to describe the DMS endpoint tags) dictr botocore exceptions ClientError BotoCoreErrormodule fail_json_awsr)rendpoint_identifierendpoint_filterreendpointrs rdescribe_endpointr6js 7J6KLOL*:?PQ  |HP -9PQ O    + +X-@-@-N-N OLQ$JKKL    + +X-@-@-N-N OPQ$NOO OPs,>B7B5BB7C2C--C2c ztjjdr t|S|jdi|S)z1deletes the DMS endpoint based on the EndpointArnwaitr)r0rrdelete_dms_endpointdelete_endpointclientrs rdms_delete_endpointr=~s7}} "6**%v%%///rc &|jdi|S)zcreates the DMS endpointr)create_endpointr;s rdms_create_endpointr@ "6 ! ! +F ++rc &|jdi|S)zupdates the endpointr)modify_endpointr;s rdms_modify_endpointrDrArc$|jdS)Nendpoint_deleted) get_waiter)r<s rget_endpoint_deleted_waiterrHs   / 00rc &|jdi|SNr)remove_tags_from_resourcer;s rdms_remove_tagsrLs +6 + + 5f 55rc &|jdi|SrJ)add_tags_to_resourcer;s r dms_add_tagsrOs &6 & & 0 00rc0tt|dS)zReturns boolean based on the existence of the endpoint :param endpoint: dict containing the described endpoint :return: bool r)boollen)r5s rendpoint_existsrSs H[)* ++rc t|}tjjdrt|jd i|}t |}|j d|gdgtjjdtjjdd|S|jd i|S#tjjtjjf$r!}tj|d Yd}~yd}~wwxYw) N)r(r8z endpoint-arnr"timeoutr )Delay MaxAttempts)r% WaiterConfigz#Failed to delete the DMS endpoint.r&r) r+r0rrr:rHr8r,r-r.r/r1)r endpoint_arn delete_arn delete_output delete_waiterr4s rr9r9s Kl3 ==  V $6J66DDM7 CM   "0\NKL'-}}'8'8'CTZTaTaTeTefoTpq  ! -:--; ; ;    + +X-@-@-N-N OKQ$IJJKsBB3!B337D *DD c ~ ttjjdtjjdtjjdtjjdtjjdtjjdtjjdtjjdtjjd  }tjjd r"tjjd |d <tjjd r"tjjd |d <tjjdr"tjjd|d<tjjdr"tjjd|d<tjjdr"tjjd|d<tjjdr"tjjd|d<tjjdr"tjjd|d<tjjdr"tjjd|d<tjjdr"tjjd|d<tjjdr"tjjd|d<tjjdr"tjjd|d<tjjd r"tjjd |d!<tjjd"r"tjjd"|d#<tjjd$r5tj tjjd$|d$<tjjd%r"tjjd%|d%<tjjd&r"tjjd&|d&<|S)'zJ Reads the module parameters and returns a dict :return: dict endpointidentifier endpointtype enginenameusernamepassword servernameport databasenamesslmode) EndpointIdentifier EndpointType EngineNameUsernamePassword ServerNamePort DatabaseNameSslModer(certificatearnCertificateArndmstransfersettingsDmsTransferSettingsextraconnectionattributesExtraConnectionAttributeskmskeyidKmsKeyIdrTagsserviceaccessrolearnServiceAccessRoleArnexternaltabledefinitionExternalTableDefinitiondynamodbsettingsDynamoDbSettings s3settings S3SettingsmongodbsettingsMongoDbSettingskinesissettingsKinesisSettingselasticsearchsettingsElasticsearchSettingsr8rUr )r+r0rrboolean)endpoint_parameterss rcreate_module_paramsrs !==,,-AB]]&&~6==$$\2"":."":.==$$\2 ]]  v &]]&&~6 !!), }}'-3]]->->}-MM* }})*06 0A0ABR0S,- }}./5;]]5F5FG\5]12 }}45;A==;L;LMh;i78 }}$*0--*;*;J*GJ' }} &,mm&7&7&?F# }}/06Y:Z:`:`:bfq:q rc|d} t}|jddt|fd|i|S#tjj tjj f$r"}tj|dYd}~yd}~wwxYw)Nr(rxzFailed to update DMS endpoint.)r'r) rpoprDr,r-r.r/r0r1)rr5arnrr4s rmodify_dms_endpointrs = !CU%' 64 ":I3I&II    + +X-@-@-N-N OUQ$DVTTUs)17B (BB c$tjjdd}|y|jdi}t||tjjd\}}|s|sytjry|jd} |rt ||||rt |}t|||y#tjjtjjf$r!}tj|d Yd}~yd}~wwxYw) NrF purge_tagsTr()r*TagKeys)r*rxz#Failed to update DMS endpoint tags.r&) r0rrr check_moderLrrOr,r-r.r/r1) rr5 desired_tags current_tags tags_to_addtags_to_removertag_listr4s r ensure_tagsrs==$$VT2L<<+L"2<v}}O`O`amOn"oK +  ,,} %CK  JC P 5kBH 8 D     + +X-@-@-N-N OKQ$IJJ Ks +B777D.D  Dc t}t|fi|S#tjjtjj f$r!}t j|dYd}~yd}~wwxYw)z Function to create the dms endpoint :param connection: boto3 aws connection :return: information about the dms endpoint object zFailed to create DMS endpoint.r&N)rr@r,r-r.r/r0r1)rrr4s rcreate_dms_endpointr<sfF%'":888    + +X-@-@-N-N OFQ$DEEFs7A0A++A0c ^td:idtddgddtddtd d g d tgd ddtdtddtdtddtdtdtddtddgdtdd d!td"tgd#d$d%td&td'tdd(tdd)tdd*tdd+tdd,tdd-tdd d.tdd/td}t|dddggddd ggddd-ggd-d0d.ggd-d0d/gggd1ad}d}tjj d}tj d2}t |tjj d}|dk(ry|rA|t||z}t|}|r"t||}|}|j d3}d}n!d4}nt|}|j d3}d}|r7t||d56}||d<n!|dk(r|rt||d5} | }d}d}nd}d7}t|xsidg8}tj|||9y);Nstatepresentabsent)choicesdefaultr^T)requiredr_sourcetarget)rr`) mysqloraclepostgresmariadbauroraredshifts3db2azuredbsybasedynamodbmongodb sqlserverF)rrrarb)no_logrcrdint)typerertrvrr+ resource_tags)raliasesrrQ)rrrprf)nonerequirez verify-caz verify-fullrryr{r}rrrrrrr8rUr True) argument_spec required_ifsupports_check_modedmsEndpointzEndpoint Already Existsr(r)zDMS Endpoint does not exist) ignore_list)changedr5r'r)r+AnsibleAWSModuler0rrr<r6rrrrrr9r exit_json) r exit_messagerr dmsclientr5params_changed updated_dmsrdelete_resultss rmainrJsB,Ix0)D,.,8X"67,! ,,-,.T"/,061,2u 3,4V5,6#'&7,8U#9,:v'8 9;,<VT2=,>v?,@LV\]A,B"VC,D!%E,F6*G,HV$I,J!f-K,L&)M,N&)O,P#/Q,Rvu -S,T% U,V% W,M\# i.!1 2 i, 0 h ) Vi[ ) Vi[ )  " FLG MM  g &E e$I FMM,=,=>R,STH   {9h7 7G+H5N1)XF * '++J78 .y9L#'' 3HG $YH]ansible_collections.community.aws.plugins.module_utils.modulesr rr+backoff_paramsjittered_backoffrr r6r=r@rDrHrLrOrSr9rrrrrr__name__rrrrsM ^ "_ B V\PffXxaq#6,^,0-0 ,^,,-,(,^,0-0,^,,-, ,^,,-, ,^,1-1,^,6-6,^,1-1,K"?D.U: F`KF zFG   sD**D32D3