RecordStream - Aerospike Node.js Client API Documentation

RecordStream

Stream of database records (full or partial) returned by Query or Scan operations.

Note: Record stream currently does not support Node.js' Stream#pause and Stream#resume methods, i.e. it always operates in flowing mode. That means data is read from the Aerospike database and provided to your application as fast as possible. If no data event handlers are attached, then data will be lost.

Aborting a Query/Scan

A query or scan operation can be aborted by calling the RecordStream#abort method at any time. It is no possible to continue a record stream, once aborted.

Constructor

new RecordStream()

Source:

record_stream.js, line 22

Example

const Aerospike = require('aerospike')

// INSERT HOSTNAME AND PORT NUMBER OF AEROSPIKE SERVER NODE HERE!
var config = {
  hosts: '192.168.33.10:3000',
  // Timeouts disabled, latency dependent on server location. Configure as needed.
  policies: {
    scan : new Aerospike.ScanPolicy({socketTimeout : 0, totalTimeout : 0}),
   }
}

Aerospike.connect(config, (error, client) => {
  if (error) throw error
  var recordsSeen = 0
  var scan = client.scan('test', 'demo')
  var stream = scan.foreach()

  stream.on('error', (error) => {
    console.error(error)
    throw error
  })
  stream.on('data', (record) => {
    recordsSeen++
    console.log(record)
    if (recordsSeen > 1000) {
      stream.abort() // We've seen enough!
    }
  })
  stream.on('end', () => {
    console.info(stream.aborted ? 'scan aborted' : 'scan completed')
    client.close()
  })
})