Aerospike Node.js v1 Aggregation Query Example

index.js

var aerospike = require('aerospike')
var config = {log: {level: 3} }
var ns = 'test'
var set = 'demo'

aerospike.client(config).connect(function (error, client) {
	client.put({ns: ns, set: set, key: 'k1'}, {i: 1}, function (error) {
		if (error && error.code !== 0) throw new Error(error.message)
		client.udfRegister('udf.lua', function (error) {
			if (error && error.code !== 0) throw new Error(error.message)
			client.udfRegisterWait('udf.lua', 50, function (error) {
				if (error && error.code !== 0) throw new Error(error.message)
				var statement = {
				  aggregationUDF: {module: 'udf', funcname: 'count'}
				}
				var query = client.query('test', 'demo', statement)
				var stream = query.execute() // returns a stream object
				stream.on('data', function (result) {
					console.info('the result is: %d', result)
				})
				stream.on('error', function (error) {
					console.error('error: %s (%d)', error.messge, error.code)
				})
				stream.on('end', function () {
					console.log('bye bye!')
					client.close()
				})
			})
		})
	})
})

package.json

{
  "dependencies": {
    "aerospike": "^1.0"
  }
}

udf.lua

function count(stream)
  local function mapper(rec)
    return 1
  end
  local function reducer(v1, v2)
    return v1 + v2
  end
  return stream : map(mapper) : reduce(reducer)
end