asynctnt 1.0

安装

使用PIP安装：

$ pip install asynctnt

文档

文件可用 here。

主要功能

• 支持Tarantool支持的所有基本请求。这个 包括：insert，select，update，upsert，eval， sql（用于tarantool 2.x）、call和call16。注意：对于 “call16”与“call”的区别请参考塔兰托 文档。
• schema在建立连接时获取，因此可以使用 空格和索引名称，而不是它们的id。
• 架构自动重新蚀刻。如果塔兰托尔的模式改变了， asynctnt重新读取。
• 自动重新连接。如果由于某种原因失去连接-asynctnt 将启动自动重新连接过程（经授权和 当然是模式获取）。
• 能够对元组使用dict并将字段名用作dml中的键 请求（select、insert、replace、delete、update、upsert）。这是 只有在tarantool中指定space.format时才可能。字段名 也可用于更新操作，而不是字段号。 此外，元组被解码成特殊的结构，这些结构可以起作用 作为tuples或通过dicts使用适当的api。
• 所有请求都支持timeout值的规范，因此如果 请求执行时间过长，引发asyncio.timeouterror。它 大大简化了代码，因为您不需要使用 asyncio.wait_for(...)东西了。

基本用法

塔兰托配置：

box.cfg{listen='127.0.0.1:3301'}box.once('v1',function()box.schema.user.grant('guest','read,write,execute','universe')locals=box.schema.create_space('tester')s:create_index('primary')s:format({{name='id',type='unsigned'},{name='name',type='string'},})end)

python代码：

importasyncioimportasynctntasyncdefmain():conn=asynctnt.Connection(host='127.0.0.1',port=3301)awaitconn.connect()foriinrange(1,11):awaitconn.insert('tester',[i,'hello{}'.format(i)])data=awaitconn.select('tester',[])first_tuple=data[0]print('tuple:',first_tuple)print(f'tuple[0]: {first_tuple[0]}; tuple["id"]: {first_tuple["id"]}')print(f'tuple[1]: {first_tuple[1]}; tuple["name"]: {first_tuple["name"]}')awaitconn.disconnect()asyncio.run(main())

标准输出：

（注意，可以通过索引或 他们的名字）

tuple: <TarantoolTuple id=1 name='hello1'>
tuple[0]: 1; tuple["id"]: 1
tuple[1]: hello1; tuple["name"]: hello1

SQL

Tarantool 2为数据库提供了一个SQL接口。你很容易 通过asynctnt

box.cfg{listen='127.0.0.1:3301'}box.once('v1',function()box.schema.user.grant('guest','read,write,execute','universe')box.sql.execute([[
        create table users (
            id int primary key,
            name text
        )
    ]])end)

importasyncioimportasynctntasyncdefmain():conn=asynctnt.Connection(host='127.0.0.1',port=3301)awaitconn.connect()awaitconn.sql("insert into users (id, name) values (1, 'James Bond')")awaitconn.sql("insert into users (id, name) values (2, 'Ethan Hunt')")data=awaitconn.sql('select * from users')forrowindata:print(row)awaitconn.disconnect()asyncio.run(main())

标准输出：

<TarantoolTuple ID=1 NAME='James Bond'>
<TarantoolTuple ID=2 NAME='Ethan Hunt'>

性能

在下面的所有基准上wal_mode = none

许可证

AsyncTNT是在Apache2.0许可下开发和分发的。

参考文献

1. Tarantool-内存数据库和 应用服务器。
2. aiotarantool- 可选的python/asyncio连接器
3. asynctnt-queue- 的asynctnt上的绑定 tarantool-queue