in src/create_activity/app.py [0:0]
def lambda_handler(message, context):
if ('body' not in message or
message['httpMethod'] != 'POST'):
return {
'statusCode': 400,
'headers': {},
'body': json.dumps({'msg': 'Bad Request'})
}
table_name = os.environ.get('TABLE', 'Activities')
region = os.environ.get('REGION', 'us-east-1')
aws_environment = os.environ.get('AWSENV', 'AWS')
if aws_environment == 'AWS_SAM_LOCAL':
activities_table = boto3.resource(
'dynamodb',
endpoint_url='http://dynamodb:8000'
)
else:
activities_table = boto3.resource(
'dynamodb',
region_name=region
)
table = activities_table.Table(table_name)
activity = json.loads(message['body'])
params = {
'id': str(uuid.uuid4()),
'date': str(datetime.timestamp(datetime.now())),
'stage': activity['stage'],
'description': activity['description']
}
response = table.put_item(
TableName=table_name,
Item=params
)
print(response)
return {
'statusCode': 201,
'headers': {},
'body': json.dumps({'msg': 'Activity created'})
}