'See :class:`UploadToS3`.'

@sync_performer
def _perform_upload_s3_key(self, dispatcher, intent):

    bucket = self.s3_buckets[intent.target_bucket]
    with intent.file.open() as source_file:
        content = source_file.read()
    content_type = intent.content_type
    if (content_type is not None):
        content = ContentTypeUnicode(content, content_type)
    bucket[intent.target_key] = content
