in scheduler/scheduler.py [0:0]
def create_schedule_table(self):
dynamodb = boto3.resource('dynamodb')
table = dynamodb.create_table(
TableName=MESSAGE_SCHEDULE_DB,
KeySchema=[
{
'AttributeName': 'uuid',
'KeyType': 'HASH'
},
{
'AttributeName': 'person_name',
'KeyType': 'RANGE'
}
],
AttributeDefinitions=[
{
'AttributeName': 'uuid',
'AttributeType': 'S'
},
{
'AttributeName': 'person_name',
'AttributeType': 'S'
},
],
ProvisionedThroughput={
'ReadCapacityUnits': 1,
'WriteCapacityUnits': 1,
}
)
table.meta.client.get_waiter('table_exists') \
.wait(TableName=MESSAGE_SCHEDULE_DB)