Python 如何使用 MySQL 8.2 读写分离？

在这篇文章中，我们将了解如何将 MySQL 8.2 的读写分离功能与 MySQL-Connector/Python 一起使用。

作者：Frederic Descamps，MySQL 社区经理

本文和封面来源：https://blogs.oracle.com/，爱可生开源社区翻译。

本文约 1200 字，预计阅读需要 4 分钟。

如您所知，MySQL 8.2 发布了最令人期待的功能之一：读写分离。

在这篇文章中，我们将了解如何将它与 MySQL-Connector/Python 一起使用。

架构

为了使用我们的 Python 程序，我们将使用 InnoDB Cluster。

以下是在 MySQL Shell 中查询 Cluster 的状态：

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）连接到集群并执行查询……。哦 ？！但为什么我们会直达主实例呢？

我们不应该是去访问只读实例（副本实例）之一吗？

autocommit

Connector/Python 默认禁用自动提交（请参阅 MySQLConnection.autocommit 属性）。并且读写分离功能必须启用自动提交才能正常工作。

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

cnx.autocommit = True

然后我们可以再次运行该程序：

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

太棒了，达到预期效果工作！

查询属性

现在让我们看看如何在主节点上强制执行查询。

MySQL Router 提供了使用查询属性来强制执行读/写拆分决策的可能性：router.access_mode。

在执行查询 ( cursor.execute(query) ) 之前添加以下行：

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

让我们再执行一次：

$ 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()

让我们执行它：

$ 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

我们可以看到没有错误，并且我们写入了主节点并从所有辅助节点读取。

请小心，如果在写入之前将 router.access_mode 的查询属性设置为 read_only（第 16 行），您将收到错误，因为副本节点上不允许写入：

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

事务

现在我们要玩一下事务。我们创建一个新脚本来执行多个事务：

  1. 自动提交中的读操作
  2. 事务中的读操作（默认情况下，这是读/写事务）
  3. 只读事务中的读操作
  4. 具有多次插入和回滚的事务

这是程序的源码：

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()

让我们执行脚本：

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

我们可以看到，第一个操作到达了副本实例，第二个操作（即事务）到达了主节点。

只读事务到达副本节点。

对于作为我们回滚事务一部分的多次写入，我们没有收到任何错误。

结论

我们已经看到将 MySQL Connector/Python 与 MySQL 8.2 读写分离一起用于 InnoDB Cluster 是多么容易。

享受通过 MySQL Connector / Python 使用 MySQL 读写分离！

更多技术文章，请访问：https://opensource.actionsky.com/

关于 SQLE

SQLE 是一款全方位的 SQL 质量管理平台，覆盖开发至生产环境的 SQL 审核和管理。支持主流的开源、商业、国产数据库，为开发和运维提供流程自动化能力，提升上线效率，提高数据质量。

SQLE 获取

类型地址
版本库https://github.com/actiontech/sqle
文档https://actiontech.github.io/sqle-docs/
发布信息https://github.com/actiontech/sqle/releases
数据审核插件开发文档https://actiontech.github.io/sqle-docs/docs/dev-manual/plugins/howtouse

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/169560.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Yolov8部署——vs2019遇到的问题

Yolov8部署——vs2019遇到的问题

Yolov8部署——vs2019遇到的问题 问题一： 默认库"LIBCMT"与其他库的使用冲突 解决方法：选择自己的项目右键属性——c/c——代码生成——运行库（多线程（/MT） 问题二： 文件包含在偏移0x18处开始…
阅读更多...
若依框架的介绍与基本使用（一起走进若依框架的世界）

若依框架的介绍与基本使用（一起走进若依框架的世界）

🎉🎉欢迎来到我的CSDN主页！🎉🎉 🏅我是君易--鑨，一个在CSDN分享笔记的博主。📚📚 🌟推荐给大家我的博客专栏《若依框架开发》。🎯🎯 &…
阅读更多...
【MySQL】聚合函数、group by、update、delete

【MySQL】聚合函数、group by、update、delete

