Python使用MySQL8.2讀寫分離實現(xiàn)示例詳解

更新時間：2023年11月21日 11:04:28 作者：愛可生開源社區(qū)

在這篇文章中,我們將了解如何將?MySQL?8.2?的讀寫分離功能與?MySQL-Connector/Python?一起使用的方法示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

引言

如您所知，MySQL 8.2 發(fā)布了最令人期待的功能之一：讀寫分離。

在這篇文章中，我們將了解如何將它與 MySQL-Connector/Python 一起使用。

架構

為了使用我們的 Python 程序，我們將使用 InnoDB Cluster。

以下是在 MySQL Shell 中查詢 Cluster 的狀態(tài)：

JS > cluster.status()
{
    "clusterName": "fred", 
    "defaultReplicaSet": {
        "name": "default", 
        "primary": "127.0.0.1:3310", 
        "ssl": "REQUIRED", 
        "status": "OK", 
        "statusText": "Cluster is ONLINE and can tolerate up to ONE failure.", 
        "topology": {
            "127.0.0.1:3310": {
                "address": "127.0.0.1:3310", 
                "memberRole": "PRIMARY", 
                "mode": "R/W", 
                "readReplicas": {}, 
                "replicationLag": "applier_queue_applied", 
                "role": "HA", 
                "status": "ONLINE", 
                "version": "8.2.0"
            }, 
            "127.0.0.1:3320": {
                "address": "127.0.0.1:3320", 
                "memberRole": "SECONDARY", 
                "mode": "R/O", 
                "readReplicas": {}, 
                "replicationLag": "applier_queue_applied", 
                "role": "HA", 
                "status": "ONLINE", 
                "version": "8.2.0"
            }, 
            "127.0.0.1:3330": {
                "address": "127.0.0.1:3330", 
                "memberRole": "SECONDARY", 
                "mode": "R/O", 
                "readReplicas": {}, 
                "replicationLag": "applier_queue_applied", 
                "role": "HA", 
                "status": "ONLINE", 
                "version": "8.2.0"
            }
        }, 
        "topologyMode": "Single-Primary"
    }, 
    "groupInformationSourceMember": "127.0.0.1:3310"
}

JS > cluster.listRouters()
{
    "clusterName": "fred", 
    "routers": {
        "dynabook::system": {
            "hostname": "dynabook", 
            "lastCheckIn": "2023-11-09 17:57:59", 
            "roPort": "6447", 
            "roXPort": "6449", 
            "rwPort": "6446", 
            "rwSplitPort": "6450", 
            "rwXPort": "6448", 
            "version": "8.2.0"
        }
    }
}

MySQL Connector/Python

Python 程序使用 MySQL-Connector/Python 8.2.0。

初始化測試腳本代碼：

import mysql.connector
cnx = mysql.connector.connect(user='python',
                              passowrd='Passw0rd!Python',
                              host='127.0.0.1',
                              port='6450')
cursor = cnx.cursor()
query = ("""select member_role, @@port port
            from performance_schema.replication_group_members
            where member_id=@@server_uuid""")
for (role, port) in cursor:
    print("{} - {}".format(role, port))
cursor.close()
cnx.close()

我們可以測試一下：

$ python test_router.py
PRIMARY - 3310

很好，我們可以使用讀/寫分離端口（6540）連接到集群并執(zhí)行查詢……。哦？！但為什么我們會直達主實例呢？

我們不應該是去訪問只讀實例（副本實例）之一嗎？

autocommit

Connector/Python 默認禁用自動提交（請參閱 MySQLConnection.autocommit 屬性）。并且讀寫分離功能必須啟用自動提交才能正常工作。

在第 8 行上方添加以下代碼：

cnx.autocommit = True

然后我們可以再次運行該程序：

$ python test_router.py
SECONDARY - 3320
$ python test_router.py
SECONDARY - 3330

太棒了，達到預期效果工作！

查詢屬性

