Skip to content

Instantly share code, notes, and snippets.

@ktilcu
Created February 8, 2018 21:51
Show Gist options
  • Select an option

  • Save ktilcu/c6140266276c66bdc769604b0966f2f5 to your computer and use it in GitHub Desktop.

Select an option

Save ktilcu/c6140266276c66bdc769604b0966f2f5 to your computer and use it in GitHub Desktop.
Firehose messages to queue
var Promise = require('bluebird');
var sqs = require('./queue');
var R = require('ramda');
var cli = require('cli');
var options = cli.parse({
dest: ['d', 'Destination queue url', 'string', undefined]
});
var string = "omgmomgomgomgomg ogmomgomgmogmog gomgomgomomgomgmg";
if (options.dest) {
var send = R.curry(sqs.sendMessages)(options.dest);
var messages = Array(100000).fill(string);
Promise.all(sqs.sendMessages(options.dest, messages))
.then(list => console.log('done'))
}else {
console.log('need queueUrls')
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment