djg07

{ 
   "Comment":"Transaction Processor State Machine Using SQS",
   "StartAt":"ProcessTransaction",
   "States":{ 
      "ProcessTransaction":{ 
         "Type":"Pass",
         "Next":"BroadcastToSqs"
      },
      "BroadcastToSqs":{ 
         "Type":"Task",

djg07

from __future__ import print_function

import json
import urllib
import boto3
import datetime

print('Loading message function...')

def process_refund(message, context):

djg07

{
  "Comment": "A simple AWS Step Functions state machine that automates a call center support session.",
  "StartAt": "ProcessTransaction",
  "States": {
    "ProcessTransaction": {
        "Type" : "Choice",
        "Choices": [ 
          {
            "Variable": "$.TransactionType",
            "StringEquals": "PURCHASE",

djg07

import json

print('Loading function')

def lambda_handler(event, context):
	#1. Parse out query string params
	transactionId = event['queryStringParameters']['transactionId']
	transactionType = event['queryStringParameters']['type']
	transactionAmount = event['queryStringParameters']['amount']

djg07

import json

print('Loading function')

def lambda_handler(event, context):
	print('------------------------')
	print(event)
	#1. Iterate over each record
	try:
		for record in event['Records']:

djg07

import json
import urllib.parse
import boto3

print('Loading function')

s3 = boto3.client('s3')

def lambda_handler(event, context):
    #1 - Get the bucket name