巧用python-mysql-replication尋找pos點

假如線上采用了1主1從，而且沒有使用其他的高可用組件，而且也沒有開啟gtid復制，架構圖如下：

 

在圖1是master宕機了，在圖2時業務需要切換到slave寫入，假如此時你忘記了記錄slave的pos點，直接修改域名指向從庫，那么在master恢復以后如何接上復制？仔細看我上面的圖中標注了server-id，沒錯，我們可以從binlog中尋找server-id來找尋准確的pos點。

正常情況下slave的binlog里面帶入的是master的server-id，也就是4135，當slave開始寫入數據時，那么自己的server-id：123就會記錄在binlog里面。所以只需要在slave的binlog找到server-id為123開始的pos點時，就是原master恢復的時候需要指向的pos點。那么有兩種做法：

1. 自己解析binlog根據server-id尋找pos點。比如需要確認大概什么時候切換的，然后找到具體那個時間段的binlog開始解析。

2. 利用python-mysql-replication這個庫來找尋，至於python-mysql-replication是干嘛的，你可以自己度娘。

我這里簡單的實現了一下，代碼如下：

get_log_pos.py

#!/usr/bin/python
# -*- coding:utf-8 -*-

import sys
import datetime
from pymysqlreplication import BinLogStreamReader
from pymysqlreplication.row_event import DeleteRowsEvent, UpdateRowsEvent, WriteRowsEvent
from pymysqlreplication.event import RotateEvent,QueryEvent

reload(sys)
sys.setdefaultencoding('utf8')

conn_setting = {
    "host": "127.0.0.1",
    "port": 3306,
    "user": "xx",
    "passwd": "xx"
}

stream = BinLogStreamReader(
    connection_settings=conn_setting,
    server_id=9999,
    log_file="mysql-bin.000009",
    log_pos=4,
    resume_stream=True,
    blocking=True
)

for binlogevent in stream:
    if isinstance(binlogevent, RotateEvent):
        current_master_log_file=binlogevent.next_binlog
        print "Next binlog file: %s" % (current_master_log_file)
    if isinstance(binlogevent, WriteRowsEvent) or isinstance(binlogevent, DeleteRowsEvent) or isinstance(binlogevent, UpdateRowsEvent) or isinstance(binlogevent, QueryEvent):
        if binlogevent.packet.server_id == 123:
            current_datetime=datetime.datetime.fromtimestamp(binlogevent.packet.timestamp)
            print "數據寫入時間: %s" % (current_datetime)
            start_binlog_file=current_master_log_file
            start_binlog_pos=binlogevent.packet.log_pos
            print "開始的binlog文件: %s" % (start_binlog_file)
            print "開始的binlog pos點: %s" % (start_binlog_pos)
            exit(1)

輸出結果如下：

Next binlog file: mysql-bin.000001
數據寫入時間: 2020-05-11 11:56:09
開始的binlog文件: mysql-bin.000001
開始的binlog pos點: 146147

我們自己動手來解析binlog看看輸出的pos點是否准確：

 

 可以看見是准確無誤的。

總結：

線上一般會開啟gtid或者使用其他高可用組件進行切換。python-mysql-replication是個好東西，建議同學們都學習使用一下。