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
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
# 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.py
DESCRIPTION:
These samples demonstrate simple 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.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) AZURE_STORAGE_ACCOUNT_NAME - the name of the storage account
"""
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 FileSamples(object):
connection_string = os.getenv("STORAGE_CONNECTION_STRING")
account_name = os.getenv("STORAGE_ACCOUNT_NAME")
def simple_file_operations(self):
if self.connection_string is None:
print("Missing required environment variable: STORAGE_CONNECTION_STRING." + '\n' +
"Test: simple_file_operations")
sys.exit(1)
# Instantiate the ShareClient from a connection string
from azure.storage.fileshare import ShareClient
share = ShareClient.from_connection_string(self.connection_string, "filesamples1")
# Create the share
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)
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:
my_file.upload_file(source)
# [END upload_file]
# Download the file
# [START download_file]
with open(DEST_FILE, "wb") as data:
stream = my_file.download_file()
data.write(stream.readall())
# [END download_file]
# Delete the files
# [START delete_file]
my_file.delete_file()
# [END delete_file]
my_allocated_file.delete_file()
finally:
# Delete the share
share.delete_share()
def copy_file_from_url(self):
if self.connection_string is None:
print("Missing required environment variable: STORAGE_CONNECTION_STRING." + '\n' +
"Test: copy_file_from_url")
sys.exit(1)
# Instantiate the ShareClient from a connection string
from azure.storage.fileshare import ShareClient
share = ShareClient.from_connection_string(self.connection_string, "filesamples2")
# Create the share
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:
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,
"filesamples2",
"sourcefile"
)
# Copy the sample source file from the url to the destination file
# [START copy_file_from_url]
destination_file.start_copy_from_url(source_url=source_url)
# [END copy_file_from_url]
finally:
# Delete the share
share.delete_share()
def acquire_file_lease(self):
if self.connection_string is None:
print("Missing required environment variable: STORAGE_CONNECTION_STRING." + '\n' +
"Test: acquire_file_lease")
sys.exit(1)
# Instantiate the ShareClient from a connection string
from azure.storage.fileshare import ShareClient
share = ShareClient.from_connection_string(self.connection_string, "filesamples3")
# Create the share
share.create_share()
try:
# Get a file client and upload a file
source_file = share.get_file_client("sourcefile")
# [START acquire_and_release_lease_on_file]
source_file.create_file(1024)
lease = source_file.acquire_lease()
source_file.upload_file(b'hello world', lease=lease)
lease.release()
# [END acquire_and_release_lease_on_file]
finally:
# Delete the share
share.delete_share()
if __name__ == '__main__':
sample = FileSamples()
sample.simple_file_operations()
sample.copy_file_from_url()
sample.acquire_file_lease()
|
