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

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

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

{
  "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

from __future__ import print_function

import json
import urllib
import boto3
import datetime

print('Loading message function...')

def process_refund(message, context):

djg07

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

djg07

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

djg07

#Talk python to me

import json
import boto3

s3 = boto3.client('s3')

def lambda_handler(event, context):
   bucket = 'aws-simplified-transactions'
   key = 'transactions.json'

djg07

S3 PutObject Role
---
{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "VisualEditor0",
            "Effect": "Allow",
            "Action": "s3:PutObject",
            "Resource": "*"

djg07

import json
import boto3
from boto3.dynamodb.conditions import Key

def lambda_handler(event, context):
	client = boto3.resource('dynamodb')
	table = client.Table('Transactions')

	#1. Example - Get Item By Id