lmdb 键值数据库读写测试

概述lmdb 键值数据库读写测试

下面是内存溢出 jb51.cc 通过网络收集整理的代码片段。

内存溢出小编现在分享给大家，也给大家做个参考。

import lmdbimport osimport argparseimport geventimport gevent.queueTEMP_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)

以上是内存溢出(jb51.cc)为你收集整理的全部代码内容，希望文章能够帮你解决所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。

总结

以上是内存溢出为你收集整理的lmdb 键值数据库读写测试全部内容，希望文章能够帮你解决lmdb 键值数据库读写测试所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。