weatherstation_data_populate.py 文件源码

def c_table (c): # create dynamo DB tables
    try:
        print "INFO :: Creating %s Table....." % c['TableName']
        db_r.create_table(**c)
        print "INFO :: Waiting for completion..."
        db_r.Table(c['TableName']).wait_until_exists()
    except botocore.exceptions.ClientError as e:
        if e.response['Error']['Code'] == "ResourceInUseException":
            print "INFO :: WeatherstationInc %s Table exists, deleting ...." % c['TableName']
            db_r.Table(c['TableName']).delete()
            print "INFO :: Waiting for delete.."
            db_r.Table(c['TableName']).wait_until_not_exists()
            c_table (c)
        else:
            print "Unknown Error"
#------------------------------------------------------------------------------