Maxwell を使用して MySQL データをリアルタイムで同期する方法

root@xxx マクスウェル]# pwd
/usr/local/マックスウェル
[root@xxx maxwell]# wget https://github.com/zendesk/maxwell/releases/download/v1.19.5/maxwell-1.19.5.tar.gz
[root@xxx maxwell]# tar zxvf maxwell-1.19.5.tar.gz 
[root@xxx maxwell]# cd maxwell-1.19.5

[root@xxx mysql]# vi /usr/local/mysql/my.cnf 

[mysqld]
log-bin=mysql-bin #この行を追加 binlog-format=ROW #行モードを選択 server_id=1 #クラスター内の他のマシンの名前と同じにならない文字列をランダムに指定します。マシンが1台しかない場合は、自由に指定できます

mysql> '%log_bin%' のような変数を表示します
+---------------------------------+---------------------------------+
| 変数名 | 値 |
+---------------------------------+---------------------------------+
| log_bin | オン |
| log_bin_basename | /data/mysqldb/mysql-bin |
| log_bin_index | /data/mysqldb/mysql-bin.index |
| log_bin_trust_function_creators | オフ |
| log_bin_use_v1_row_events | オフ |
| sql_log_bin | オン |
+---------------------------------+---------------------------------+
セット6行（0.11秒）

#同期されたデータを持つユーザーyhreplを作成する
mysql> 'scgaopan' によって識別されるユーザー 'yhrepl'@'*' を作成します。 
クエリは正常、影響を受けた行は 0 行 (0.10 秒)

#このユーザー yhrepl には、同期する必要があるデータベース テーブルを操作する権限が必要です。mysql> 'scgaopan' によって識別される 'yhrepl'@'%' に test.* のすべての権限を付与します。 
クエリは正常、影響を受けた行は 0 行 (0.13 秒)

# yhrepl にデータを同期する権限を与えますmysql> grant select,replication client,replication slave on *.* to 'yhrepl'@'%' identified by 'scgaopan';
クエリは正常、影響を受けた行は 0 行 (0.10 秒)
# Maxwell には、schema_database オプションで指定されたデータベースに状態を保存する権限が必要です (デフォルトのデータベース名は maxwell です)
mysql> 'scgaopan' で識別される 'yhrepl'@'%' に maxwell.* のすべての権限を付与します。
クエリは正常、影響を受けた行は 0 行 (0.09 秒)

[root@xxx maxwell-1.19.5]# vi /usr/local/maxwell/maxwell-1.19.5/config.properties
#ログレベル log_level=DEBUG

プロデューサー=rabbitmq
デーモン=true

#監視対象データベース、mysql ユーザーに binlog の読み取りと新しいデータベース テーブルの作成権限が必要です host=47.105.110.xxx
ユーザー=yhrepl
パスワード=scgaopan

出力NULL=true
jdbc_options=自動再接続=true

#データベース内のどのテーブルが監視されますか? filter=exclude: *.*,include: test.AA

#replica_server_id および client_id の一意の識別子。クラスターの展開に使用されます。replica_server_id=64
client_id=テストID

#メトリックス_type=http
#メトリックス_slf4j_間隔=60
#http_port=8111
#http_diagnostic=true # デフォルトは false

#うさぎ
rabbitmq_host=47.105.110.xxx
ラビットmq_port=5672
rabbitmq_user=ゲスト
rabbitmq_pass=ゲスト
rabbitmq_virtual_host=/
rabbitmq_exchange=マックスウェル
rabbitmq_exchange_type=トピック
rabbitmq_exchange_durable=false
rabbitmq_exchange_autodelete=false
rabbitmq_routing_key_template=%db%.%テーブル%
rabbitmq_message_persistent=偽
rabbitmq_declare_exchange=true

[root@xxx maxwell-1.19.5]# ./bin/maxwell
#バックグラウンドで起動できます [root@xxx maxwell-1.19.5]# nohub ./bin/maxwell &

./bin/maxwell-bootstrap --database xhd --table xhd-sso --host 127.0.0.1 --user xiehd --password xiehd2018 --client_id maxwell_dev

./bin/maxwell --client_id maxwell_dev