alexcasalboni

Bridge Function between Kinesis Streams and Step Functions

For each record read from the Kinesis Stream, a StepFunction state machine will be executed asynchronously.

Required Environment Variables

• region: the AWS region where your StepFunction state machine is defined.
• stateMachineArn: the ARN of the StepFunction state machine you want to execute.

Notes

alexcasalboni

import json
from base64 import b64decode, b64encode

# some useful constants
STATUS_OK = 'Ok'
STATUS_DROPPED = 'Dropped'
STATUS_FAIL = 'ProcessingFailed'

class DroppedRecordException(Exception):
    """ This exception can be raised if a record needs to be skipped/dropped """

alexcasalboni

DROP TRIGGER IF EXISTS TR_contacts_on_insert;
DELIMITER ;;
CREATE TRIGGER TR_contacts_on_insert
  AFTER INSERT ON Contacts
  FOR EACH ROW
BEGIN
  SELECT  NEW.email , NEW.fullname
  INTO @Email , @Fullname;
  lambda_async(
    'arn:aws:lambda:REGION:ACCOUNT_ID:function:SendEmailWithContact', 

alexcasalboni

const https = require("https");

/* FB configuration */
const FB_ACCESS_TOKEN = "EAF...DZD";
const FB_PSID = "facebookMessengerPsid";
const FB_REQUEST = {
    host: "graph.facebook.com",
    path: "/v2.6/me/messages?access_token=" + FB_ACCESS_TOKEN,
    method: "POST",
    headers: {

alexcasalboni

const AWS = require('aws-sdk');

const pricing = new AWS.Pricing({region: 'us-east-1'});

const main = async () => {

    const output = {};
 
    const prices = await pricing.getProducts({
        ServiceCode: "AmazonStates",

alexcasalboni

const http = require('http');
const AWS = require('aws-sdk');
const codepipeline = new AWS.CodePipeline();

exports.handler = async (event, context) => {
    // Retrieve event data
    const jobData = event["CodePipeline.job"];
    const jobId = jobData.id;
    const url = jobData.data.actionConfiguration.configuration.UserParameters;
    

alexcasalboni

def lambda_handler(event, context):
    name = event.get('name') or 'World'
    print("Name: %s" % name)
    return "Hello %s!" % name

alexcasalboni

// original: http://geon.github.io/programming/2016/03/03/dsxyliea
"use strict";
$(function(){

	var getTextNodesIn = function(el) {
	    return $(el).find(":not(iframe)").addBack().contents().filter(function() {
	        return this.nodeType == 3;
	    });
	};

alexcasalboni

AWS Lambda: Advanced Coding Session (slides)

Live demos:

1. Amazon API Gateway Access Control
2. Amazon Kinesis Streams processing
3. Amazon Cognito Sync trigger
4. AWS CloudFormation Custom Resources

alexcasalboni

# config
BUCKET_NAME=your-bucket-name
STACK_NAME=lambda-power-tuning-demo

# package
sam package --s3-bucket $BUCKET_NAME --template-file template.yml --output-template-file packaged.yml

# deploy
sam deploy --template-file packaged.yml --stack-name $STACK_NAME --capabilities CAPABILITY_AUTO_EXPAND CAPABILITY_IAM