AWS Lambda Snowplow Analytics SDK example functions

snowplow-analytics-sdk-lambda-example-python2.py

from __future__ import print_function

import snowplow_analytics_sdk.event_transformer
import snowplow_analytics_sdk.snowplow_event_transformation_exception

import base64
import json

print('Loading function')

def lambda_handler(event, context):
    #print("Received event: " + json.dumps(event, indent=2))
    for record in event['Records']:
        # Kinesis data is base64 encoded so decode here
        payload = base64.b64decode(record['kinesis']['data'])
        print("Decoded payload: " + payload)
        try:
            print(snowplow_analytics_sdk.event_transformer.transform(payload))
        except snowplow_analytics_sdk.snowplow_event_transformation_exception.SnowplowEventTransformationException as e:
            for error_message in e.error_messages:
                print(error_message)
    return 'Successfully processed {} records.'.format(len(event['Records']))

snowplow-analytics-sdk-lambda-example-python3.py

import snowplow_analytics_sdk.event_transformer
import snowplow_analytics_sdk.snowplow_event_transformation_exception

import base64
import json

print('Loading function')

def lambda_handler(event, context):
    #print("Received event: " + json.dumps(event, indent=2))
    for record in event['Records']:
        # Kinesis data is base64 encoded so decode here
        payload = base64.b64decode(record['kinesis']['data'])
        print("Decoded payload: " + payload.decode('utf-8'))
        try:
            print(snowplow_analytics_sdk.event_transformer.transform(payload.decode('utf-8')))
        except snowplow_analytics_sdk.snowplow_event_transformation_exception.SnowplowEventTransformationException as e:
            for error_message in e.error_messages:
                print(error_message)
    return 'Successfully processed {} records.'.format(len(event['Records']))