def lambda_handler()

in src/aws-lambda/segment-personalize-events-destination/segment-personalize-events-destination.py [0:0]
34 lines of code
13 McCabe index (conditional complexity)

def lambda_handler(event, context):    
    # In high volume applications, remove this code.
    logger.debug("Got event: " + json.dumps(event))

    # Segment will invoke your function once per event type you have configured
    # in the Personalize destination in Segment.
    try:
        if ('anonymousId' in event or 'userId' in event and 'properties' in event):
            # Make sure this event contains an itemId since this is required for the Retail Demo Store
            # dataset - you can also check for specific event names here if needed, and only pass the ones
            # that you want to use in the training dataset
            if (not 'productId' in event['properties']):
                logger.debug("Got event with no productId, discarding.")
                return

            logger.debug("Calling putEvents()")
            # Function parameters for put_events call.
            params = {
                'trackingId': personalize_tracking_id,
                'sessionId': event['anonymousId']
            }

            # If a user is signed in, we'll get a userId. Otherwise for anonymous 
            # sessions, we will not have a userId. We still want to call put_events
            # in both cases. Once the user identifies themsevles for the session, 
            # subsequent events will have the userId for the same session and 
            # Personalize will be able to connect prior anonymous to that user.
            if event.get('userId'):
                params['userId'] = event['userId']

            # YOU WILL NEED TO MODIFY THIS PART TO MATCH THE EVENT PROPS
            # THAT COME FROM YOUR EVENTS
            # 
            # Personalize needs the event identifier
            # that was used to train the model. In this case, we're using the 
            # product's productId passed through Segment to represent the itemId.
            #
            properties = { 'itemId': event['properties']['productId'] }

            # Build the event that we're sending to Personalize.  Note that Personalize
            # expects a specific event format
            personalize_event = {
                'eventId': event['messageId'],
                'sentAt': int(dp.parse(event['timestamp']).strftime('%s')),
                'eventType': event['event'],
                'properties': json.dumps(properties)
            }

            params['eventList'] = [ personalize_event ]

            logger.debug('put_events parameters: {}'.format(json.dumps(params, indent = 2)))
            # Call put_events
            response = personalize_events.put_events(**params)
        else:
            logger.debug("Segment event does not contain required fields (anonymousId and sku)")
    except ValueError as ve:
        logger.error("Invalid JSON format received, check your event sources.")
    except KeyError as ke:
        logger.error("Invalid configuration for Personalize, most likely.")
    except ClientError as ce:
        logger.error("ClientError: ")
        logger.error(ce.response['Error']['Code'])
        logger.error(ce.response['Error']['Message'])