現(xiàn)在讓我們看看如何在主節(jié)點上強制執(zhí)行查詢。

MySQL Router 提供了使用查詢屬性來強制執(zhí)行讀/寫拆分決策的可能性：router.access_mode。

在執(zhí)行查詢 ( cursor.execute(query) ) 之前添加以下行：

cursor.add_attribute("router.access_mode", "read_write")

讓我們再執(zhí)行一次：

$ python test_router.py
PRIMARY - 3310

router.access_mode 可接受的值為：

auto
read_only
read_write

測試 DML 語句

讓我們嘗試一些不同的東西，我們將向表中插入行。

我們將使用下表：

CREATE TABLE `t1` (
  `id` int unsigned NOT NULL AUTO_INCREMENT,
  `port` int DEFAULT NULL,
  `role` varchar(15) DEFAULT NULL,
  `timestamp` timestamp NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB ;

我們將使用以下 Python 腳本：

import mysql.connector
cnx = mysql.connector.connect(user='python',
                              password='Passw0rd!Python',
                              host='127.0.0.1',
                              port='6450',
                              database='test')
cnx.autocommit = True
cursor = cnx.cursor()
for i in range(3):
    query = ("""insert into t1 values(0, @@port, (
          select member_role
            from performance_schema.replication_group_members
            where member_id=@@server_uuid), now())""")
    cursor.execute(query)
cursor.close()
cnx.close()
for i in range(3):
    cnx = mysql.connector.connect(user='python',
                              password='Passw0rd!Python',
                              host='127.0.0.1',
                              port='6450',
                              database='test')
    cnx.autocommit = True
    cursor = cnx.cursor()
    query = ("""select *, @@port port_read from t1""")
    cursor.execute(query)
    for (id, port, role, timestamp, port_read) in cursor:
             print("{} : {}, {}, {} : read from {}".format(id,
                                             port,
                                             role,
                                             timestamp,
                                             port_read))
    cursor.close()
    cnx.close()

讓我們執(zhí)行它：

$ python test_router2.py
1 : 3310, PRIMARY, 2023-11-09 17:44:00 : read from 3330
2 : 3310, PRIMARY, 2023-11-09 17:44:00 : read from 3330
3 : 3310, PRIMARY, 2023-11-09 17:44:00 : read from 3330
1 : 3310, PRIMARY, 2023-11-09 18:44:00 : read from 3320
2 : 3310, PRIMARY, 2023-11-09 18:44:00 : read from 3320
3 : 3310, PRIMARY, 2023-11-09 18:44:00 : read from 3320
1 : 3310, PRIMARY, 2023-11-09 17:44:00 : read from 3330
2 : 3310, PRIMARY, 2023-11-09 17:44:00 : read from 3330
3 : 3310, PRIMARY, 2023-11-09 17:44:00 : read from 3330

我們可以看到?jīng)]有錯誤，并且我們寫入了主節(jié)點并從所有輔助節(jié)點讀取。

請小心，如果在寫入之前將 router.access_mode 的查詢屬性設置為 read_only（第 16 行），您將收到錯誤，因為副本節(jié)點上不允許寫入：

_mysql_connector.MySQLInterfaceError: The MySQL server is running with the --super-read-only option so it cannot execute this statement

事務

現(xiàn)在我們要玩一下事務。我們創(chuàng)建一個新腳本來執(zhí)行多個事務：

自動提交中的讀操作
事務中的讀操作（默認情況下，這是讀/寫事務）
只讀事務中的讀操作
具有多次插入和回滾的事務

這是程序的源碼：

import mysql.connector
cnx = mysql.connector.connect(user='python',
                              password='Passw0rd!Python',
                              host='127.0.0.1',
                              port='6450',
                              database='test')
cnx.autocommit = True
cursor = cnx.cursor()
query = ("""select member_role, @@port port
            from performance_schema.replication_group_members
            where member_id=@@server_uuid""")
