Maxwellを利用し、MySQL／Auroraのバイナリログ（binlog）を読み込み、JSON形式で出力することが可能です。

Maxwellのダウンロード

以下のサイトからMaxwellをダウンロードできます。
https://github.com/zendesk/maxwell/releases/download/v1.10.8/maxwell-1.10.8.tar.gz

$ curl -sLo - https://github.com/zendesk/maxwell/releases/download/v1.10.8/maxwell-1.10.8.tar.gz | tar zxvf -

MySQL/Aurora側の設定

１．バイナリログ形式を「ROW」（行に基づくロギング）に変更する。

$ vi my.cnf

[mysqld]
server-id=1
log-bin=master
binlog_format=row

RDSを利用する場合、パラメータグループを変更します。

２．MySQL/AuroraにてMaxwellユーザを作成し、権限を付与します。

mysql> CREATE USER 'maxwell' identified by 'password';
mysql> GRANT SELECT, REPLICATION CLIENT, REPLICATION SLAVE on *.* to 'maxwell' identified by 'password';
mysql> GRANT ALL on maxwell.* to 'maxwell';

Maxwellの起動

以下のコマンドを利用し、STDOUT（標準出力）モードでMaxwellを起動します。

$ cd maxwell-1.10.8
$ bin/maxwell --user='maxwell' --password='password' --host='xxxxxxxx.rds.amazonaws.com' --producer=stdout

JSON形式binlogの出力

動作確認としてMySQL側以下のSQLを発行します。

mysql> INSERT INTO user_info VALUES (0, 'admin', 'password', 'admin@myApp.com');
Query OK, 1 row affected (0.01 sec)

mysql> update user_info set username='user', email='user@myApp.com';
Query OK, 1 row affected (0.02 sec)
Rows matched: 1  Changed: 1  Warnings: 0

mysql> delete from user_info;
Query OK, 1 row affected (0.01 sec)

以下のJSONが出力されます。

{"database":"test_db","table":"user_info","type":"insert","ts":1508315079,"xid":929,"commit":true,"data":{"id":0,"username":"admin","password":"password","email":"admin@myApp.com"}}
{"database":"test_db","table":"user_info","type":"update","ts":1508315160,"xid":1012,"commit":true,"data":{"id":0,"username":"user","password":"password","email":"user@myApp.com"},"old":{"username":"admin","email":"admin@myApp.com"}}
{"database":"test_db","table":"user_info","type":"delete","ts":1508315171,"xid":1018,"commit":true,"data":{"id":0,"username":"user","password":"password","email":"user@myApp.com"}}

引用