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
|
# 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: blob_samples_walk_blob_hierarchy.py
DESCRIPTION:
This example walks the containers and blobs within a storage account,
displaying them in a hierarchical structure and, when present, showing
the number of snapshots that are available per blob. This sample expects
that the `STORAGE_CONNECTION_STRING` environment variable is set.
It SHOULD NOT be hardcoded in any code derived from this sample.
USAGE: python blob_samples_walk_blob_hierarchy.py
Set the environment variables with your own values before running the sample:
1) STORAGE_CONNECTION_STRING - the connection string to your storage account
EXAMPLE OUTPUT:
C: container1
F: folder1/
F: subfolder1/
B: test.rtf
B: test.rtf
F: folder2/
B: test.rtf
B: test.rtf (1 snapshots)
B: test2.rtf
C: container2
B: demovid.mp4
B: mountain.jpg
C: container3
C: container4
"""
import os
import sys
from azure.storage.blob import BlobServiceClient
from azure.storage.blob import BlobPrefix
try:
CONNECTION_STRING = os.environ['STORAGE_CONNECTION_STRING']
except KeyError:
print("STORAGE_CONNECTION_STRING must be set.")
sys.exit(1)
def walk_container(client, container):
container_client = client.get_container_client(container.name)
print('C: {}'.format(container.name))
depth = 1
separator = ' '
def walk_blob_hierarchy(prefix=""):
nonlocal depth
for item in container_client.walk_blobs(name_starts_with=prefix):
short_name = item.name[len(prefix):]
if isinstance(item, BlobPrefix):
print('F: ' + separator * depth + short_name)
depth += 1
walk_blob_hierarchy(prefix=item.name)
depth -= 1
else:
message = 'B: ' + separator * depth + short_name
results = list(container_client.list_blobs(name_starts_with=item.name, include=['snapshots']))
num_snapshots = len(results) - 1
if num_snapshots:
message += " ({} snapshots)".format(num_snapshots)
print(message)
walk_blob_hierarchy()
try:
service_client = BlobServiceClient.from_connection_string(CONNECTION_STRING)
containers = service_client.list_containers()
for container in containers:
walk_container(service_client, container)
except Exception as error:
print(error)
sys.exit(1)
|
