如何在RelStorage包中删除斑点?

此问题与How to pack blobstorage with Plone and RelStorage

有关

使用zodb数据库和RelStorage和sqlite作为后端,我试图删除未使用的Blob。当前db.pack不能从光盘中删除斑点。下面的最小工作示例演示了此行为:

import logging
import numpy as np
import os
import persistent
from persistent.list import PersistentList
import shutil
import time
from ZODB import config,blob

connectionString = """
%import relstorage
<zodb main>
<relstorage>
blob-dir ./blob
keep-history false
cache-local-mb 0
<sqlite3>
    data-dir .
</sqlite3>
</relstorage>
</zodb>
"""


class Data(persistent.Persistent):
    def __init__(self,data):
        super().__init__()

        self.children = PersistentList()

        self.data = blob.Blob()
        with self.data.open("w") as f:
            np.save(f,data)


def main():
    logging.basicConfig(level=logging.INFO)
    # Initial cleanup
    for f in os.listdir("."):
        if f.endswith("sqlite3"):
            os.remove(f)

    if os.path.exists("blob"):
        shutil.rmtree("blob",True)

    # Initializing database
    db = config.databaseFromString(connectionString)
    with db.transaction() as conn:
        root = Data(np.arange(10))
        conn.root.Root = root

        child = Data(np.arange(10))
        root.children.append(child)

    # Removing child reference from root
    with db.transaction() as conn:
        conn.root.Root.children.pop()

    db.close()

    print("blob directory:",[[os.path.join(rootDir,f) for f in files] for rootDir,_,files in os.walk("blob") if files])
    db = config.databaseFromString(connectionString)
    db.pack(time.time() + 1)
    db.close()
    print("blob directory:",files in os.walk("blob") if files])


if __name__ == "__main__":
    main()

上面的示例执行以下操作:

  1. 删除当前目录中的所有先前数据库以及blob目录。
  2. 从头开始创建数据库/存储,添加两个对象(root和child),而child由root引用并执行事务。
  3. 从根到子之间删除链接并执行事务。
  4. 关闭数据库/存储
  5. 打开数据库/存储并在将来执行db.pack一秒钟。

最小工作示例的输出如下:

INFO:ZODB.blob:(23376) Blob directory '<some path>/blob/' does not exist. Created new directory.
INFO:ZODB.blob:(23376) Blob temporary directory './blob/tmp' does not exist. Created new directory.
blob directory: [['blob/.layout'],['blob/3/.lock','blob/3/0.03da352c4c5d8877.blob'],['blob/6/.lock','blob/6/0.03da352c4c5d8877.blob']]
INFO:relstorage.storage.pack:pack: beginning pre-pack
INFO:relstorage.storage.pack:Analyzing transactions committed Thu Aug 27 11:48:17 2020 or before (TID 277592791412927078)
INFO:relstorage.adapters.packundo:pre_pack: filling the pack_object table
INFO:relstorage.adapters.packundo:pre_pack: Filled the pack_object table
INFO:relstorage.adapters.packundo:pre_pack: analyzing references from 7 object(s) (memory delta: 256.00 KB)
INFO:relstorage.adapters.packundo:pre_pack: objects analyzed: 7/7
INFO:relstorage.adapters.packundo:pre_pack: downloading pack_object and object_ref.
INFO:relstorage.adapters.packundo:pre_pack: traversing the object graph to find reachable objects.
INFO:relstorage.adapters.packundo:pre_pack: marking objects reachable: 4
INFO:relstorage.adapters.packundo:pre_pack: finished successfully
INFO:relstorage.storage.pack:pack: pre-pack complete
INFO:relstorage.adapters.packundo:pack: will remove 3 object(s)
INFO:relstorage.adapters.packundo:pack: cleaning up
INFO:relstorage.adapters.packundo:pack: finished successfully
blob directory: [['blob/.layout'],'blob/6/0.03da352c4c5d8877.blob']]

您可以看到db.pack确实删除了3个对象“ 将删除3个对象”,但是文件系统中的blob不变。

在RelStorage的单元测试中,它们似乎确实在测试是否从文件系统(see here)中删除了blob,但是在上面的脚本中,它不起作用。

我在做什么错?任何提示/链接/帮助表示赞赏。

iCMS 回答:如何在RelStorage包中删除斑点?

