voldern / elasticsearch-writable-stream Goto Github PK

{
    "index": {
        "_index": "indexName",
        "_id": "recordId",
        "_type": "recordType",
        "status": 400,
        "error": {
          "type": "errorType",
          "reason": "errorReason",
          "caused_by": {
            "type": "causedType",
            "reason": "causedReason"
      }
   }
}

{
  index: 'name-of-index',
  type: 'recordType',
  id: 'recordId',
  parent: 'parentRecordType', // optional
  action: 'update', // optional (default: 'index')
  body: {
    name: 'Foo Bar'
  }
}

var ElasticsearchWritableStream = require('elasticsearch-writable-stream');

var stream = new ElasticsearchWritableStream(elasticsearchClient, {
  highWaterMark: 256,
  flushTimeout: 500
});

pg.connect(connectionString,function(err, client, done) {
--
  | if(err) throw err;
  | var query = new QueryStream('SELECT * FROM srt')
  | var streams = client.query(query)
  | //release the client when the stream is finished
  | streams.on('end', done)
  | streams.pipe(JSONStream.stringify()).pipe(stream)
  | })

{
  "gov": {
    "aliases": {},
    "mappings": {},
    "settings": {
      "index": {
        "creation_date": "1499854061799",
        "number_of_shards": "5",
        "number_of_replicas": "1",
        "uuid": "DwHKUuBIRdiZqCyORwfCDA",
        "version": {
          "created": "5050099"
        },
        "provided_name": "gov"
      }
    }
  }
}