これはなにか
RDSのSlowLogをSlackに通知したかった。
AWSのAPIで download-db-log-file-portion があったが通知するには使い勝手が悪かったので
MySQLのテーブルにSlowLogを保存して、それをFluentdからSELECT & Clear をすることにした。
この記事はMysqlの設定なので、他のDBの場合はよしなに変更してください。
使ったもの
fluent-plugin-slack : https://github.com/sowawa/fluent-plugin-slack
fluent-plugin-rds-slowlog : https://github.com/kenjiskywalker/fluent-plugin-rds-slowlog
RDSの設定
-
Parameter Group
- slow_query_log : 1
- long_query_time : ?秒(ご自由に)
- log_output : TABLE
-
ユーザー作成
- CREATE USER hoge;
- SET PASSWORD FOR 'hoge'@'%' = PASSWORD('hogehoge');
- GRANT select ON mysql.slow_log TO hoge;
- GRANT EXECUTE ON PROCEDURE mysql.rds_rotate_slow_log TO hoge;
Slackの設定
- IncomingWebHookでWebhookURL取得
Fluentdの設定
<source>
type rds_slowlog
tag rds.slow_query
host ****************************.ap-northeast-1.rds.amazonaws.com
username hoge
password hogehoge
</source>
<match rds.slow_query>
type buffered_slack
webhook_url [WebhookURL]
channel [channel名]
username [通知ユーザー名]
color danger
message "start_time:%s\r\nuser_host:%s\r\nquery_time:%s\r\nlock_time:%s\r\nrows_sent:%s\r\nrows_examined:%s\r\ndb:%s\r\nlast_insert_id:%s\r\ninsert_id:%s\r\nserver_id:%s\r\nsql_text:%s"
message_keys start_time,user_host,query_time,lock_time,rows_sent,rows_examined,db,last_insert_id,insert_id,server_id,sql_text
flush_interval 1m
</match>
通知されたもの
最後に
そのまま使うと危険なので適当に変更してください。