From 126a59200a3140a638a7b0554075af09031ac536 Mon Sep 17 00:00:00 2001 From: Adam Cooke Date: Wed, 14 Jun 2017 09:30:01 +0100 Subject: [PATCH] add script to return current queue size (for monitoring) --- script/queue_size.rb | 7 +++++++ 1 file changed, 7 insertions(+) create mode 100644 script/queue_size.rb diff --git a/script/queue_size.rb b/script/queue_size.rb new file mode 100644 index 0000000..764c0a6 --- /dev/null +++ b/script/queue_size.rb @@ -0,0 +1,7 @@ +#!/usr/bin/env ruby +require_relative '../lib/postal/config' +require 'mysql2' + +client = Mysql2::Client.new(:host => Postal.config.main_db.host, :username => Postal.config.main_db.username, :password => Postal.config.main_db.password, :port => Postal.config.main_db.port, :database => Postal.config.main_db.database) +result = client.query("SELECT COUNT(id) as size FROM `queued_messages` WHERE retry_after IS NULL OR retry_after > ADDTIME(UTC_TIMESTAMP(), '30')") +puts result.to_a.first['size']