Tiny demo of using Amazon SQS to listen to notifications from Mechanical Turk. Run `npm install` to get dependencies.

aws_creds.json

{
  "accessKey": "your access key",
  "secretKey": "your secret key"
}

config.json

{
  "Turker": {
    "sqs_queue_url": "https://sqs.us-west-2.amazonaws.com/<some kind of ID>/<queue_name>"
  }
}

package.json

{
  "name": "sqs-test",
  "version": "0.0.1",
  "private": true,
  "dependencies": {
    "sqs": "~1.2.0",
    "mturk": "git+https://github.com/kleinschmidt/mturk.git#dfk/sendtestnotification"
  }
}

sqs_notification_test.js

var creds = require('./aws_creds.json');
var mturk = require('mturk')({ creds: creds, sandbox: true });

var config = require('./config.json');
var sqs_queue_url = config.Turker.sqs_queue_url;

var test_event_type = ['AssignmentAbandoned'];

var test_notification = {
    Destination: sqs_queue_url,
    Transport: 'SQS',
    Version: '2006-05-05',
    EventType: test_event_type
};

console.log('Sending Notification:\n', test_notification);

mturk.SendTestEventNotification({
    Notification: test_notification,
    TestEventType: test_event_type
}, console.log);

// receive messages

var sqs = require('sqs');
var queue = sqs({ access: creds.accessKey,
                  secret: creds.secretKey,
                  region: 'us-west-2' });

queue.pull('HLPTurk_test', function(message, callback) {
    console.log('Notification received:\n', message);
    // remove message from queue and pull again:
    callback();
});