blobfs.py 文件源码

def read(self, path, length, offset, fh):
        if debug:
            print "read:       " + path
            print "offset:  " 
            print offset
            print "length: "
            print length 
            print fh
        full_path = self._full_path(path)
        print full_path
        #os.lseek(fh, offset, os.SEEK_SET)
        #if os.path.isfile(full_path) == False:
        import config as config
        account_name = config.STORAGE_ACCOUNT_NAME
        account_key = config.STORAGE_ACCOUNT_KEY
        containername = path.split('/')[1]
        filename = path.split('/')[2]
        service = baseblobservice.BaseBlobService(account_name, account_key)
        blob = service.get_blob_to_bytes(containername, filename, None, offset, offset+length-1)
        #blob = blob[offset:(offset+length)]
        bytes = blob.content 
        return bytes
        """try:
            if os.path.isdir(path.split('/')[1]) == False:
                os.mkdir(full_path.split('/')[0]+'/'+containername)
            if os.path.isfile(full_path) == False:
                print "read block blob" 
                block_blob_service.get_blob_to_path(containername, filename, full_path)
            else:
                os.remove(full_path)
                block_blob_service.get_blob_to_path(containername, filename, full_path)
        except:
            pass

        fhn = os.open(full_path, 32768)
        os.lseek(fhn, offset, os.SEEK_SET)

        #print "os.read(fh, length)"
        #print os.read(fh, length)
        return os.read(fhn, length)"""