cursor.execute(query)
for (role, port) in cursor:
    print("{} - {}".format(role, port))
cnx.start_transaction()
query = ("""select member_role, @@port port
            from performance_schema.replication_group_members
            where member_id=@@server_uuid""")
cursor.execute(query)
for (role, port) in cursor:
    print("{} - {}".format(role, port))
cnx.commit()
cnx.start_transaction(readonly=True)
query = ("""select member_role, @@port port
            from performance_schema.replication_group_members
            where member_id=@@server_uuid""")
cursor.execute(query)
for (role, port) in cursor:
    print("{} - {}".format(role, port))
cnx.commit()
cnx.start_transaction()
for i in range(3):
    query = ("""insert into t1 values(0, @@port, (
          select member_role
            from performance_schema.replication_group_members
            where member_id=@@server_uuid), now())""")
    cursor.execute(query)
cnx.rollback()
cursor.close()
cnx.close()

讓我們執(zhí)行腳本：

$ python test_router3.py
SECONDARY - 3320
PRIMARY - 3310
SECONDARY - 3320

我們可以看到，第一個操作到達了副本實例，第二個操作（即事務）到達了主節(jié)點。

只讀事務到達副本節(jié)點。

對于作為我們回滾事務一部分的多次寫入，我們沒有收到任何錯誤。

結論

我們已經(jīng)看到將 MySQL Connector/Python 與 MySQL 8.2 讀寫分離一起用于 InnoDB Cluster 是多么容易。

享受通過 MySQL Connector / Python 使用 MySQL 讀寫分離！更多關于Python MySQL8.2讀寫分離的資料請關注腳本之家其它相關文章！

您可能感興趣的文章:

python如何下載網(wǎng)絡文件到本地指定文件夾
這篇文章主要為大家詳細介紹了python如何實現(xiàn)下載網(wǎng)絡文件到本地指定文件夾,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學習一下
2025-05-05
python?rpyc客戶端調(diào)用服務端方法的注意說明
這篇文章主要介紹了python?rpyc客戶端調(diào)用服務端方法的注意說明，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2022-06-06
python 多進程和協(xié)程配合使用寫入數(shù)據(jù)
這篇文章主要介紹了python 多進程和協(xié)程配合使用寫入數(shù)據(jù)，幫助大家利用python高效辦公，感興趣的朋友可以了解下
2020-10-10
解決pycharm運行出錯,代碼正確結果不顯示的問題
今天小編就為大家分享一篇解決pycharm運行出錯,代碼正確結果不顯示的問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2018-11-11
python批量下載網(wǎng)站馬拉松照片的完整步驟
這篇文章主要給大家介紹了關于利用python批量下載網(wǎng)站馬拉松照片的完整步驟，文中通過示例代碼介紹的非常詳細，對大家的學習或工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2018-12-12
基于Keras的格式化輸出Loss實現(xiàn)方式
這篇文章主要介紹了基于Keras的格式化輸出Loss實現(xiàn)方式，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2020-06-06
python清除字符串中間空格的實例講解
今天小編就為大家分享一篇python清除字符串中間空格的實例講解，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2018-05-05
Python利用Selenium實現(xiàn)自動化分頁處理和信息提取
在 Web 自動化測試或數(shù)據(jù)抓取場景中,分頁處理是一個常見的需求,通過 Selenium,我們可以實現(xiàn)對多頁面內(nèi)容的自動遍歷,并從中提取所需的信息,本文將詳細介紹如何利用 Selenium 進行自動化分頁處理和信息提取,需要的朋友可以參考下
2025-06-06
Django模板標簽中url使用詳解(url跳轉到指定頁面)
這篇文章主要介紹了Django模板標簽中url使用詳解(url跳轉到指定頁面)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2020-03-03
Python button選取本地圖片并顯示的實例
今天小編就為大家分享一篇Python button選取本地圖片并顯示的實例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2019-06-06