#!/usr/bin/env ruby
require 'mysql2'

while 1
  client = Mysql2::Client.new(
    host: "",
    username: "",
    password: "")

  slave_status = client.query("show slave status;")

  if slave_status.first["Last_SQL_Errno"] == 1045
    client.query("CALL mysql.rds_skip_repl_error;")
  elsif slave_status.first["Slave_IO_Running"] == "No"
    client.query("CALL mysql.rds_start_replication;")
  end
 sleep 0.5
end