Async batch functionality for Azure Table Storage
Project description
Async Microsoft Azure CosmosDB Table SDK for Python with batching functionality
This project provides a asynchronous wrapper for the Azure cosmosdb TableService.
The wrapper lets you insert/merge/replace/delete lists of entities using aioify
.
You can give it any number of PartitionKeys, they will be processed in different batches.
For documentation on the base package please see azure-cosmosdb-table
package. (https://pypi.org/project/azure-cosmosdb-table/)
Features
- Automatically split lists of entities into batches based on PartitionKey
- Automatically chunk entities into sub-lists for correct batch sizes
- Batch Insert Entities async
- Batch Update Entities async
- Batch Merge Entities async
- Batch Delete Entities async
- Batch Insert or Replace Entities async
- Batch Insert or Merge Entities async
Getting Started
To install via the Python Package Index (PyPI), type:
pip install batch-table-storage
Minimum Requirements
- azure-cosmosdb-table==1.0.6
Code Sample
Import the wrapper class
from batch_table_service import BatchTableService
Instantiate the service
service = BatchTableService(account_name='storageAccount', account_key='x')
Create some entities
entities = [
{'PartitionKey': 'person', 'RowKey': '1', 'name': 'John'},
{'PartitionKey': 'pet', 'RowKey': '1', 'name': 'Cat'}
]
Import asyncio:
import asyncio
Create and commit the batches async:
asyncio.run(
service.batch_insert_entities(table_name='tableA', entities=entities)
)
Learn More
Microsoft Azure CosmosDB Table SDK for Python: https://pypi.org/project/azure-cosmosdb-table/
Project details
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
Hashes for batch_table_storage-0.0.9.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | edf10768eccbf2a93f7a46026b805b66943f42cfecc612c546ec08a0a7528562 |
|
MD5 | c43d7de802d559ecca7c616846ed41f5 |
|
BLAKE2b-256 | 8d7eb50487c9b20df1cf56357ce6c81521efc11f0084048cf1605d8e1313b3a3 |
Hashes for batch_table_storage-0.0.9-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1d6806657666443877cad7133c648f451a3d5e2f97d0896c460889e6dc5b0684 |
|
MD5 | c98a09c35ebbff02566c528636ecafff |
|
BLAKE2b-256 | bae1c803c1fad41f6d7185c00cba60820b9d21ba35c828bf3832c21003ead605 |