gistfile1.txt

$ watch -n1 ruby notus.rb

Every 1.0s: ruby notus.rb                                                       Thu Jun 28 09:08:11 2012

[1, 1, 0, 0, 0, 0, 0, 1, 0, 1, 0, 1, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 1, 0, 0, 0, 0, 1, 0, 0]
8   
30667
Sending individual alerts

notus.rb

#!/usr/bin/env ruby

require 'rubygems'
require 'redis'
require 'chronic'

@redis = Redis.new(:host => "localhost", :port => 6379)
@redis.hincrby("events", Time.now.to_i, rand(2)) # generate some dummy events

def frequency_of_events_since(time)
  range = (Chronic.parse(time).to_i .. Time.now.to_i)
  window = range.to_a

  @redis.hmget("events", *window).map {|i| i.to_i}
end

frequency = frequency_of_events_since("30 seconds ago")
threshold = 10
p frequency
p sum = frequency.inject(:+)
p @redis.hgetall("events").size

if sum >= threshold then
  puts "Merging alerts"
else
  puts "Sending individual alerts"
end