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
~

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
box api如何使用box Java SDK从图像文件中获取特定大小的缩略图?   java无法从JNA使用python cffi调用DLL中定义的函数   java在linux中通过Jar文件发送电子邮件   使用lucene+hibernate的java查询时间连接   java在带有循环的arrayList中设置值   java为什么ImageReader返回错误的BuffereImage?   c#TCP数据有时接收顺序错误且不完整   java如果发生IOException,该InputStream是否会正确关闭?   tcp在Java中,如果不使用IP,如何获取MAC地址?   java从批处理方法调用中收集结果   java Android Studio RecyclerView在滚动图像时严重滞后   java如何使用OOP进行retrofti调用?   记录FileAppender在Java中如何工作   与S3连接期间收到java异常   java找不到JNDI资源Tomcat 7