Published April 21, 2016 © GPL3+

Anger Management

IoT button to know our buddy, Anger, using AWS IoT to track how often we get angry, if certain threshold reach, let us calm.

IntermediateFull instructions provided1,435

Things used in this project

Hardware components

Raspberry Pi 1 Model B+

SparkFun Pushbutton switch 12mm

Software apps and online services

Amazon Web Services AWS DynamoDB

Amazon Web Services AWS IoT

Amazon Web Services AWS Lambda

Story

How often you get angry? or affected by other emotion?

This project was inspired by movie "Inside Out", we like to have a happy life but shit happens, life is unpredictable and full of ups and downs that we cannot control. But certainly we can control how we deal with these negative feeling and at least make ourselves angry-free.

Wiki page suggests a treatment called "anger diary writing", by writing down the negative feeling allow us to understand and re-evaluate the situation, take time to calm and to learn how to deal with it. The page said this treatment is useful for children but I think it is also good for adult except we are too busy but situation doesn't allow us to write. So I build this project backed by AWS platform so we can easily track our angry, get relief and get back to work calmly. We can also review the number of anger on AWS platform at a later time and get professional advise when necessary.

Raspberry Pi was used in this project which connect to Amazon platform using NodeJS aws-iot-device-sdk, once the button was pressed, it will publish to AWS IOT. Lambda is called based on the rule and store the time info in DynamoDB, if the number of press reach threshold, Lambda will publish request to Raspberry PI to play a song so user can aware it was enough for today and he should now listen to the music and stay clam. So this project involves AWS IoT, Lambda and DynamoDB service.

To Setup AWS IoT node and Raspberry PI (NodeJS), I followed the doc at http://docs.aws.amazon.com/iot/latest/developerguide/iot-device-sdk-node.html.

DynamoDB setup is easy, just create a empty table to store the data with default setting. Remember to "enable" the table once created, otherwise it won't work and you may want to press the angry button now. :D

caption (optional)

Create a new Lambda function, and give permission.

(The code is available at software section, modify the IoT endpoint path so Lambda can push the "play" request to Raspberry Pi.)

Now, back to AWS IoT to create a rule so Lambda function is called whenever the button was pressed, it should be like this:

caption (optional)

Now, wire and create your own Anger button with Raspberry Pi. Install additional required NodeJS libraries (sudo npm install sleep onoff node-aplay) and run my NodeJS code.

If nothing goes wrong, you can press the button anytime when you feel angry to track it, and we can login to AWS DynamoDB to review the number of press and timestamp when it was pressed, for example, we can filter the result based on date:

(as future improvement, we can build also user interface with AWS S3 to easily present the data or sending daily summary of press using AWS SNS service)

I hope this can help you to know your best friend, Anger.

Stay calm and be happy!

Code

var AWS = require('aws-sdk');
var url = require('url');
var dynamodb = new AWS.DynamoDB();

exports.handler = function(event, context) {
    var tableName = "angar";
    var datetime = new Date().getTime().toString();
    var date = new Date();
    var tmp = date.getFullYear()+""+date.getMonth()+1+""+date.getDate()+"-"+date.getHours() + date.getMinutes() + date.getSeconds();
    
    dynamodb.putItem({
            "TableName": tableName,
            "Item": {
                "date": {
                    "S": tmp
                }, 
                "timedate": {
                    "N": datetime
                }
            }
        }, function(err, data) {
            if (err) {
                context.fail('ERROR: Dynamo failed: ' + err);
            } else {
                console.log('Dynamo Success: ' + JSON.stringify(data, null, '  '));
                context.succeed('SUCCESS');
            }
        });

    tmp = "" + date.getFullYear()+""+date.getMonth()+1+""+date.getDate();
    var params = {
        "TableName": "angar",
        "ScanFilter": {
            "date": {
                "AttributeValueList": [{"S": tmp }],
                "ComparisonOperator": "BEGINS_WITH"
            },
        },
        "Limit": "10"
    };
    dynamodb.scan(params, function(err, result) {
        if (err) {
            console.log(err); 
        } else {
            if (result.Count>9){
                var client = new AWS.IotData({endpoint: 'xxxxx.iot.xxxxx.amazonaws.com'});
                client.publish({
                payload: JSON.stringify(result),
                    topic: 'topic/play'
                }, function(err, data){
                if(err) {
                    context.fail(err);
                } else {
                    context.succeed({published:true});
                }
                });
            }
        }
    });
}

var awsIot = require('aws-iot-device-sdk');
var Gpio = require('onoff').Gpio;
var sleep = require('sleep');
var Sound = require('node-aplay');

var thingShadows = awsIot.thingShadow({
   keyPath: 'private.pem.key',
  certPath: 'certificate.pem.crt',
    caPath: 'root-CA.crt',
  clientId: 'raspberrypi',
    region: 'ap-northeast-1'
});

function exit() {
  high.unexport();
  button.unexport();
  process.exit();
}

var State = {"state":{"reported":{"connected":"yes"}}};

var clientTokenUpdate;

thingShadows.on('connect', function() {
    thingShadows.register( 'raspberrypi' , { ignoreDeltas: true, persistentSubscribe: true } );
    thingShadows.subscribe('topic/play');
    setTimeout( function() {
       clientTokenUpdate = thingShadows.update('raspberrypi', State  );
       }, 2000 );
    });

thingShadows.on('status',
    function(thingName, stat, clientToken, stateObject) {
       console.log('received '+stat+' on '+thingName+': '+
                   JSON.stringify(stateObject));
    });

thingShadows.on('message', function(topic, payload) {
    if(topic.indexOf('play') > -1) {
	    new Sound('~/song.wav').play();
	  }
  });

high = new Gpio(23, 'out');
high.writeSync(1);
button = new Gpio(24, 'in', 'rising');

button.watch(
    function(err, value) {
       delete State['version'];
       delete State['connected'];
       State["state"]["reported"]["button"] = 1;
       buttonStateResponse = thingShadows.update('raspberrypi', State);
       thingShadows.publish('topic/pressed', value.toString());
    });
process.on('SIGINT', exit);

Credits

Taiyuk

3 projects • 7 followers

Anger Management

Things used in this project

Hardware components

Software apps and online services

Story

Schematics

Schematics

Raw materials

Raw materials

Code

Lambda function

NodeJS client

Credits

Taiyuk

Comments

Embed the widget on your own site

Anger Management

Anger Management

Things used in this project

Hardware components

Software apps and online services

Story

Schematics

Schematics

Raw materials

Raw materials

Code

Lambda function

NodeJS client

Credits

Taiyuk

Comments

Related channels and tags