Newio + RethinkDB: Async RethinkDB driver
Work In Progress, Not Production Ready!
Overview
from newio_kernel import run
from newio_rethinkdb import r, set_loop_type
async def main():
conn = await r.connect('127.0.0.1', 28015)
ret = await r.db("test").table_list().run(conn)
print(ret)
set_loop_type()
run(main)
Install
pip install newio-rethinkdb
Document
connect, run
Just call them as coroutine await xxx()
.
reql
Not Support.
ConnectionPool
from newio_kernel import run
from newio_rethinkdb import ConnectionPool, r, set_loop_type
async def main():
pool = ConnectionPool(host='127.0.0.1', port=28015)
conn = await pool.get()
ret = await r.db("test").table_list().run(conn)
print(ret)
await pool.put(conn)
set_loop_type()
run(main)
Need Help? Contributing?
- Open issues for any Questions/Bugs/Features
- Pull Requests are welcome