mysql binlog到闪烁信号
pymysqlblinker的Python项目详细描述
python mysql replication blinker
==
features
--
从mysql的binlog读取事件并发送到blinker的信号。
-binlog操作级别
-schema级别
-table级别
-row级别
binlog信号:binlog事件的1个信号。
架构信号:事件架构的1个信号。表信号:事件表的1个信号。行信号:事件行的1+信号。每行1个信号。
代码块:
binlog event->;binlog signal->;schema signal->;table signal-->;row signals
因此,假设一个事件带有schema=foo,table=bar,并且它更新了
2行。这些信号将被发送:
+——————+———————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————124;事件(rowsevent)|
+————+——————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————|
+——+——+——————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————|
+——+——+————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————代码块::python
@signals.on_table_write('db0','table1')
def subscriber1(rows,schema,table):
传递
信号发布
----
开始发布信号
。代码块::python
它通过在最后一个binlog位置保留内存来操作。默认情况下,它保存到一个文件中。
要进行此操作,请调用:
。代码块::python
复制是发布具有记住最后一个binlog位置的能力。对于第一次运行,它将从当前binlog的结尾开始。
1.1.1
~
==
features
--
-binlog操作级别
-schema级别
-table级别
-row级别
binlog信号:binlog事件的1个信号。
架构信号:事件架构的1个信号。表信号:事件表的1个信号。行信号:事件行的1+信号。每行1个信号。
代码块:
binlog event->;binlog signal->;schema signal->;table signal-->;row signals
因此,假设一个事件带有schema=foo,table=bar,并且它更新了
2行。这些信号将被发送:
+——————+———————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————124;事件(rowsevent)|
+————+——————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————|
+——+——+——————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————|
+——+——+————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————代码块::python
@signals.on_table_write('db0','table1')
def subscriber1(rows,schema,table):
传递
信号发布
----
开始发布信号
。代码块::python
它通过在最后一个binlog位置保留内存来操作。默认情况下,它保存到一个文件中。
要进行此操作,请调用:
。代码块::python
复制是发布具有记住最后一个binlog位置的能力。对于第一次运行,它将从当前binlog的结尾开始。
1.1.1
~