lmdb 键值数据库读写测试
发布时间:2020-12-17 17:12:57 所属栏目:Python 来源:网络整理
导读:今天PHP站长网 52php.cn把收集自互联网的代码分享给大家,仅供参考。 import lmdbimport osimport argparseimport geventimport gevent.queueTEMP_PATH="/dev/shm/test"#TEMP_PATH="/dev/shm/"env = lmdb.Environment('./
以下代码由PHP站长网 52php.cn收集自互联网 现在PHP站长网小编把它分享给大家,仅供参考 import lmdb import os import argparse import gevent import gevent.queue TEMP_PATH="/dev/shm/test" #TEMP_PATH="/dev/shm/" env = lmdb.Environment('./lm_db/',readonly = False,map_size=1048576 * 1024,metasync=False,sync=True,map_async=True) files = os.listdir(TEMP_PATH) queue = gevent.queue.Queue() map(queue.put,files) def lmdbstore(db,queue = queue): with db.begin(write=True) as lmdb_txn: try: for i in xrange(3000): item = queue.get() key = item value = file(os.path.join(TEMP_PATH,item)).read() lmdb_txn.put( key,value ) print(i,item) except StopIteration as exc: print( str(exc)) def delete(db): with db.begin( write = True ) as txn: cursor = txn.cursor() for idx,data in enumerate( cursor.iternext_nodup() ): txn.delete(data) def query(db): with db.begin( write = True) as txn: cursor = txn.cursor() for idx,data in enumerate( cursor.iternext_nodup()): print(idx,data) if __name__ == '__main__': #query( env ) lmdbstore(env,queue) env.sync(True) 以上内容由PHP站长网【52php.cn】收集整理供大家参考研究 如果以上内容对您有帮助,欢迎收藏、点赞、推荐、分享。 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |