aclouguru-statemachines

courses.csv

courses.py

import boto3
import awswrangler as wr

courses_bucket_name = 'datafeed-20230131'
s3_courses_csv_file_name = 'premium-courses.csv'

s3_client = boto3.client('s3')

def lambda_handler(event, context):
    
    print('Received event from Step Functions')
    print(event)
    response = {}
    response ['Message'] = 'Well done, this was a hard quiz and you nailed it! Here are your premium courses!'
    response['Score'] = event["Score"]
    
    csv_file = f's3://' + courses_bucket_name + '/' + s3_courses_csv_file_name
    df = wr.s3.read_csv(csv_file)
    response['Courses'] = df.to_dict()

    
    return response

lessons.csv

lessons.py

import boto3
import awswrangler as wr

lessons_bucket_name = 'datafeed-20230131'
s3_lessons_csv_file_name = 'premium-lessons.csv'

s3_client = boto3.client('s3')

def lambda_handler(event, context):
    
    print('Received event from Step Functions')
    print(event)
    response = {}
    response ['Message'] = "You didn't pass. Don't worry! Practice makes perfect. Here are premium lessons to keep you going!"
    response['Score'] = event["Score"]
    
    csv_file = f's3://' + lessons_bucket_name + '/' + s3_lessons_csv_file_name
    df = wr.s3.read_csv(csv_file)
    response['Lessons'] = df.to_dict()

    return response

statemachine.json

{
    "Comment": "Rewards Processor State Machine",
    "StartAt": "AssessStudent",
    "States": {
      "AssessStudent": {
        "Type": "Choice",
        "Choices": [
          {
            "Variable": "$.Score",
            "NumericGreaterThan": 74,
            "Next": "UnlockPremiumCourses"
          },
          {
            "Variable": "$.Score",
            "NumericLessThan": 75,
            "Next": "UnlockPremiumLessons"
          }
        ]
  },
  
      "UnlockPremiumCourses": {
        "Type": "Task",
        "Resource": "",
        "End": true
      },
      "UnlockPremiumLessons": 
      {
        "Type": "Task",
        "Resource": "",
        "End": true
      }
    }
  }