David Ko nycdavid

Getting a CLI Shell to talk to the Faktory job server: cat <(echo "HELLO {\"wid\":\"4qpc2443vpvai\", \"labels\": [\"golang\"]}") - | nc localhost 7419

First, open a persistent connection via Netcat to the Faktory job server:

  $> cat <(echo "HELLO {\"wid\":\"4qpc2443vpvai\", \"labels\": [\"golang\"]}") - | nc localhost 7419
  #=> +HI {"v":"1"}
  #=> +OK

Then, PUSH a job to the end of the queue, with at least the minimum parameters of jid, jobtype, args:

	var EventEmitter = require('events').EventEmitter;

	// Create the initial Counter class, that emits the named event
	var Counter = function(init) {
	this.increment = function() {
	init++;
	this.emit('incrementer', init);
	}
	};

	var fs = require('fs'),
	path = '/path/to/sql/file'; // This represents a 4-5 gb file, way too large for a buffer in memory

	// Without Streams
	fs.readFile(path, 'utf8', function(err, data) { // This will fail because the size is too large for BUffer creation
	if (err) throw err;
	console.log(data);
	});

	// With Streams

	var fs = require('fs'),
	mongoClient = require('mongodb').MongoClient,
	foodsJson = JSON.parse(fs.readFileSync('./foods-2011-10-03.json'));

	mongoClient.connect('mongodb://127.0.0.1:27017/salud', function(err, db) {
	if (err) throw err;

	var collection = db.collection('foods-orig');

	foodsJson.forEach(function(el, i) {

	require "pry"

	class JwtAuthentication
	def initialize(app)
	@app = app
	end

	def call(env)
	req = Rack::Request.new(env)
	secret = ";Xsc2}M48w33xUvL7N>SG-V}OnU??BG&O&\|!az,)yHpLgm/\|g,kj^iVNwr<SFqy"

	require "csv"
	require "fileutils"

	TYPES = ["Instrumental", "Vocal"]

	GENRES = [
	"Ambient", "Americana", "Blues", "Childrens", "Classical",
	"Country", "Disco", "Easy Listening", "Electronica", "Folk",
	"Funk", "Gospel", "Hip Hop", "Holiday", "Jazz", "Latin",
	"Lounge", "None", "Orchestral", "Pop", "R&B", "Reggae",

	require "fileutils"

	class AvidMover
	Bin = Struct.new(:type, :genre, :filename)

	def initialize(project_path)
	@project_path = project_path
	end

	def move_bins