pycore.py 文件源码

def s3_create_new_bucket(self, bucketname, bucket_location="sa-east-1", debug=False):

        record              = {
                            }

        results             = self.build_def_hash("Display Error", "Not Run", record)

        try:

            cur_keys        = self.aws_get_keys(debug)

            import boto 
            import boto.s3

            conn_s3         = boto.connect_s3(cur_keys["Key"], cur_keys["Secret"])
            bucket          = conn_s3.create_bucket(bucketname, location=bucket_location)

            if bucket:
                self.lg("Created Bucket(" + str(bucketname) + ")", 6)
                results     = self.build_def_hash("SUCCESS", "", {})
            else:
                results     = self.build_def_hash("Display Error", "Failed to Create Bucket(" + str(bucketname) + ")", {})

        except Exception,k:
            status          = "FAILED"
            err_msg         = "Unable to Create new S3 Bucket(" + str(bucketname) + ") with Ex(" + str(k) + ")"
            self.lg("ERROR: " + str(err_msg), 0)
            results         = self.build_def_hash("Display Error", err_msg, {})
        # end of try/ex

        return results
    # end of s3_create_new_s3_bucket