聚合函数、group by、update、delete 前言正式开始update将孙悟空同学的数学成绩变更为 80 分将曹孟德同学的数学成绩变更为 60 分，语文成绩变更为 70 分将总成绩倒数前三的 3 位同学的数学成绩加上 30 分将所有同学的语文成绩更新为原来的 2 倍 delete删除孙悟空同…
阅读更多...
trzsz支持文件拖动到终端进行上传，类似lrzsz

trzsz支持文件拖动到终端进行上传，类似lrzsz

考虑到 LapTop -> Host 1 -> Host 2 -> Docker -> TMUX，使用scp或sftp命令不方便；使用rz和sz命令就会方便很多，但是却又与 TMUX 不兼容（备注：Tmux是一个终端复用工具，允许用户在一个终端窗口中…
阅读更多...
C语言前瞻

C语言前瞻

文章目录 C语言基础简介编译方式分布编译示例流程一步编译 代码运行运行结果展示实际代码 C语言基础简介 关于C语言的书籍，文章有很多。C的历史我不赘述，只讲C语言的基础语法和使用，帮助大家入门，同时也是自己学习过程的一个回顾。…
阅读更多...
Python的os.path.join()详解

Python的os.path.join()详解

当你需要构建文件路径时，os.path.join() 是一个很有用的方法。这个方法会根据你的操作系统使用正确的路径分隔符（例如，在 Windows 上是反斜杠 \，在类 Unix 系统上是正斜杠 /）来连接路径中的各个部分。这样你就可以确保…
阅读更多...
想要成为CSS大师？这些技巧是你必须知道的！

想要成为CSS大师？这些技巧是你必须知道的！

前言 CSS 是网页设计中不可或缺的一部分，掌握一些实用的 CSS 技巧，可以让你在设计中展现出更多的创意和个性。本文将介绍一些 CSS 技巧，帮助你提升自己的技能，成为一个真正的 CSS 大师。 1. 改变 input 自动填充的背景颜色 这段 …
阅读更多...
获取阿里云Docker镜像加速器

获取阿里云Docker镜像加速器

1、阿里云官网（www.aliyun.com）注册账号 2、打开“控制台首页” 控制台首页地址：https://home.console.aliyun.com/home/dashboard/ProductAndService 3、点击“概览->容器镜像服务 ACR” 4、打开“镜像工具->镜像加速器”页面&#x…
阅读更多...
数据集笔记：NGSIM （next generation simulation）

数据集笔记：NGSIM （next generation simulation）

1 数据集介绍 数据介绍s Next Generation Simulation (NGSIM) Open Data (transportation.gov) 数据地址：Next Generation Simulation (NGSIM) Vehicle Trajectories and Supporting Data | Department of Transportation - Data Portal 时间2005年到2006年间地…
阅读更多...
【Linux】 线程

【Linux】 线程

pthread_join: 获取线程返回值 #include <stdio.h> #include <stdlib.h> #include <pthread.h> #include <unistd.h> #include <string.h>/*** 测试 pthread_join* 阻塞等待一个子线程的退出&#xff0c;可以接收到某一个子线程调用pthread_ex…
阅读更多...
【Linux】Linux下的基础IO

【Linux】Linux下的基础IO

❤️前言 大家好&#xff01;今天这篇博客和大家聊一聊关于Linux下的基础IO。 正文 在阅读本篇博客之前&#xff0c;请大家先回顾一下C语言文件操作的一些方法&#xff0c;这里可以看看我之前记录的一些内容&#xff1a; 【C语言】C语言成长之路之文件操作_MO_lion的博客-CSD…
阅读更多...
elementui表格自定义指令控制显示哪些列可以拖动

elementui表格自定义指令控制显示哪些列可以拖动

