Vh4sddlmZmZmZeZdZdZdZddl Z ddl Z ddl m Z ddl mZddlmZmZmZmZmZmZdd lmZgZd Zdd Zdd Zdd ZddZddZddZddZ ddZ!dZ"e#dk(re"yy))absolute_importdivisionprint_functionu --- module: mysql_replication short_description: Manage MySQL or MariaDB replication description: - Manages MySQL or MariaDB server replication, replica, primary status, get and change primary host. author: - Balazs Pocze (@banyek) - Andrew Klychkov (@Andersson007) - Dennis Urtubia (@dennisurtubia) - Laurent Indermühle (@laurent-indermuehle) options: mode: description: - Module operating mode. Could be C(changeprimary) (CHANGE MASTER TO) - also works for MySQL 8.0.23 and later since community.mysql 3.10.0, C(changereplication) (CHANGE REPLICATION SOURCE TO) - only supported in MySQL 8.0.23 and later, C(getprimary) (SHOW MASTER STATUS), C(getreplica) (SHOW REPLICA STATUS), C(startreplica) (START REPLICA), C(stopreplica) (STOP REPLICA), C(resetprimary) (RESET MASTER) - supported since community.mysql 0.1.0, C(resetreplica) (RESET REPLICA), C(resetreplicaall) (RESET REPLICA ALL). type: str choices: - changeprimary - changereplication - getprimary - getreplica - startreplica - stopreplica - resetprimary - resetreplica - resetreplicaall default: getreplica primary_host: description: - Same as the C(MASTER_HOST) mysql variable. type: str aliases: [master_host] primary_user: description: - Same as the C(MASTER_USER) mysql variable. type: str aliases: [master_user] primary_password: description: - Same as the C(MASTER_PASSWORD) mysql variable. type: str aliases: [master_password] primary_port: description: - Same as the C(MASTER_PORT) mysql variable. type: int aliases: [master_port] primary_connect_retry: description: - Same as the C(MASTER_CONNECT_RETRY) mysql variable. type: int aliases: [master_connect_retry] primary_log_file: description: - Same as the C(MASTER_LOG_FILE) mysql variable. type: str aliases: [master_log_file] primary_log_pos: description: - Same as the C(MASTER_LOG_POS) mysql variable. type: int aliases: [master_log_pos] relay_log_file: description: - Same as mysql variable. type: str relay_log_pos: description: - Same as mysql variable. type: int primary_ssl: description: - Same as the C(MASTER_SSL) mysql variable. - When setting it to C(yes), the connection attempt only succeeds if an encrypted connection can be established. - For details, refer to L(MySQL encrypted replication documentation,https://dev.mysql.com/doc/refman/8.0/en/replication-solutions-encrypted-connections.html). - The default is C(false). type: bool aliases: [master_ssl] primary_ssl_ca: description: - Same as the C(MASTER_SSL_CA) mysql variable. - For details, refer to L(MySQL encrypted replication documentation,https://dev.mysql.com/doc/refman/8.0/en/replication-solutions-encrypted-connections.html). type: str aliases: [master_ssl_ca] primary_ssl_capath: description: - Same as the C(MASTER_SSL_CAPATH) mysql variable. - For details, refer to L(MySQL encrypted replication documentation,https://dev.mysql.com/doc/refman/8.0/en/replication-solutions-encrypted-connections.html). type: str aliases: [master_ssl_capath] primary_ssl_cert: description: - Same as the C(MASTER_SSL_CERT) mysql variable. - For details, refer to L(MySQL encrypted replication documentation,https://dev.mysql.com/doc/refman/8.0/en/replication-solutions-encrypted-connections.html). type: str aliases: [master_ssl_cert] primary_ssl_key: description: - Same as the C(MASTER_SSL_KEY) mysql variable. - For details, refer to L(MySQL encrypted replication documentation,https://dev.mysql.com/doc/refman/8.0/en/replication-solutions-encrypted-connections.html). type: str aliases: [master_ssl_key] primary_ssl_cipher: description: - Same as the C(MASTER_SSL_CIPHER) mysql variable. - Specifies a colon-separated list of one or more ciphers permitted by the replica for the replication connection. - For details, refer to L(MySQL encrypted replication documentation,https://dev.mysql.com/doc/refman/8.0/en/replication-solutions-encrypted-connections.html). type: str aliases: [master_ssl_cipher] primary_ssl_verify_server_cert: description: - Same as C(MASTER_SSL_VERIFY_SERVER_CERT) MySQL/MariaDB variable. - The module switch automatically to C(SOURCE_SSL_VERIFY_SERVER_CERT) for MySQL 8.0.23 and later. - Prior to community.mysql 3.14.0 C(false) had no effect. type: bool version_added: '3.5.0' primary_auto_position: description: - Whether the host uses GTID based replication or not. - Same as the C(MASTER_AUTO_POSITION) mysql variable. type: bool default: false aliases: [master_auto_position] primary_use_gtid: description: - Configures the replica to use the MariaDB Global Transaction ID. - C(disabled) equals MASTER_USE_GTID=no command. - To find information about available values see U(https://mariadb.com/kb/en/library/change-master-to/#master_use_gtid). - Available since MariaDB 10.0.2. choices: [current_pos, replica_pos, disabled] type: str version_added: '0.1.0' aliases: [master_use_gtid] primary_delay: description: - Time lag behind the primary's state (in seconds). - Same as the C(MASTER_DELAY) mysql variable. - Available from MySQL 5.6. - For more information see U(https://dev.mysql.com/doc/refman/8.0/en/replication-delayed.html). type: int version_added: '0.1.0' aliases: [master_delay] connection_name: description: - Name of the primary connection. - Supported from MariaDB 10.0.1. - Mutually exclusive with I(channel). - For more information see U(https://mariadb.com/kb/en/library/multi-source-replication/). type: str version_added: '0.1.0' channel: description: - Name of replication channel. - Multi-source replication is supported from MySQL 5.7. - Mutually exclusive with I(connection_name). - For more information see U(https://dev.mysql.com/doc/refman/8.0/en/replication-multi-source.html). type: str version_added: '0.1.0' fail_on_error: description: - Fails on error when calling mysql. type: bool default: false version_added: '0.1.0' notes: - Compatible with MariaDB or MySQL. - If an empty value for the parameter of string type is needed, use an empty string. attributes: check_mode: support: none extends_documentation_fragment: - community.mysql.mysql seealso: - module: community.mysql.mysql_info - name: MySQL replication reference description: Complete reference of the MySQL replication documentation. link: https://dev.mysql.com/doc/refman/8.0/en/replication.html - name: MySQL encrypted replication reference. description: Setting up MySQL replication to use encrypted connection. link: https://dev.mysql.com/doc/refman/8.0/en/replication-solutions-encrypted-connections.html - name: MariaDB replication reference description: Complete reference of the MariaDB replication documentation. link: https://mariadb.com/kb/en/library/setting-up-replication/ a # If you encounter the "Please explicitly state intended protocol" error, # use the login_unix_socket argument - name: Stop mysql replica thread community.mysql.mysql_replication: mode: stopreplica login_unix_socket: /run/mysqld/mysqld.sock - name: Get primary binlog file name and binlog position community.mysql.mysql_replication: mode: getprimary - name: Change primary to primary server 192.0.2.1 and use binary log 'mysql-bin.000009' with position 4578 community.mysql.mysql_replication: mode: changeprimary primary_host: 192.0.2.1 primary_log_file: mysql-bin.000009 primary_log_pos: 4578 - name: Change replication source to replica server 192.0.2.1 and use binary log 'mysql-bin.000009' with position 4578 community.mysql.mysql_replication: mode: changereplication primary_host: 192.0.2.1 primary_log_file: mysql-bin.000009 primary_log_pos: 4578 - name: Check replica status using port 3308 community.mysql.mysql_replication: mode: getreplica login_host: ansible.example.com login_port: 3308 - name: On MariaDB change primary to use GTID current_pos community.mysql.mysql_replication: mode: changeprimary primary_use_gtid: current_pos - name: Change primary to use replication delay 3600 seconds community.mysql.mysql_replication: mode: changeprimary primary_host: 192.0.2.1 primary_delay: 3600 - name: Start MariaDB replica with connection name primary-1 community.mysql.mysql_replication: mode: startreplica connection_name: primary-1 - name: Stop replication in channel primary-1 community.mysql.mysql_replication: mode: stopreplica channel: primary-1 - name: > Run RESET MASTER command which will delete all existing binary log files and reset the binary log index file on the primary community.mysql.mysql_replication: mode: resetprimary - name: Run start replica and fail the task on errors community.mysql.mysql_replication: mode: startreplica connection_name: primary-1 fail_on_error: true - name: Change primary and fail on error (like when replica thread is running) community.mysql.mysql_replication: mode: changeprimary fail_on_error: true z queries: description: List of executed queries which modified DB's state. returned: always type: list sample: ["CHANGE MASTER TO MASTER_HOST='primary2.example.com',MASTER_PORT=3306"] version_added: '0.1.0' N) AnsibleModule)CommandResolver)get_server_versionget_server_implementation mysql_connect mysql_drivermysql_driver_fail_msgmysql_common_argument_spec) to_nativecj|jd}|j||j}|S)NzSHOW MASTER STATUS)resolve_commandexecutefetchone)cursorcommand_resolverquery primarystatuss u/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/mysql/plugins/modules/mysql_replication.pyget_primary_statusr?s1  , ,-A BE NN5OO%M c~|r d|d|d}nd|z}|r|d|zz }|j||j}|S)NzSHOW  'z' STATUSzSHOW %s STATUS FOR CHANNEL '%s')rr)rconnection_namechanneltermrreplica_statuss rget_replica_statusr!GsJ)-? 4' $w.. NN5__&N rc<|r d|d|d}nd|z}|r|d|zz } tj||j|d}|S#tj$r }d}Yd}~|Sd}~wt $r-}|r|j dt|z d}Yd}~|Sd}~wwxYw) NzSTOP r'zSTOP %srTFzSTOP REPLICA failed: %smsgexecuted_queriesappendrr Warning Exception fail_jsonr) modulerrr fail_on_errorrrstoppedes r stop_replicar0Us"&8D  $w.. &u N    N     !:Yq\!I  J N #(ABA"" B."BBc<|r d|d|d}nd|z}|r|d|zz } tj||j|d}|S#tj$r }d}Yd}~|Sd}~wt $r-}|r|j dt|z d}Yd}~|Sd}~wwxYw) NRESET rr#zRESET %srTFzRESET REPLICA failed: %sr$r& r,rrrr-rrresetr/s r reset_replicar6ks#'9T! $w.. &u L    L     !;il!J  K L r1c<|r d|d|d}nd|z}|r|d|zz } tj||j|d}|S#tj$r }d}Yd}~|Sd}~wt $r-}|r|j dt|z d}Yd}~|Sd}~wwxYw) Nr3rz' ALLz RESET %s ALLrTFzRESET REPLICA ALL failed: %sr$r&r4s rreset_replica_allr8s'+_=% $w.. &u L    L     !?)A,!N  O L r1cJ|jd} tj||j|d}|S#tj $r }d}Yd}~|Sd}~wt $r>}|r/|j|jddt|d}Yd}~|Sd}~wwxYw)Nz RESET MASTERTFz failed: r$) rr'r(rr r)r*r+r)r,rrr-rr5r/s r reset_primaryr:s  , ,^ k(rd?}n|jd=}|jd!}|jd"}|jd@}t |jtAn%tjdBt jC|jdD}|jdE} t|| |||||ddF||G \}!}"t%!}$t'|!}%t)|%|$}&|!j+dL|%dMk(rdNdOlm}'ndNdOlm}'|'j3|!rdP}(n dQ}(|dRk(rdS}|dTk(rCt5|!|&})|)rdU|)vr dV|)vrd |)dW<n tddXY})|j6ddZt8i|)n|dk(rEt;|!|||(})|)rd[|)vsd\|)vrd |)d]<n tdd^_})|j6ddZt8i|)n|d`k(r4g}*i}+|&|*j=|&j?dadb|dc|&|*j=|&j?dddb|dc|&|*j=|&j?dedb|dc|%|*j=|&j?dfdg||%|*j=|&j?dhdg||&|*j=|&j?didb|dc| %|*j=|&j?djdg| |%|*j=|&j?dkdg|| |*j=dl| z| |*j=dm| z| I| r$|*j=dn|&j?dozn#|*j=dp|&j?doz| &|*j=|&j?dqdb| dc|&|*j=|&j?drdb|dc|&|*j=|&j?dsdb|dc|&|*j=|&j?dtdb|dc|&|*j=|&j?dudb|dc|I|r$|*j=dn|&j?dvzn#|*j=dp|&j?dvz|r#|*j=dn|&j?dwz||*j=dx|z tA|!|&|*||d |+d}<|j6ddZt8i|+n|d~k(rHtC||!||||(},|,d ur|j7dd t8nP|j7ddt8n6|dk(rHtE||!||||(}-|-d ur|j7dd t8n|j7ddt8n|dk(rFtG||!|&|}.|.d ur|j7dd t8n|j7ddt8n|dk(rHtI||!||||(}.|.d ur|j7dd t8nk|j7ddt8nQ|dk(rHtK||!||||(}.|.d ur|j7dd t8n|j7ddt8n|dk(rg}*i}+||*j=d|z||*j=d|z||*j=d|z||*j=d|z||*j=d|z||*j=d|z| |*j=d| z||*j=d|z| |*j=dl| z| |*j=dm| z| %| r|*j=dn|*j=d| |*j=d| z||*j=d|z||*j=d|z||*j=d|z||*j=d|z|I|r$|*j=dn|&j?dvzn#|*j=dp|&j?dvz|r|*j=d tM|!|*|d |+d}<|j6ddZt8i|+tjNdy#t$rm}#tjj!|r"|jdH|dIt#|#An!|jdJ|dKt#|#AYd}#~#8d}#~#wwxYw#t j$r}#t#|#|+dy<Yd}#~#Xd}#~#wt$r=}#|jt#|#dz|&j?d{d||*AYd}#~#d}#~#wwxYw#t j$r}#t#|#|+dy<Yd}#~#Fd}#~#wt$r+}#|jt#|#d|*AYd}#~#xd}#~#wwxYw)Nstr getreplica) getprimaryrJrE stopreplica startreplica resetprimary resetreplicaresetreplicaallrG)typedefaultchoicesboolFmaster_auto_position)rQrRaliases master_host)rQrV master_userTmaster_password)rQno_logrVint master_portmaster_connect_retrymaster_log_filemaster_log_pos)rQ master_ssl master_ssl_camaster_ssl_capathmaster_ssl_certmaster_ssl_keymaster_ssl_cipher) current_pos replica_posdisabledmaster_use_gtid)rQrSrV master_delay)rQrR)modeprimary_auto_position primary_host primary_userprimary_password primary_portprimary_connect_retryprimary_log_fileprimary_log_posrelay_log_file relay_log_pos primary_sslprimary_ssl_caprimary_ssl_capathprimary_ssl_certprimary_ssl_keyprimary_ssl_cipherprimary_ssl_verify_server_certprimary_use_gtid primary_delayrrr-rr) argument_specmutually_exclusiverkrmrnrorprqrrrsrtrurvrwrxryrzr{r|rl client_cert client_keyca_certcheck_hostnameconnect_timeout config_filer~r}rhnor-r$error)categorylogin_password login_user DictCursor) cursor_classrrzRunable to connect to database, check login_user and login_password are correct or z) has the credentials. Exception message: zunable to find z. Exception message: zSELECT VERSION()mariadbr) replicationREPLICASLAVErg slave_posrKFilePosition Is_PrimaryzLServer is not configured as mysql primary. Meaning: Binary logs are disabled)rr%queriesSlave_IO_RunningReplica_IO_Running Is_Replicaz)Server is not configured as mysql replica)rr%rE MASTER_HOSTz='r# MASTER_USERMASTER_PASSWORD MASTER_PORT=MASTER_CONNECT_RETRYMASTER_LOG_FILEMASTER_LOG_POS MASTER_DELAYzRELAY_LOG_FILE='%s'zRELAY_LOG_POS=%sz%s=1 MASTER_SSLz%s=0 MASTER_SSL_CAMASTER_SSL_CAPATHMASTER_SSL_CERTMASTER_SSL_KEYMASTER_SSL_CIPHERMASTER_SSL_VERIFY_SERVER_CERTMASTER_AUTO_POSITIONzMASTER_USE_GTID=%swarningz . Query == r?rAchangedrMzReplica started )r%rrz.Replica already started (Or cannot be started)rLzReplica stoppedzReplica already stoppedrNz Primary resetzPrimary already resetrOz Replica resetzReplica already resetrPrGzSOURCE_HOST='%s'zSOURCE_USER='%s'zSOURCE_PASSWORD='%s'zSOURCE_PORT=%szSOURCE_CONNECT_RETRY=%szSOURCE_LOG_FILE='%s'zSOURCE_LOG_POS=%szSOURCE_DELAY=%sz SOURCE_SSL=1z SOURCE_SSL=0zSOURCE_SSL_CA='%s'zSOURCE_SSL_CAPATH='%s'zSOURCE_SSL_CERT='%s'zSOURCE_SSL_KEY='%s'zSOURCE_SSL_CIPHER='%s'zSOURCE_AUTO_POSITION=1z(. Query == CHANGE REPLICATION SOURCE TO ignore)(r updatedictrparamsgetr r+r warningsfilterwarningsr)r r*ospathexistsrrr rrPansible_collections.community.mysql.plugins.module_utils.implementations.mariadbrNansible_collections.community.mysql.plugins.module_utils.implementations.mysqluses_replica_terminologyr exit_jsonr'r!r(rrEr=r0r:r6r8rG simplefilter)/rr,rkrmrnrorprqrrrsrtrurvrwrxryrzr{r|rlssl_certssl_keyssl_carrrr~r}rrr-rrrdb_connr/server_versionserver_implementationrimpl replica_termstatusrCresultr<r.r5s/ rmainrs .0M ul =! "#H^G_`u}o>u}o>5@Q?RSu}o>"8N7OP53D2EF%2B1CD'&f|n=0ABU5H4IJ53D2EF%@P?QRU5H4IJ'+'8536@Q?RT/?@%(% 6C"F#  * F == D==0L==0L}}%78==0L"MM*AB}}%78mm$56O]]#34NMM/2M-- .K]]#34N';<}}%78mm$56O';<%+]]3S%T""MM*AB}}]+HmmL)G ]]9 %F]]#34Nmm$56O-- .KMM/2M }}+, :!==);<mm$56OmmI&GMM/2M23,2F2FG]]#34N|,J k' NK(0'64Vb8GXfh(/N5f=&'"RTab c  % JJ,~= >  $ JJ)M9 :  " 6$4$D$D\$RRS 6$4$D$D\$RRS  % JJ$4$D$D_$UWef g  ) JJ$4$D$DEX$Y[mn o  ' JJ$4$D$DEV$WYij k  & JJ$4$D$DEU$VXgh i  ) JJ$4$D$DEX$Y[mn o ) 5- 6$4$D$DEd$eef 6$4$D$DEd$eef JJv 0 @ @AW XX Y  ' JJ+.>> ? C &"2C' R !y N D=   $HX  Y   !8%Qa  b  ffow Wcd D=   $HX  Y   !8%Qa  b " "!&&/7M[gh D=   $HX  Y   !8%Qa  b $ $  # JJ)L8 9  # JJ)L8 9  ' JJ-0@@ A  # JJ',6 7 , JJ03HH I  ' JJ-0@@ A  & JJ*_< =  $ JJ(=8 9  % JJ,~= >  $ JJ)M9 :  " >* >*  % JJ+n< =  ) JJ/2DD E  ' JJ-0@@ A  & JJ,> ?  ) JJ/2DD E ) 5- 6$4$D$DEd$eef 6$4$D$DEd$eef JJ/ 0 g fc7 3 !y>+ &   ansible_collections.community.mysql.plugins.module_utils.mysqlrr r r r r ansible.module_utils._textrr'rr!r0r6r8r:r=rErGr__name__rrrrsA@ L \E N  41 ,,, , V$r zFr