test_daemon.py 文件源码

def rethinkdb_append_entry(connection):

    global ITERATION
    value = {"id": DEFAULT_VALUE, "value": ITERATION}


    try:
        t = timeit.default_timer()
        r.table(RETHINKDB_TABLE_NAME).insert(value, conflict='replace').run(connection, durability="hard", read_mode='majority')
        v = r.table(RETHINKDB_DB_NAME, read_mode='majority').run(connection, durability="hard", read_mode='majority')
        ITERATION += 1
        ITERATION %= 100
        logging.info('key added')
    except:
        logging.error('{} not added'.format(value))
    finally:
        return timeit.default_timer() - t