@log_calls<EOL><INDENT>def create_bucket(self, source):<DEDENT>
s3url = S3URL(source)<EOL>message('<STR_LIT>', source)<EOL>if not self.opt.dry_run:<EOL><INDENT>resp = self.s3.create_bucket(Bucket=s3url.bucket)<EOL>if resp['<STR_LIT>']["<STR_LIT>"] == <NUM_LIT:200>:<EOL><INDENT>message('<STR_LIT>')<EOL><DEDENT>else:<EOL><INDENT>raise Failure('<STR_LIT>' % source)<EOL><DEDENT><DEDENT>
Use the create_bucket API to create a new bucket