默认情况下,blob存储目录用作 cache ,用于存储也存储在数据库中的blob数据;这个想法是,从本地磁盘缓存加载blob数据比从远程数据库服务器加载blob数据快。使用缓存Blob存储将数据存储在无历史记录的存储中,不会删除无法访问的Blob文件,而是在需要腾出空间时依靠文件大小限制器将过时的缓存数据逐出。但是,您没有设置大小限制,因此缓存无限增长,那些无法访问的Blob文件将永远存在。

打包不能在此处删除blob文件,因为缓存是每个ZODB客户端本地的;就像以前一样,它不在ZODB存储的管辖范围之内。当使用SQLite作为数据库层时,这可能并不明显,但可以想象一下,在单独的服务器上使用Postgres,在不同的计算机上有多个客户端,并且您可以看到打包时缓存清理是不可行的。

请注意,另一个Blob存储选项是共享 Blob存储,它可能更接近您的预期:所有Blob数据都存储在磁盘上 ,不在数据库中。与远程数据库服务器和多个客户端一起使用时,您需要将其放置在NTFS共享之类的东西上。在这种情况下,打包操作直接在Blob上进行,打包时会立即删除无法访问的Blob文件。

您有两个选择:

  • 通过设置blob-cache-size来设置Blob缓存的大小限制。压缩仍不会删除blob文件,但是当空间不足时,它们会被删除。

  • 切换到共享Blob缓存(将shared-blob-dir设置为true)。尽管有文档中的可怕警告,但对于由sqlite支持的RelStorage,这可能比缓存blob存储更有意义!

最简单的更改是切换Blob存储模式:

connectionString = """
%import relstorage
<zodb main>
<relstorage>
blob-dir ./blob
shared-blob-dir true
keep-history false
cache-local-mb 0
<sqlite3>
    data-dir .
</sqlite3>
</relstorage>
</zodb>
"""

然后输出更改为:

INFO:ZODB.blob:(26177) Blob directory '<some path>/blob/' does not exist. Created new directory.
INFO:ZODB.blob:(26177) Blob temporary directory './blob/tmp' does not exist. Created new directory.
blob directory: [['blob/.layout'],['blob/0x00/0x00/0x00/0x00/0x00/0x00/0x00/0x03/0x03da4f169582cd22.blob','blob/0x00/0x00/0x00/0x00/0x00/0x00/0x00/0x03/.lock'],['blob/0x00/0x00/0x00/0x00/0x00/0x00/0x00/0x06/0x03da4f169582cd22.blob','blob/0x00/0x00/0x00/0x00/0x00/0x00/0x00/0x06/.lock']]
INFO:relstorage.storage.pack:pack: beginning pre-pack
INFO:relstorage.storage.pack:Analyzing transactions committed Tue Sep  1 01:22:35 2020 or before (TID 277621285453417864)
INFO:relstorage.adapters.packundo:pre_pack: filling the pack_object table
INFO:relstorage.adapters.packundo:pre_pack: Filled the pack_object table
INFO:relstorage.adapters.packundo:pre_pack: analyzing references from 7 object(s) (memory delta: 0 KB)
INFO:relstorage.adapters.packundo:pre_pack: objects analyzed: 7/7
INFO:relstorage.adapters.packundo:pre_pack: downloading pack_object and object_ref.
INFO:relstorage.adapters.packundo:pre_pack: traversing the object graph to find reachable objects.
INFO:relstorage.adapters.packundo:pre_pack: marking objects reachable: 4
INFO:relstorage.adapters.packundo:pre_pack: finished successfully
INFO:relstorage.storage.pack:pack: pre-pack complete
INFO:relstorage.adapters.packundo:pack: will remove 3 object(s)
INFO:relstorage.adapters.packundo:pack: cleaning up
INFO:relstorage.adapters.packundo:pack: finished successfully
blob directory: [['blob/.layout'],'blob/0x00/0x00/0x00/0x00/0x00/0x00/0x00/0x03/.lock']]

是的,blob dir布局发生了变化,因此它可以处理所有可能的OID。 OID 6已被删除。

您发现的单元测试仅在testing with a shared blob cache时运行:

# If the blob directory is a cache,don't test packing,# since packing can not remove blobs from all caches.
test_packing = shared_blob_dir
本文链接:https://www.f2er.com/1671169.html

大家都在问