如何用python-mysql-replication获取当前binlog文件名并恢复读取位置？

1. API是否提供事件对应的binlog文件名？ #

是的，python-mysql-replication的事件对象本身就包含对应的binlog文件名。你可以通过binlogevent.log_file或者binlogevent.packet.log_file获取（不同版本可能略有差异，两种都可以尝试）。修改你的代码如下：

stream = BinLogStreamReader(
    connection_settings=mysql_connection,
    server_id=server_id,
    blocking=True,
    resume_stream=True,
    only_events=[DeleteRowsEvent, WriteRowsEvent, UpdateRowsEvent],
)

for binlogevent in stream:
    print('Current binlog file:', binlogevent.log_file)
    print('Current position:', binlogevent.packet.log_pos)
    # 你的事件处理逻辑...

这样就能同时拿到文件名和位置，重启时可以用这两个参数恢复消费。

2. 从指定位点恢复消费的建议 #

如果因为特殊情况无法通过事件获取文件名，或者需要更可靠的恢复机制，推荐以下方案：

• 持久化完整位点信息：每次处理完事件后，将当前的log_file和log_pos写入本地文件、Redis或数据库等持久化存储。重启进程时，读取这两个值，初始化BinLogStreamReader时指定log_file和log_pos参数，并将resume_stream设为False，示例：

  # 从持久化存储读取上次的位点
  last_log_file = 'mysql-bin.000001'
  last_log_pos = 12345
  
  stream = BinLogStreamReader(
      connection_settings=mysql_connection,
      server_id=server_id,
      blocking=True,
      resume_stream=False,
      log_file=last_log_file,
      log_pos=last_log_pos,
      only_events=[DeleteRowsEvent, WriteRowsEvent, UpdateRowsEvent],
  )
  

• 定期同步主库位点：可以在消费进程中定期执行SHOW MASTER STATUS SQL命令，获取当前主库的binlog文件名和位置，作为兜底的位点记录。不过注意这个是主库的最新位点，不是你消费到的位点，所以仅作为备份或异常恢复时的参考。

• 利用MySQL的复制位点记录：如果你的server_id唯一且固定，开启resume_stream=True后，python-mysql-replication会自动向MySQL注册该server_id的复制位点，重启时会从上次断开的位置继续消费。但这种方式依赖MySQL自身的复制元数据，不如自己持久化位点灵活可控，比如跨机器重启进程时可能出现问题。

内容的提问来源于stack exchange，提问作者Weston Sankey