onestep-mysql
MySQL connector plugin for onestep.
pip install onestep-mysql
The package registers these YAML resource types through the onestep.resources
entry point:
mysqlmysql_state_storemysql_cursor_storemysql_table_queuemysql_incrementalmysql_binlogmysql_table_sink
Python usage:
from onestep_mysql import MySQLConnector
SQLAlchemy database operations use AsyncEngine and async drivers. Existing
mysql:// and mysql+pymysql:// DSNs are accepted and are automatically
adapted to the asyncmy dialect. SQLite is supported in tests and local
development through aiosqlite. The binlog reader remains isolated behind a
thread boundary because mysql-replication is a synchronous library.
Production mysql_incremental sources should bind a durable
mysql_cursor_store with an explicit stable state_key. Retries redeliver the
same logical row with incremented attempts and pause later SQL reads across the
gap. Concurrent acknowledgements advance only a contiguous prefix and are
coalesced into cursor-store commit waves.
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file onestep_mysql-0.6.1.tar.gz.
File metadata
- Download URL: onestep_mysql-0.6.1.tar.gz
- Upload date:
- Size: 27.6 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/7.0.0 CPython/3.13.14
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
5d947493187d234955ec094bd81e1137c42c239dd630ff6dfdcd4a2c999267fd
|
|
| MD5 |
215568e97a39efbb882d5eaff9d2288d
|
|
| BLAKE2b-256 |
c2378be21e44c7f0bd9f78054bc52c1ecb9ce0cbcf54654572b73f782707241c
|
File details
Details for the file onestep_mysql-0.6.1-py3-none-any.whl.
File metadata
- Download URL: onestep_mysql-0.6.1-py3-none-any.whl
- Upload date:
- Size: 17.7 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/7.0.0 CPython/3.13.14
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
15a6c27dd7b287284d56af86f78dc44a9639c32d6ec6cacdeb5203c5826442fd
|
|
| MD5 |
66fcfa8648aaf7c21c1e093de41ab3f3
|
|
| BLAKE2b-256 |
d1697fa82ae17f8be86abcaa42e4c72684efc59e8abd26ae5b667431c8511202
|
