binlog2sql在MySQL8下的微调

$ cat ../requirements.txt  

PyMySQL==0.9.3
wheel==0.29.0
mysql-replication==0.21

def reversed_lines(fin):
    """Generate the lines of file in reverse order."""
    part = ''
    for block in reversed_blocks(fin):
        if PY3PLUS:
            block = block.decode("utf-8","ignore")  # 修改后的写法
            #block = block.decode("utf-8")   # 原先是这个写法
        for c in reversed(block):
            if c == '\n' and part:
                yield part[::-1]
                part = ''
            part += c
    if part:
        yield part[::-1]

import random


            cursor.execute("SELECT @@server_id")
            #self.server_id = cursor.fetchone()[0]
            self.server_id = random.randint(1024,4294967295)  # 随机造一个server_id连到主库去
            if not self.server_id:
                raise ValueError('missing server_id in %s:%s' % (self.conn_setting['host'], self.conn_setting['port']))