Python cbException.cbException函数代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Python›Python编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Python中pycb.cbException.cbException函数的典型用法代码示例。如果您正苦于以下问题：Python cbException函数的具体用法？Python cbException怎么用？Python cbException使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了cbException函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: work

    def work(self):
        request = self.request
        exists = self.user.exists(self.bucketName)

        if self.acl:
            if not exists:
                raise cbException('NoSuchBucket')
            (perms, data_key) = self.user.get_perms(self.bucketName)
            ndx = perms.find("W")
            if ndx < 0:
                raise cbException('AccessDenied')

            rc = self.grant_public_permissions(self.bucketName, self.objectName)
            if not rc:
                xml = self.request.content.read()
                pycb.log(logging.INFO, "xml %s" % (xml))
                grants = parse_acl_request(xml)
                for g in grants:
                    pycb.log(logging.INFO, "granting %s to %s" % (g[2], g[0]))
                    self.user.grant(g[0], self.bucketName, perms=g[2])
        else:
            if exists:
                raise cbException('BucketAlreadyExists')
            self.user.put_bucket(self.bucketName)
            self.grant_public_permissions(self.bucketName, self.objectName)

        self.set_common_headers()
        self.setHeader(request, 'Content-Length', 0)
        self.setHeader(request, 'Connection', 'close')
        self.setHeader(request, 'Location', "/" + self.bucketName)
        self.setResponseCode(request, 200, 'OK')

        self.finish(request)

开发者ID:Annatara，项目名称:nimbus，代码行数:33，代码来源:cbRequest.py

示例2: work

 def work(self):
     pycb.log(logging.INFO, "===== def work of cbRequest.py")
     exists = self.user.exists(self.bucketName)
     if not exists:
         raise cbException('NoSuchBucket')
     (perms, data_key) = self.user.get_perms(self.bucketName)
     ndx = perms.find("w")
     if ndx < 0:
         raise cbException('AccessDenied')
     self.deleteIt(data_key)

开发者ID:xxy-php，项目名称:code，代码行数:10，代码来源:cbRequest.py

示例3: parse_acl_request

def parse_acl_request(xml):
    dom = parseString(xml)
    grant_a = dom.getElementsByTagName("Grant")
    grants = []
    users = {}

    for g in grant_a:
        email = getText(g.getElementsByTagName("DisplayName")[0].childNodes)
        id = getText(g.getElementsByTagName("ID")[0].childNodes)
        perm_set = g.getElementsByTagName("Permission")

        perms = ""
        for p in perm_set:
            requested_perm = getText(p.childNodes)

            if requested_perm not in perms_strings:
                raise cbException('InvalidArgument')

            pv = perms_strings[requested_perm]
            ndx = perms.find(pv)
            if ndx < 0:
                perms = perms + pv

        if id in users.keys():
            (i, e, p) = users[id]
            perms = perms + p
        users[id] = (id, email, perms)

    return users.values()

开发者ID:oldpatricka，项目名称:nimbus，代码行数:29，代码来源:cbRequest.py

示例4: init

    def __init__(self, data_key, access="r", openIt=True):
        self.fname = data_key
        self.metafname = data_key + ".meta"
        self.data_key = data_key
        self.blockSize = pycb.config.block_size
        self.hashValue = None
        self.delete_on_close = False
        self.md5er = hashlib.md5()
        self.access = access

        self.seek_count = 0

        if not openIt:
            return

        try:
            # this allows head to be very fast
            if access == "r":
                mFile = open(self.metafname, 'r')
                self.hashValue = mFile.readline()
                mFile.close()
        except:
            pass

        try:
            self.file = open(self.fname, access)
        except OSError, (OsEx):
            if OsEx.errno == errno.ENOENT:
               raise cbException('NoSuchKey')

开发者ID:Annatara，项目名称:nimbus，代码行数:29，代码来源:cbPosixBackend.py

示例5: seek

 def seek(self, offset, whence=None):
     pycb.log(logging.INFO, "===== def seek of cbPosixBackend.py")
     self.seek_count = self.seek_count + 1
     pycb.log(logging.WARNING, "Someone is seeking %s %d :: %d" % (self.fname, offset, self.seek_count), tb=traceback)
     if self.seek_count > 1:
         raise cbException('InternalError')
     return self.file.seek(offset, whence)

