Azure表存储的异步批处理功能
batch-table-storage的Python项目详细描述
异步Microsoft Azure CosmosDB Table SDK for Python,具有批处理功能
此项目为azurecosmsdb表服务提供异步包装。
包装器允许您使用aioify
插入/合并/替换/删除实体列表。
你可以给它任何数量的分区键,它们将在不同的批处理。在
有关基本包的文档,请参阅azure-cosmosdb-table
包。(https://pypi.org/project/azure-cosmosdb-table/)
特点
- 根据PartitionKey自动将实体列表拆分为批
- 自动将实体分块到子列表中以获得正确的批大小
- 批插入实体异步
- 批量更新实体异步
- 批合并实体异步
- 批量删除实体异步
- 批量插入或替换实体异步
- 批插入或合并实体异步
入门
要通过Python包索引(PyPI)安装,请键入:
pip install batch-table-storage
最低要求
- azure宇宙数据库表==1.0.6
代码示例
导入包装类
^{pr2}$实例化服务
service = BatchTableService(account_name='storageAccount', account_key='x')
创建一些实体
entities = [
{'PartitionKey': 'person', 'RowKey': '1', 'name': 'John'},
{'PartitionKey': 'pet', 'RowKey': '1', 'name': 'Cat'}
]
导入异步:
import asyncio
异步创建和提交批处理:
asyncio.run(
service.batch_insert_entities(table_name='tableA', entities=entities)
)
了解更多
用于Python的Microsoft Azure CosmsDB Table SDK:https://pypi.org/project/azure-cosmosdb-table/
- 项目
标签: