国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

用Python編寫一個簡單的FUSE文件系統的教程

2020-02-23 00:31:46
字體:
來源:轉載
供稿:網友

如果你是我的長期讀者,那么你應該知道我在尋找一個完美備份程序,最后我寫了一個基于bup的我自己的加密層。

在寫encbup的時候,我對僅僅恢復一個文件就必須要下載整個巨大的檔案文件的做法不甚滿意,但仍然希望能將EncFS和 rdiff-backup一起使用來實現可遠程掛載、加密、去重、版本化備份的功能。

再次試用obnam 后(啰嗦一句:它還是慢的出奇),我注意到了它有一個mount命令。深入研究后,我發(fā)現了fuse-python和fusepy,感覺用Python寫一個FUSE文件系統應該挺簡單的。

聰明的讀者可能已經意識到了我接下來要做的事情:我決定用Python寫一個加密文件系統層!它與EncFS會非常相似,但也有一些重要的區(qū)別:

    它默認以反向模式運行,接收正常的文件并且暴露一個被加密的目錄。任何備份程序會發(fā)現(并且備份)這些加密的目錄,不需要任何其它的存儲。     它也能接受由一個目錄列表組成的配置文件,并且在掛載點將這些目錄暴露出來。這樣的話,所有的備份腳本就需要將掛載點備份,各種不同的目錄會立刻得以備份。     它會更偏重于備份,而不是加密存儲。寫起來應該會挺有意思的。

一個FUSE文件系統示例

寫這個腳本的第一步是寫出一個純粹的傳遞式的文件系統。它僅僅是接受一個目錄,并在掛載點將其暴露出來,確保任何在掛載點的修改都會鏡像到源數據中。

fusepy 要求你寫一個類,里面定義了各種操作系統級別的方法。你可以選擇定義那些你的文件系統想要支持的方法,其他的可以暫時不予定義,但是我需要定義全部的方法,因為我的文件系統是一個傳遞式的文件系統,它應該表現的與原有的文件系統盡可能一致。

寫這段代碼會非常簡單有趣,因為大部分的方法只是對os模塊的一些簡單封裝(確實,你可以直接給它們賦值,比如 open=os.open 等等,但是我的模塊需要一些路徑擴展)。不幸的是,fuse-python有一個bug(據我所知)是當打開和讀文件的時候,它無法將文件句柄回傳給文件系統。因而我的腳本不知道某個應用執(zhí)行讀寫操作時對應的是哪個文件句柄,從而導致了失敗。只需要對fusepy做極少的改動,它就可以很好地運行。它只有一個文件,所以你可以把它直接放到你的工程里。
代碼

在這里,我很樂意給出這段代碼,當你打算自己實現文件系統的時候可以拿來參考。這段代碼提供了一個很好的起點,你可以直接把這個類復制到你的工程中并且根據需要重寫里面的一些方法。

接下來是真正的代碼了:

#!/usr/bin/env python from __future__ import with_statement import osimport sysimport errno from fuse import FUSE, FuseOSError, Operations class Passthrough(Operations):  def __init__(self, root):    self.root = root   # Helpers  # =======   def _full_path(self, partial):    if partial.startswith("/"):      partial = partial[1:]    path = os.path.join(self.root, partial)    return path   # Filesystem methods  # ==================   def access(self, path, mode):    full_path = self._full_path(path)    if not os.access(full_path, mode):      raise FuseOSError(errno.EACCES)   def chmod(self, path, mode):    full_path = self._full_path(path)    return os.chmod(full_path, mode)   def chown(self, path, uid, gid):    full_path = self._full_path(path)    return os.chown(full_path, uid, gid)   def getattr(self, path, fh=None):    full_path = self._full_path(path)    st = os.lstat(full_path)    return dict((key, getattr(st, key)) for key in ('st_atime', 'st_ctime',           'st_gid', 'st_mode', 'st_mtime', 'st_nlink', 'st_size', 'st_uid'))   def readdir(self, path, fh):    full_path = self._full_path(path)     dirents = ['.', '..']    if os.path.isdir(full_path):      dirents.extend(os.listdir(full_path))    for r in dirents:      yield r   def readlink(self, path):    pathname = os.readlink(self._full_path(path))    if pathname.startswith("/"):      # Path name is absolute, sanitize it.      return os.path.relpath(pathname, self.root)    else:      return pathname   def mknod(self, path, mode, dev):    return os.mknod(self._full_path(path), mode, dev)   def rmdir(self, path):    full_path = self._full_path(path)    return os.rmdir(full_path)   def mkdir(self, path, mode):    return os.mkdir(self._full_path(path), mode)   def statfs(self, path):    full_path = self._full_path(path)    stv = os.statvfs(full_path)    return dict((key, getattr(stv, key)) for key in ('f_bavail', 'f_bfree',      'f_blocks', 'f_bsize', 'f_favail', 'f_ffree', 'f_files', 'f_flag',      'f_frsize', 'f_namemax'))   def unlink(self, path):    return os.unlink(self._full_path(path))   def symlink(self, target, name):    return os.symlink(self._full_path(target), self._full_path(name))   def rename(self, old, new):    return os.rename(self._full_path(old), self._full_path(new))   def link(self, target, name):    return os.link(self._full_path(target), self._full_path(name))   def utimens(self, path, times=None):    return os.utime(self._full_path(path), times)   # File methods  # ============   def open(self, path, flags):    full_path = self._full_path(path)    return os.open(full_path, flags)   def create(self, path, mode, fi=None):    full_path = self._full_path(path)    return os.open(full_path, os.O_WRONLY | os.O_CREAT, mode)   def read(self, path, length, offset, fh):    os.lseek(fh, offset, os.SEEK_SET)    return os.read(fh, length)   def write(self, path, buf, offset, fh):    os.lseek(fh, offset, os.SEEK_SET)    return os.write(fh, buf)   def truncate(self, path, length, fh=None):    full_path = self._full_path(path)    with open(full_path, 'r+') as f:      f.truncate(length)   def flush(self, path, fh):    return os.fsync(fh)   def release(self, path, fh):    return os.close(fh)   def fsync(self, path, fdatasync, fh):    return self.flush(path, fh) def main(mountpoint, root):  FUSE(Passthrough(root), mountpoint, foreground=True) if __name__ == '__main__':  main(sys.argv[2], sys.argv[1])            
發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 鄂州市| 固始县| 大港区| 水城县| 长治市| 无极县| 仪陇县| 汉源县| 襄垣县| 长岛县| 沿河| 敖汉旗| 上饶县| 淳化县| 香格里拉县| 澎湖县| 昂仁县| 泸州市| 丹江口市| 崇左市| 平度市| 文水县| 阿克陶县| 大渡口区| 上饶县| 南丹县| 温泉县| 西乌| 奎屯市| 昌吉市| 铜山县| 兴安县| 衡南县| 民权县| 巴彦淖尔市| 洛川县| 贡嘎县| 陵川县| 辉南县| 平和县| 抚州市|