guzzler:流式传输 MySQL 二进制日志并使用 Scala actor(RabbitMQ、Kafka)使用它们

时间:2024-07-31 14:31:06
【文件属性】:

文件名称:guzzler:流式传输 MySQL 二进制日志并使用 Scala actor(RabbitMQ、Kafka)使用它们

文件大小:2.26MB

文件格式:ZIP

更新时间:2024-07-31 14:31:06

Scala

Guzzler:流式传输 MySQL 二进制日志并对其采取行动 Guzzler 已被取代 Guzzler 允许您从 master 流式传输 MySQL 二进制日志,并允许您使用 Scala actor(消费者)对它们进行操作。 消费者可以在 guzzler.conf 中与其余所需参数一起配置。 Guzzler 包含一个 RabbitMQ 使用者,它将查询推送到 RabbitMQ 服务器以供使用。 Guzzler 可以通过远程 SSH 接口启动、停止、重启和查找二进制日志。 Guzzler 处理连接问题或随机断开连接,并尝试从中断的地方继续。 Guzzler 本身或 RabbitMQ 背后的消费者都可以分析查询(Guzzler 提供基于 JSqlParser 的 SQL 查询解析器),并可能决定更新计数器、触发事件、日志消息等。 示例 SSH 会话(尚无身份验证): -=[ Wel


【文件预览】:
guzzler-master
----project()
--------Build.scala(2KB)
----src()
--------main()
----scripts()
--------rmq_consumer.py(824B)
----lib()
--------jsqlparser-0.7.0.jar(140KB)
--------kafka-0.7.jar(838KB)
--------zookeeper-3.3.3.jar(1000KB)
--------log4j-1.2.15.jar(383KB)
--------jopt-simple-3.2.jar(52KB)
--------zkclient-0.1.0.jar(95KB)
----config()
--------akka.conf(9KB)
----README.md(1KB)
----guzzler-example.conf(770B)

网友评论