1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
# coding: utf-8
# -------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
# --------------------------------------------------------------------------
"""
FILE: file_samples_client_async.py
DESCRIPTION:
These samples demonstrate simple async file operations like creating a share or file,
uploading and downloading to a file, and copying a file from a URL.
USAGE:
python file_samples_client_async.py
Set the environment variables with your own values before running the sample:
1) STORAGE_CONNECTION_STRING - the connection string to your storage account
2) STORAGE_ACCOUNT_NAME - the name of the storage account
"""
import asyncio
import os
import sys
current_dir = os.path.dirname(os.path.abspath(__file__))
DEST_FILE = os.path.join(current_dir, "SampleDestination.txt")
SOURCE_FILE = os.path.join(current_dir, "SampleSource.txt")
class FileSamplesAsync(object):
connection_string = os.getenv("STORAGE_CONNECTION_STRING")
account_name = os.getenv("STORAGE_ACCOUNT_NAME")
async def simple_file_operations_async(self):
if self.connection_string is None:
print("Missing required environment variable: STORAGE_CONNECTION_STRING." + '\n' +
"Test: simple_file_operations_async")
sys.exit(1)
# Instantiate the ShareClient from a connection string
from azure.storage.fileshare.aio import ShareClient
share = ShareClient.from_connection_string(self.connection_string, "filesamples1async")
# Create the share
async with share:
await share.create_share()
try:
# Get a file client
my_allocated_file = share.get_file_client("my_allocated_file")
my_file = share.get_file_client("my_file")
# [START create_file]
# Create and allocate bytes for the file (no content added yet)
await my_allocated_file.create_file(size=100)
# [END create_file]
# Or upload a file directly
# [START upload_file]
with open(SOURCE_FILE, "rb") as source:
await my_file.upload_file(source)
# [END upload_file]
# Download the file
# [START download_file]
with open(DEST_FILE, "wb") as data:
stream = await my_file.download_file()
data.write(await stream.readall())
# [END download_file]
# Delete the files
# [START delete_file]
await my_file.delete_file()
# [END delete_file]
await my_allocated_file.delete_file()
finally:
# Delete the share
await share.delete_share()
async def copy_file_from_url_async(self):
if self.connection_string is None:
print("Missing required environment variable: STORAGE_CONNECTION_STRING." + '\n' +
"Test: copy_file_from_url_async")
sys.exit(1)
# Instantiate the ShareClient from a connection string
from azure.storage.fileshare.aio import ShareClient
share = ShareClient.from_connection_string(self.connection_string, "filesamples2async")
# Create the share
async with share:
await share.create_share()
try:
# Get a file client and upload a file
source_file = share.get_file_client("sourcefile")
with open(SOURCE_FILE, "rb") as source:
await source_file.upload_file(source)
# Create another file client which will copy the file from url
destination_file = share.get_file_client("destinationfile")
# Build the url from which to copy the file
source_url = "https://{}.file.core.windows.net/{}/{}".format(
self.account_name,
'filesamples2async',
'sourcefile'
)
# Copy the sample source file from the url to the destination file
# [START copy_file_from_url]
await destination_file.start_copy_from_url(source_url=source_url)
# [END copy_file_from_url]
finally:
# Delete the share
await share.delete_share()
async def main():
sample = FileSamplesAsync()
await sample.simple_file_operations_async()
await sample.copy_file_from_url_async()
if __name__ == '__main__':
asyncio.run(main())
|