开发者ID:xxy-php，项目名称:code，代码行数:7，代码来源:cbPosixBackend.py

示例6: get_uf

 def get_uf(self, bucketName, objectName=None):
     file = self.get_file_obj(bucketName, objectName)
     if file == None:
         pycb.log(logging.INFO, "b:o not found %s:%s" % (bucketName, str(objectName)))
         raise cbException('NoSuchKey')
     uf = UserFile(file, self.user)
     return uf

开发者ID:oldpatricka，项目名称:nimbus，代码行数:7，代码来源:cbAuthzSecurity.py

示例7: init

    def __init__(self, data_key, access="r", openIt=True):
#       file like stuff
        #self.closed = True
        #self.encoding = 
        #self.errors
        #self.mode
        #self.name
        #self.newlines
        #self.softspace

        self.fname = data_key
        self.metafname = data_key + ".meta"
        self.data_key = data_key
        self.blockSize = 1024*512
        self.hashValue = None
        self.delete_on_close = False
        self.md5er = hashlib.md5()

        if not openIt:
            return

        try:
            mFile = open(self.metafname, 'r')
            self.hashValue = mFile.readline()
            mFile.close()
        except:
            pass

        try:
            self.file = open(self.fname, access)
        except OSError, (OsEx):
            if OsEx.errno == errno.ENOENT:
               raise cbException('NoSuchKey')

开发者ID:oldpatricka，项目名称:nimbus，代码行数:33，代码来源:cbPosixBackend.py

示例8: delete_bucket

 def delete_bucket(self, bucketName):
     try:
         file = self.get_file_obj(bucketName)
         kids = file.get_all_children()
         if len(list(kids)) != 0:
             raise cbException('BucketNotEmpty')
         file.delete()
     finally:
         self.db_obj.commit()

开发者ID:oldpatricka，项目名称:nimbus，代码行数:9，代码来源:cbAuthzSecurity.py

示例9: init

 def __init__(self, alias_name, con_str):
     self.db_obj = DB(con_str=con_str)
     alias = User.find_alias(self.db_obj, alias_name, pynimbusauthz.alias_type_s3)
     a_list = list(alias)
     if len(a_list) < 1:
         raise cbException('AccessDenied')
     # pick the first one, hmmm XXX
     self.alias = a_list[0]
     self.user = self.alias.get_canonical_user()

开发者ID:oldpatricka，项目名称:nimbus，代码行数:9，代码来源:cbAuthzSecurity.py

示例10: check_permissions

    def check_permissions(self):
        pycb.log(logging.INFO, "===== def check_permissions of cbRequest.py")
        srcExists = self.user.exists(self.srcBucketName, self.srcObjectName)
        if not srcExists:
            raise cbException('NoSuchKey')
        (perms, src_data_key) = self.user.get_perms(self.srcBucketName, self.srcObjectName)
        # make sure that we can read the source
        ndx = perms.find("r")
        if ndx < 0:
            raise cbException('AccessDenied')

        # make sure we can write to the destination
        dstExists = self.user.exists(self.dstBucketName, self.dstObjectName)

        (bperms, bdata_key) = self.user.get_perms(self.dstBucketName)
        ndx = bperms.find("w")
        if ndx < 0:
            raise cbException('AccessDenied')

        dst_data_key = None
        dst_size = 0
        if dstExists:
            (perms, dst_data_key) = self.user.get_perms(self.dstBucketName, self.dstObjectName)
            ndx = perms.find("w")
            if ndx < 0:
                raise cbException('AccessDenied')

            (dst_size, ctm, md5) = self.user.get_info(self.dstBucketName, self.dstObjectName)
        (src_size, self.src_ctm, self.src_md5) = self.user.get_info(self.srcBucketName, self.srcObjectName)

        # check the quota
        remaining_quota = self.user.get_remaining_quota()
        if remaining_quota != User.UNLIMITED:
            if remaining_quota < src_size - dst_size:
                pycb.log(logging.INFO, "user %s did not pass quota.  file size %d quota %d" % (self.user, src_size, remaining_quota))
                raise cbException('AccountProblem')

        # if we get to here we are allowed to do the copy
        if dst_data_key == None:
            self.dst_file = self.bucketIface.put_object(self.dstBucketName, self.dstObjectName)
        else:
            self.dst_file = self.bucketIface.get_object(dst_data_key)
        self.dst_file.set_delete_on_close(True)
        self.src_file = self.bucketIface.get_object(src_data_key)

