Experimenting with map-reduce / aggregation in RethinkDB

rethinkdb_requests_second.js

// successful jobs grouped by type maped by req/sec
r.db('qm_production').table('jobs')
  .filter({'last_event_type': 'success'})
  .map(function(doc) {
    return {
      'ds_type': doc('ds_type'),
      'last_event_type': doc('last_event_type'),
      'res_sec': doc("stats_event_response_count").div(doc('stats_run_duration')),
      'req_sec': doc("stats_event_request_count").div(doc('stats_run_duration'))
    };
  })
  .group('ds_type')
  .avg('res_sec')