Skip to content

Latest commit

 

History

History
executable file
·
101 lines (68 loc) · 2.44 KB

README.rst

File metadata and controls

executable file
·
101 lines (68 loc) · 2.44 KB

Python MySQL Replication Blinker

Join the chat at https://gitter.im/tarzanjw/python-mysql-binlog-to-blinker

Features

This package uses mysql-replication to read events from MySQL's binlog and send to blinker's signal.

  • binlog action level
  • rows level

It will send RowsEvent only.

Whenever a binlog event come, it will be dispatched into some signals:

  1. binlog_position_signal: 1 signal for the binlog current position
  2. binlog_signal: 1 signal for the binlog event.
  3. rows_signal: 1 signal for event's rows. 1 signal per row.

Signals

There are 5 signals:

  1. binlog_position_signal: sent whenever binlog event come to notify the current position of binlog stream
  2. binlog_signal: sent whenever binlog event come to notify the binlog event
  3. rows_inserted_signal, rows_updated_signal, rows_deleted_signal: sent on the event as their name

Connect to signals

To connect to a signal, you can use the signal instance or a decorator.

Suppose that you need to connect to write signal on table db0.table1:

from mysqlbinlog2blinker import signals

@signal.rows_updated.connect
def on_rows_updated_signal(table_name, rows, meta):
    pass

@signal.binlog_signal.connect
def on_binlog_signal(event, stream):
    pass

Signal publishing

To start publishing signals

from pymysqlblinker import start_publishing

start_publishing(
    {
        'host': 'localohst',
        'user': 'root',
    },
)

Replication

This package support a method to replicate from mysql database. It operates by keep memory at last binlog position. By default, it save to a file.

To make it, call:

from pymysqlblinker import start_replication

start_replication(
    {
        'host': 'localohst',
        'user': 'root',
    },
    ('/path/to/file/that/remember/binlog/position', 2),
)

Change logs

0.1

  • First version