asyncmy - A fast asyncio MySQL driver
Introduction
asyncmy is a fast asyncio MySQL driver, which reuse most of pymysql and rewrite
core with cython to speedup.
Features
Benchmark
The result comes from benchmark, we can know asyncmy performs well when compared to other drivers.
The device is MacBook Pro (13-inch, M1, 2020) 16G and MySQL version is 8.0.23.
Install
Just install from pypi:
> pip install asyncmy
Usage
Use connect
from asyncmy import connect
from asyncmy.cursors import DictCursor
import asyncio
async def run():
conn = await connect()
async with conn.cursor(cursor=DictCursor) as cursor:
await cursor.execute("create database if not exists test")
await cursor.execute(
"""CREATE TABLE if not exists test.asyncmy
(
`id` int primary key auto_increment,
`decimal` decimal(10, 2),
`date` date,
`datetime` datetime,
`float` float,
`string` varchar(200),
`tinyint` tinyint
)"""
)
if __name__ == '__main__':
asyncio.run(run())
Use pool
import asyncmy
import asyncio
async def run():
pool = await asyncmy.create_pool()
async with pool.acquire() as conn:
async with conn.cursor() as cursor:
await cursor.execute("SELECT 1")
ret = await cursor.fetchone()
assert ret == (1,)
if __name__ == '__main__':
asyncio.run(run())
Replication
from asyncmy import connect
from asyncmy.replication import BinLogStream
import asyncio
async def run():
conn = await connect()
ctl_conn = await connect()
stream = BinLogStream(
conn,
ctl_conn,
1,
master_log_file="binlog.000172",
master_log_position=2235312,
resume_stream=True,
blocking=True,
)
await stream.connect()
async for event in stream:
print(event)
if __name__ == '__main__':
asyncio.run(run())
ThanksTo
asyncmy is build on top of these nice projects.
- pymysql, a pure python MySQL client.
- aiomysql, a library for accessing a MySQL database from the asyncio.
- python-mysql-replication, pure Python Implementation of MySQL replication protocol build on top of PyMYSQL.
License
This project is licensed under the Apache-2.0 License.
1 maintainer
Metadata
1 maintainer
Release files for asyncmy 0.1.8
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| asyncmy-0.1.8.tar.gz | 60.1 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| asyncmy-0.1.8-cp39-cp39-manylinux2014_x86_64.whl | CPython 3.9 | CPython 3.9 | Linux glibc 2.17+ x86-64 | Details |
Total release size: 3.1 MB
Release files / asyncmy-0.1.8.tar.gz
| Download URL | asyncmy-0.1.8.tar.gz |
|---|---|
| Size | 60.1 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
a7c06caf37f874d397db8f3a7eb96fdbc2b6608f3c737b77ae2636c4d4ad1949
|
|
BLAKE2b-256 checksum How to use checksums |
17adef3a0287311b9a7926017763b57247f217dd3e24d8680a5186143c216492
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/3.4.2 importlib_metadata/4.6.4 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.1 CPython/3.9.6
|
Release files / asyncmy-0.1.8-cp39-cp39-manylinux2014_x86_64.whl
| Download URL | asyncmy-0.1.8-cp39-cp39-manylinux2014_x86_64.whl |
|---|---|
| Size | 3.1 MB |
| Tags | CPython 3.9 Linux glibc 2.17+ x86-64 |
|
SHA-256 checksum How to use checksums |
eb244d7c2b4f35ed678132581180f3a1d40370e91fb0e31974dd3c7429e4b1cc
|
|
BLAKE2b-256 checksum How to use checksums |
1992dcd44345c655b118d09b27448de58f982dc15e9bf2054aa2adc8866d78ad
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/3.4.2 importlib_metadata/4.6.4 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.1 CPython/3.9.6
|
