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_directory.py
DESCRIPTION:
These samples demonstrate directory operations like creating a directory
or subdirectory, and working on files within the directories.
USAGE:
python file_samples_directory.py
Set the environment variables with your own values before running the sample:
1) STORAGE_CONNECTION_STRING - the connection string to your 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 DirectorySamples(object):
connection_string = os.getenv('STORAGE_CONNECTION_STRING')
def create_directory_and_file(self):
if self.connection_string is None:
print("Missing required environment variable: STORAGE_CONNECTION_STRING." + '\n' +
"Test: create_directory_and_file")
sys.exit(1)
# Instantiate the ShareClient from a connection string
from azure.storage.fileshare import ShareClient
share = ShareClient.from_connection_string(self.connection_string, "directorysamples1")
# Create the share
share.create_share()
try:
# Get the directory client
my_directory = share.get_directory_client(directory_path="mydirectory")
# [START create_directory]
my_directory.create_directory()
# [END create_directory]
# [START upload_file_to_directory]
# Upload a file to the directory
with open(SOURCE_FILE, "rb") as source:
my_directory.upload_file(file_name="sample", data=source)
# [END upload_file_to_directory]
# [START delete_file_in_directory]
# Delete the file in the directory
my_directory.delete_file(file_name="sample")
# [END delete_file_in_directory]
# [START delete_directory]
my_directory.delete_directory()
# [END delete_directory]
finally:
# Delete the share
share.delete_share()
def create_subdirectory_and_file(self):
if self.connection_string is None:
print("Missing required environment variable: STORAGE_CONNECTION_STRING." + '\n' +
"Test: create_subdirectory_and_file")
sys.exit(1)
# Instantiate the ShareClient from a connection string
from azure.storage.fileshare import ShareClient
share = ShareClient.from_connection_string(self.connection_string, "directorysamples2")
# Create the share
share.create_share()
try:
# Get the directory client
parent_dir = share.get_directory_client(directory_path="parentdir")
# [START create_subdirectory]
# Create the directory
parent_dir.create_directory()
# Create a subdirectory
subdir = parent_dir.create_subdirectory("subdir")
# [END create_subdirectory]
# Upload a file to the parent directory
with open(SOURCE_FILE, "rb") as source:
parent_dir.upload_file(file_name="sample", data=source)
# Upload a file to the subdirectory
with open(SOURCE_FILE, "rb") as source:
subdir.upload_file(file_name="sample", data=source)
# [START lists_directory]
# List the directories and files under the parent directory
my_list = list(parent_dir.list_directories_and_files())
print(my_list)
# [END lists_directory]
# You must delete the file in the subdirectory before deleting the subdirectory
subdir.delete_file("sample")
# [START delete_subdirectory]
parent_dir.delete_subdirectory("subdir")
# [END delete_subdirectory]
finally:
# Delete the share
share.delete_share()
def get_subdirectory_client(self):
if self.connection_string is None:
print("Missing required environment variable: STORAGE_CONNECTION_STRING." + '\n' +
"Test: get_subdirectory_client")
sys.exit(1)
# Instantiate the ShareClient from a connection string
from azure.storage.fileshare import ShareClient
share = ShareClient.from_connection_string(self.connection_string, "directorysamples3")
# Create the share
share.create_share()
try:
# [START get_subdirectory_client]
# Get a directory client and create the directory
parent = share.get_directory_client("dir1")
parent.create_directory()
# Get a subdirectory client and create the subdirectory "dir1/dir2"
subdirectory = parent.get_subdirectory_client("dir2")
subdirectory.create_directory()
# [END get_subdirectory_client]
finally:
# Delete the share
share.delete_share()
if __name__ == '__main__':
sample = DirectorySamples()
sample.create_directory_and_file()
sample.create_subdirectory_and_file()
sample.get_subdirectory_client()
|