开发者ID:xxy-php，项目名称:code，代码行数:44，代码来源:cbRequest.py

示例11: request_object_factory

    def request_object_factory(self, request, user, path, requestId):
        pycb.log(logging.INFO, "===== def request_object_factory of cumulus.py")
        pycb.log(logging.INFO, "path %s" % (path))
        # handle the one service operation
        if path == "/":
            if request.method == 'GET':
                cbR = cbGetService(request, user, requestId, pycb.config.bucket)
                return cbR
            raise cbException('InvalidArgument')

        (bucketName, objectName) = path_to_bucket_object(path)
        init_redirector(request, bucketName, objectName)

        pycb.log(logging.INFO, "path %s bucket %s object %s" % (path, bucketName, str(objectName)))
        if request.method == 'GET':
            if objectName == None:
                cbR = cbGetBucket(request, user, bucketName, requestId, pycb.config.bucket)
            else:
                cbR = cbGetObject(request, user, bucketName, objectName, requestId, pycb.config.bucket)
            return cbR
        elif request.method == 'PUT':
            if objectName == None:
                cbR = cbPutBucket(request, user, bucketName, requestId, pycb.config.bucket)
            else:
                args = request.getAllHeaders()
                if 'x-amz-copy-source' in args:
                    (srcBucketName, srcObjectName) = path_to_bucket_object(args['x-amz-copy-source'])
                    cbR = cbCopyObject(request, user, requestId, pycb.config.bucket, srcBucketName, srcObjectName, bucketName, objectName)
                else:
                    cbR = cbPutObject(request, user, bucketName, objectName, requestId, pycb.config.bucket)
            return cbR
        elif request.method == 'POST':
            pycb.log(logging.ERROR, "Nothing to handle POST")
        elif request.method == 'DELETE':
            if objectName == None:
                cbR = cbDeleteBucket(request, user, bucketName, requestId, pycb.config.bucket)
            else:
                cbR = cbDeleteObject(request, user, bucketName, objectName, requestId, pycb.config.bucket)
            return cbR
        elif request.method == 'HEAD' and objectName != None:
            cbR = cbHeadObject(request, user, bucketName, objectName, requestId, pycb.config.bucket)
            return cbR

        raise cbException('InvalidArgument')

开发者ID:xxy-php，项目名称:code，代码行数:44，代码来源:cumulus.py

示例12: send_access_error

 def send_access_error(self, req):
     ex = cbException('AccessDenied')
     m_msg = "HTTP/1.1 %s %s\r\n" % (ex.httpCode, ex.httpDesc)
     self.transport.write(m_msg)
     m_msg = "%s: %s\r\n" % (('x-amz-request-id', str(uuid.uuid1())))
     self.transport.write(m_msg)
     self.transport.write('content-type: text/html')
     e_msg = ex.make_xml_string(self._path, str(uuid.uuid1()))
     self.transport.write(e_msg)
     self.transport.loseConnection()

开发者ID:acarpena，项目名称:nimbus，代码行数:10，代码来源:cumulus.py

示例13: get_owner

 def get_owner(self, bucketName, objectName=None):
     try:
         uf = self.get_uf(bucketName, objectName)
         o = uf.get_owner()
         uas = list(o.get_alias_by_type(pynimbusauthz.alias_type_s3))
         if len(uas) < 1:
             raise cbException('InternalError')
         return (uas[0].get_name(), uas[0].get_friendly_name())
     finally:
         self.db_obj.commit()

开发者ID:oldpatricka，项目名称:nimbus，代码行数:10，代码来源:cbAuthzSecurity.py

示例14: parse_acl_request

