python-mysql-replication.py

import json
import boto3
from pymysqlreplication import BinLogStreamReader
from pymysqlreplication.row_event import (
  DeleteRowsEvent,
  UpdateRowsEvent,
  WriteRowsEvent,
)



def main():
  
  stream = BinLogStreamReader(
    connection_settings= {
      "host": "127.0.0.1",
      "port": 3306,
      "user": "root",
      "passwd": "root"},
    server_id=100,
    blocking=True,
    resume_stream=True,
    only_events=[DeleteRowsEvent, WriteRowsEvent, UpdateRowsEvent])

  for binlogevent in stream:
    for row in binlogevent.rows:
      event = {"schema": binlogevent.schema,
      "table": binlogevent.table,
      "type": type(binlogevent).__name__,
      "row": row
      }

      print(json.dumps(event, sort_keys=True, default=str))

if __name__ == "__main__":
   main()