def upload_recording()

in gym_recording/storage_s3.py [0:0]


def upload_recording(directory, env_name, bucket):
    """
    Upload the recording saved in directory to bucket. Returns an s3://... URL
    """
    s3 = boto3.resource('s3')
    token = random_token(3)
    s3dir = os.path.join('recording', env_name, time.strftime('%Y-%m-%d_%H-%M-%S') + '_' + token)
    logger.info('Scanning %s', directory)
    b = s3.Bucket(bucket)
    for fn in os.listdir(directory):
        logger.info('Upload %s to %s', fn, os.path.join(s3dir, fn))
        b.upload_file(Filename=os.path.join(directory, fn), Key=os.path.join(s3dir, fn))
    return 's3://' + bucket + '/' + s3dir