Module: OpenDNS::DNSDB::Traffic

Included in:
OpenDNS::DNSDB
Defined in:
lib/opendns-dnsdb/dnsdb/traffic.rb

Constant Summary collapse

DEFAULT_DAYS_BACK = 
7

Instance Method Summary collapse

Instance Method Details

#daily_traffic_by_name(names, options = { }) ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/opendns-dnsdb/dnsdb/traffic.rb', line 11

def daily_traffic_by_name(names, options = { })
  names_is_array = names.kind_of?(Enumerable)
  names = [ names ] unless names_is_array
  multi = query_multi
  date_end = options[:start] || Date.today
  date_end_s = CGI::escape("#{date_end.year}/#{date_end.month}/#{date_end.day}/23")
  days_back = options[:days_back] || DEFAULT_DAYS_BACK
  date_start = date_end - days_back
  date_start += 1 unless date_start == date_end
  date_start_s = CGI::escape("#{date_start.year}/#{date_start.month}/#{date_start.day}/00")
  date_end, date_start = date_start, date_end if date_start > date_end
  queries_traffic = { }
  names.each do |name|
    name0 = name.gsub(/^www[.]/, '')
    url_traffic = "/appserver/?v=1&function=domain2-system&domains=#{name0}" +
    "&locations=&start=#{date_start_s}&stop=#{date_end_s}"
    query_traffic = query_handler(url_traffic)
    multi.queue(query_traffic)
    queries_traffic[name] = query_traffic
  end
  multi.run
  responses = { }
  queries_traffic.each_pair do |name, query|
    obj = MultiJson.load(query.response.body)
    tc = obj['response']
    tc = tc.group_by { |x| x[0].split('/')[0...3].join('/') }
    tc.each_key do |date_s|
      tc[date_s] = tc[date_s].inject(0) { |a, x| a + x[1] }
    end
    responses[name] = tc.values
  end
  responses = Response::HashByName[responses]
  responses = responses.values.first unless names_is_array
  responses        
end

#high_pass_filter(names_ts, options) ⇒ Object 



64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/opendns-dnsdb/dnsdb/traffic.rb', line 64

def high_pass_filter(names_ts, options)
  names_ts_is_hash = names_ts.kind_of?(Hash)
  names_ts = { x: names_ts } unless names_ts_is_hash
  responses = { }
  cutoff = options[:cutoff]
  names_ts.each_pair do |name, ts|
    responses[name] = ts.map { |x| x < cutoff ? 0.0 : x }
  end
  responses = Response::HashByName[responses]
  responses = responses.values.first unless names_ts_is_hash
  responses        
end

#relative_standard_deviation(names_ts) ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/opendns-dnsdb/dnsdb/traffic.rb', line 47

def relative_standard_deviation(names_ts)
  names_ts_is_hash = names_ts.kind_of?(Hash)
  names_ts = { x: names_ts } unless names_ts_is_hash
  responses = { }
  names_ts.each_pair do |name, ts|
    mean = ts.mean
    if mean <= 0.0
      responses[name] = 0.0
    else
      responses[name] = ts.standard_deviation / mean * 100.0
    end
  end
  responses = Response::HashByName[responses]
  responses = responses.values.first unless names_ts_is_hash
  responses
end