基于 MySQL Binlog 实现可配置的异构数据同步

[mysqld]log_bin=mysql-binbinlog-format=ROWserver_id=1

go get github.com/siddontang/go-mysql-elasticsearchcd $GOPATH/src/github.com/siddontang/go-mysql-elasticsearchmake

# MySQL address, user and password# user must have replication privilege in MySQL.my_addr = "127.0.0.1:3306"my_user = "root"my_pass = "123456"my_charset = "utf8"
# Set true when elasticsearch use https#es_https = false# Elasticsearch addresses_addr = "127.0.0.1:9200"# Elasticsearch user and password, maybe set by shield, nginx, or x-packes_user = ""es_pass = ""
# Path to store data, like master.info, if not set or empty,# we must use this to support breakpoint resume syncing.data_dir = "./var"
# Inner Http status addressstat_addr = "127.0.0.1:12800"stat_path = "/metrics"
# pseudo server id like a slaveserver_id = 1001
# mysql or mariadbflavor = "mysql"
# mysqldump execution path# if not set or empty, ignore mysqldump.mysqldump = "mysqldump"
# if we have no privilege to use mysqldump with --master-data,# we must skip it.#skip_master_data = false
# minimal items to be inserted in one bulkbulk_size = 128
# force flush the pending requests if we don't have enough items >= bulk_sizeflush_bulk_time = "200ms"
# Ignore table without primary keyskip_no_pk_table = false
# MySQL data source[[source]]schema = "wanber"
tables = ["item", "aaa", "xxx"]
[[rule]]schema = "a"table = "a"index = "xxx"type = "xxx"

[[rule]]schema = "b"table = "b"index = "xxx"type = "xxx"

./bin/go-mysql-elasticsearch -config=canal.toml