Vue.directive(tableBorder, function (el, {value}) {// value允许传字符串数字和数组el.classList.add(z_table_hasBorder)let hasStyle el.querySelector(style)if(hasStyle){hasStyle.remove()}let style document.createElement(style)let str .z_table_hasBorder .el…
阅读更多...
Sentinel 热点规则 (ParamFlowRule)

Sentinel 热点规则 (ParamFlowRule)

Sentinel 是面向分布式、多语言异构化服务架构的流量治理组件&#xff0c;主要以流量为切入点&#xff0c;从流量路由、流量控制、流量整形、熔断降级、系统自适应过载保护、热点流量防护等多个维度来帮助开发者保障微服务的稳定性。 SpringbootDubboNacos 集成 Sentinel&…
阅读更多...
Ui自动化概念 + Web自动化测试框架介绍！

Ui自动化概念 + Web自动化测试框架介绍！

1.UI自动化测试概念:我们先明确什么是UI UI&#xff0c;即(User Interface简称UI用户界面)是系统和用户之间进行交互和信息交换的媒介 UI自动化测试: Web自动化测试和移动自动化测试都属于UI自动化测试&#xff0c;UI自动化测试就是借助自动化工具对程序UI层进行自动化的测试 …
阅读更多...
远程文件包含演示

远程文件包含演示

远程文件包含 基本介绍 受害机器 10.9.47.181 攻击者机器1 10.9.47.41 攻击者机器2 10.9.47.217 实现过程 受害者机器开启phpstudy 并且开启允许远程连接 攻击者机器1上有一个文件&#xff0c;内容是phpinfo(); 攻击者机器1提供web服务使得受害者机器能够访问到攻击者…
阅读更多...
Linux latin1字符集转成UTF-8

Linux latin1字符集转成UTF-8

latin1字符集&#xff0c;我用命令iconv转换后依旧乱码&#xff0c;但是本地用Notepad转成utf-8再入库数据&#xff0c;却是正常的 查看文件编码 vi WeakcoverReason_20231120.csv:set fileencoding使用编码转换命令&#xff0c;将latin1改成UTF-8 iconv -f latin1 -t UTF-8 W…
阅读更多...
Android Termux安装MySQL，内网穿透实现公网远程访问

Android Termux安装MySQL，内网穿透实现公网远程访问

文章目录 前言1.安装MariaDB2.安装cpolar内网穿透工具3. 创建安全隧道映射mysql4. 公网远程连接5. 固定远程连接地址 前言 Android作为移动设备&#xff0c;尽管最初并非设计为服务器&#xff0c;但是随着技术的进步我们可以将Android配置为生产力工具&#xff0c;变成一个随身…
阅读更多...
管家婆订货易在线商城任意文件上传漏洞复现

管家婆订货易在线商城任意文件上传漏洞复现

0x01 产品简介 管家婆订货易&#xff0c;帮助传统企业构建专属的订货平台&#xff0c;PC微信APP小程序h5商城5网合一&#xff0c;无缝对接线下的管家婆ERP系统&#xff0c;让用户订货更高效。支持业务员代客下单&#xff0c;支持多级推客分销&#xff0c;以客带客&#xff0c;拓…
阅读更多...
单链表相关面试题--5.将两个有序链表合并为一个新的有序链表并返回。新链表是通过拼接给定的两个链表的所有节点组成的

单链表相关面试题--5.将两个有序链表合并为一个新的有序链表并返回。新链表是通过拼接给定的两个链表的所有节点组成的

/* 解题思路&#xff1a; 此题可以先创建一个空链表&#xff0c;然后依次从两个有序链表中选取最小的进行尾插操作进行合并。 */ typedef struct ListNode Node; struct ListNode* mergeTwoLists(struct ListNode* l1, struct ListNode* l2){if(l1 NULL)return l2;else if(l2 …
阅读更多...
【监控系统】日志可视化监控体系ELK搭建

【监控系统】日志可视化监控体系ELK搭建

1.ELK架构是什么 ELK是ElasticsearchLogstashKibana的简称。 Elasticsearch是一个开源的分布式搜索和分析引擎&#xff0c;可以用于全文检索、结构化检索和分析&#xff0c;它构建在Lucene搜索引擎库之上&#xff0c;是当前使用较为广泛的开源搜索引擎之一。 Logstash是一个…
阅读更多...
最新文章

Copyright @ 2022~2023