event emitter for archive data
safety elasticsearch bulk data broker with bucket and job queue
Writable stream to create bulk array.
