python lmdb demo 这接口和BDB一样恶心啊！

import lmdb

lmdb_img_name = "test.lmdb"

env = lmdb.open(lmdb_img_name, map_size=1e6)

with env.begin(write=True) as txn:

    txn.put("key", "xxxxxxxxxxxxxxxxxx")

    txn.put("key2", "?")

    txn.put("key3", "some value")

    #txn.commit()

env.close()

env = lmdb.open(lmdb_img_name, readonly=True)

with env.begin() as txn:

    print txn.get(b'key')

    cursor = txn.cursor()

    for key, value in cursor:

        print(key, value)

更多见：http://blog.csdn.net/ayst123/article/details/44077903，摘录如下：

write

db_img = lmdb.Environment(lmdb_img_name,map_size=int(1e12))

txn_img = db_img.begin(write=True,buffers=True)

datum_img = getImgDatum(img_path)

txn_img.put(key,datum_img.SerializeToString())

txn_img.commit()

db_img.close()

这里，先建立lmdb的instance， db_img。然后开始txn(可能有很多个开始？)。 put 存放，最后一定注意要commit()。不然根本没有存进去，检查下生成的lmdb文件就能看出。最后，close()

这里生成datum是用caffe自带的函数，做io.py里，叫caffe.io.array_to_datum, 将array变成datum.

Note:

datum存的时候一定要用datum.SerializeToString(), 将它变成string()

分段write

for ind,obj in enumerate(list):

    if ind%100=0:

        txn.commit()

        txn = env.begin(write=True)

txn.commit()

env.close()

每一次commit 后，需要再定义一次 txn=env.begin(write=True)
for loop 外面最后再 commit

Read

img_lmdb = imdb.open("name")

txn= img_lmdb.begin()

cursor = txn.cursor()

cursor.iternext()

key = cursor.key()

value = cursor.value()

datum = caffe_pb2.Datum()

datum.ParseFromString(value)

Note:

cursor 第一个是空的， iternext()后是第一个值

循环

txn = …
cursor = txn.cursor()
for ( idx, (key, value) ) in enumerate(cursor):
…………….

这就可以循环找了

巴特西

python lmdb demo 这接口和BDB一样恶心啊！

write

分段write

Read

循环

最新文章

热门文章