azure.storage.blob.aio import BlobServiceClient as BlobServiceClientAsync
async def query_blob_async(self):
blob_service_client = BlobServiceClientAsync.from_connection_string(
self.connection_string_srct.get_secret_value()
)
async with blob_service_client:
container_client = blob_service_client.get_container_client(self.container)
blob_client = container_client.get_blob_client(blob)
data_reader = await blob_client.query_blob( # nosec
f"SELECT * FROM BlobStorage where measurement_source_id in {in_string}",
blob_format=parquet_format,
output_format=csv_format,
)
我尝试异步使用blob*client.query_*blob(),但在尝试上面的代码时,我得到以下错误:
“无法解包不可迭代的协同程序对象”。
我可以看到blob_client对象有query_blob方法,但看不到任何关于如何异步使用它的文档。任何帮助都将非常感谢:)
1条答案
按热度按时间6pp0gazn1#
我在我的环境中试了一下,得到的结果是:
您可以使用下面的代码使用azure-blob存储**
query_blobs
**。验证码:
输出:
上述查询已成功执行,您可以查看CSV文件的第二列。
**引用:**azure.storage.blob.BlobClient类|微软学习