def parse_acl_request(xml):
    pycb.log(logging.INFO, "===== def parse_acl_request of cbRequest.py")
    dom = parseString(xml)
    grant_a = dom.getElementsByTagName("Grant")
    grants = []
    users = {}

    for g in grant_a:
        el = g.getElementsByTagName("URI")
        if el != None and len(el) >= 1:
            u = getText(el[0].childNodes)
            if u == "http://acs.amazonaws.com/groups/global/AllUsers":
                id = "CumulusPublicUser"
                email = ""
            else:
                raise cbException('InvalidArgument')
        else:
            el = g.getElementsByTagName("DisplayName")
            if el == None or len(el) < 1:
                email = None
            else:
                email = getText(el[0].childNodes)
            id = getText(g.getElementsByTagName("ID")[0].childNodes)
        perm_set = g.getElementsByTagName("Permission")

        perms = ""
        for p in perm_set:
            requested_perm = getText(p.childNodes)

            if requested_perm not in perms_strings:
                raise cbException('InvalidArgument')

            pv = perms_strings[requested_perm]
            ndx = perms.find(pv)
            if ndx < 0:
                perms = perms + pv

        if id in users.keys():
            (i, e, p) = users[id]
            perms = perms + p
        users[id] = (id, email, perms)

    return users.values()

开发者ID:xxy-php，项目名称:code，代码行数:43，代码来源:cbRequest.py

示例15: delete_bucket

 def delete_bucket(self, bucketName):
     pycb.log(logging.INFO, "===== def delete_bucket of cbAuthzSecurity.py")
     try:
         file = self.get_file_obj(bucketName)
         kids = file.get_all_children()
         if len(list(kids)) != 0:
             raise cbException('BucketNotEmpty')
         file.delete()
     finally:
         self.db_obj.commit()

开发者ID:xxy-php，项目名称:code，代码行数:10，代码来源:cbAuthzSecurity.py

示例16: init

    def __init__(self, request, user, bucketName, objName, requestId, bucketIface):
        cbRequest.__init__(self, request, user, requestId, bucketIface)
        ndx = objName.find("cumulus:/")
        if ndx >= 0:
            pycb.log(logging.ERROR, "someone tried to make a key named cumulus://... why would someone do that? %d" % (ndx))
            raise cbException('InvalidURI')

        self.checkMD5 = None
        self.bucketName = bucketName
        self.objectName = objName

开发者ID:Annatara，项目名称:nimbus，代码行数:10，代码来源:cbRequest.py

示例17: init_redirector

def init_redirector(req, bucketName, objectName):
    redir_host = pycb.config.redirector.new_connection(req)
    req.notifyFinish().addBoth(end_redirector, req)

    if redir_host:
        pycb.log(logging.INFO, "REDIRECT %s" % (redir_host))
        ex = cbException('TemporaryRedirect')
        req.setHeader('location', "http://%s%s" % (redir_host, req.uri))
        ex.add_custom_xml("Bucket", bucketName)
        ex.add_custom_xml("Endpoint", redir_host)
        raise ex

开发者ID:acarpena，项目名称:nimbus，代码行数:11，代码来源:cumulus.py

示例18: grant

 def grant(self, user_id, bucketName, objectName=None, perms="Rr"):
     (o_perms, key) = self.getPerms(bucketName, objectName)
     ndx = o_perms.find("W")
     if ndx < 0:
         raise cbException('AccessDenied')
     if objectName == None:
         f = self.getBucketPermFile(bucketName)
     else:
         f = self.getObjectFile(bucketName, objectName)
     self.add_perms(f, user_id, perms)
     pycb.log(logging.INFO, "granted: %s to %s" % (perms, user_id))

开发者ID:Annatara，项目名称:nimbus，代码行数:11，代码来源:cbPosixSecurity.py

示例19: request_object_factory

    def request_object_factory(self, request, user, path, requestId):

        pycb.log(logging.INFO, "path %s" % (path))
        # handle the one service operation
        if path == "/":
            if request.method == 'GET':
                cbR = cbGetService(request, user, requestId, pycb.config.bucket)
                return cbR
            raise cbException('InvalidArgument')

        (bucketName, objectName) = path_to_bucket_object(path)

        pycb.log(logging.INFO, "path %s bucket %s object %s" % (path, bucketName, str(objectName)))
        if request.method == 'GET':
            if objectName == None:
                cbR = cbGetBucket(request, user, bucketName, requestId, pycb.config.bucket)
            else:
                cbR = cbGetObject(request, user, bucketName, objectName, requestId, pycb.config.bucket)
            return cbR
        elif request.method == 'PUT':
            if objectName == None:
                cbR = cbPutBucket(request, user, bucketName, requestId, pycb.config.bucket)
            else:
                cbR = cbPutObject(request, user, bucketName, objectName, requestId, pycb.config.bucket)
            return cbR
        elif request.method == 'POST':
            pycb.log(logging.ERROR, "Nothing to handle POST")
        elif request.method == 'DELETE':
            if objectName == None:
                cbR = cbDeleteBucket(request, user, bucketName, requestId, pycb.config.bucket)
            else:
                cbR = cbDeleteObject(request, user, bucketName, objectName, requestId, pycb.config.bucket)
            return cbR
        elif request.method == 'HEAD' and objectName != None:
            cbR = cbHeadObject(request, user, bucketName, objectName, requestId, pycb.config.bucket)
            return cbR

        raise cbException('InvalidArgument')

开发者ID:pauloricardomg，项目名称:nimbus，代码行数:38，代码来源:cumulus.py

示例20: get_user

    def get_user(self, id):
        usr_ath_filename = getPosixAuthDir() + id
        if os.path.exists(usr_ath_filename) == 0:
            ex = cbException('InvalidAccessKeyId')
            pycb.log(logging.ERROR, "could not open: %s" % (usr_ath_filename))
            raise ex

        auth_file = open(usr_ath_filename, 'r')
        key = auth_file.readline()
        key = key.strip()
        display_name = auth_file.readline()
        display_name = display_name.strip()
        auth_file.close()
        return cbPosixUserObject(id, display_name, key)

开发者ID:Annatara，项目名称:nimbus，代码行数:14，代码来源:cbPosixSecurity.py

注：本文中的pycb.cbException.cbException函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Python fft.fft函数代码示例发布时间：2022-05-25

Python pycb.log函数代码示例发布时间：2022-05-25

Python util.grid_equal函数代码示例

1 Python 入门教程

Python入门教程 Python 是一种解释型、面向对象、动态数据类型的高级程序设计语言。 P

阅读：13759|2022-01-22

2 Python wikiutil.getFrontPage函数代码示例

Python wikiutil.getFrontPage函数代码示例

阅读：9124|2022-05-24

3 Python 简介

Python 简介 Python 是一个高层次的结合了解释性、编译性、互动性和面向对象的脚本

阅读：4061|2022-01-22

4 Python tests.group函数代码示例

Python tests.group函数代码示例

阅读：4038|2022-05-27

5 Python util.check_if_user_has_permission

Python util.check_if_user_has_permission函数代码示例

阅读：3816|2022-05-27

6 Python 操练实例98

Python 练习实例98 Python 100例题目：从键盘输入一个字符串，将小写字母全部转换成大

阅读：3498|2022-01-22

7 Python 环境搭建

Python 环境搭建本章节我们将向大家介绍如何在本地搭建 Python 开发环境。 Py

阅读：3020|2022-01-22

8 Python output.darkgreen函数代码示例

Python output.darkgreen函数代码示例

阅读：2634|2022-05-25

9 Python 基础语法

Python 基础语法 Python 语言与 Perl，C 和 Java 等语言有许多相似之处。但是，也

阅读：2622|2022-01-22

10 Python 中文编码

Python 中文编码前面章节中我们已经学会了如何用 Python 输出 Hello, World!，英文没

阅读：2290|2022-01-22

客服电话

电子邮件

Python cbException.cbException函数代码示例

示例1: work

示例2: work

示例3: parse_acl_request

示例4: __init__

示例5: seek

示例6: get_uf

示例7: __init__

示例8: delete_bucket

示例9: __init__

示例10: check_permissions

示例11: request_object_factory

示例12: send_access_error

示例13: get_owner

示例14: parse_acl_request

示例15: delete_bucket

示例16: __init__

示例17: init_redirector

示例18: grant

示例19: request_object_factory

示例20: get_user

请发表评论

全部评论

上一篇：

下一篇：

Python util.grid_equal函数代码示例

Python util.get_worker_name函数代码示例

Python util.get_webmention_target函数代

Python util.get_uuid函数代码示例

Python util.get_type_by_name函数代码示例

Python util.grid_equal函数代码示例

Python util.get_worker_name函数代码示例

Python util.get_webmention_target函数代

Python util.get_uuid函数代码示例

Python util.get_type_by_name函数代码示例

Python util.get_stdout函数代码示例

关于我们

产品与服务

解决方案

139-2527-9053

示例4: init

示例7: init

示例9: init

示例16: init