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
|
#region Disclaimer / License
// Copyright (C) 2015, The Duplicati Team
// http://www.duplicati.com, info@duplicati.com
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
//
#endregion
using System.Collections.Generic;
using System.IO;
using System.Linq;
using Duplicati.Library.Interface;
using Duplicati.Library.Utility;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Blob;
namespace Duplicati.Library.Backend.AzureBlob
{
/// <summary>
/// Azure blob storage facade.
/// </summary>
public class AzureBlobWrapper
{
private readonly string _containerName;
private readonly CloudBlobContainer _container;
public AzureBlobWrapper(string accountName, string accessKey, string containerName)
{
_containerName = containerName;
var connectionString = string.Format("DefaultEndpointsProtocol=https;AccountName={0};AccountKey={1}",
accountName, accessKey);
var storageAccount = CloudStorageAccount.Parse(connectionString);
var blobClient = storageAccount.CreateCloudBlobClient();
_container = blobClient.GetContainerReference(containerName);
}
public void AddContainer()
{
_container.Create(BlobContainerPublicAccessType.Off);
}
public virtual void GetFileStream(string keyName, Stream target)
{
_container.GetBlockBlobReference(keyName).DownloadToStream(target);
}
public void GetFileObject(string keyName, string localfile)
{
_container.GetBlockBlobReference(keyName).DownloadToFile(localfile, FileMode.Create);
}
public void AddFileObject(string keyName, string localfile)
{
using (var fs = File.Open(localfile, FileMode.Open, FileAccess.Read, FileShare.Read))
{
AddFileStream(keyName, fs);
}
}
public virtual void AddFileStream(string keyName, Stream source)
{
_container.GetBlockBlobReference(keyName).UploadFromStream(source);
}
public void DeleteObject(string keyName)
{
_container.GetBlockBlobReference(keyName).DeleteIfExists();
}
public virtual List<IFileEntry> ListContainerEntries()
{
var listBlobItems = _container.ListBlobs(blobListingDetails: BlobListingDetails.Metadata);
try
{
return listBlobItems.Select(x =>
{
var absolutePath = x.StorageUri.PrimaryUri.AbsolutePath;
var containerSegment = string.Concat("/", _containerName, "/");
var blobName = absolutePath.Substring(absolutePath.IndexOf(
containerSegment, System.StringComparison.Ordinal) + containerSegment.Length);
try
{
if (x is CloudBlockBlob)
{
var cb = (CloudBlockBlob)x;
var modified = cb.Properties.LastModified;
var lastModified = new System.DateTime();
if (cb.Properties.LastModified != null)
lastModified = new System.DateTime(cb.Properties.LastModified.Value.Ticks, System.DateTimeKind.Utc);
return new FileEntry(Uri.UrlDecode(blobName.Replace("+", "%2B")), cb.Properties.Length, lastModified, lastModified);
}
}
catch
{
// If the metadata fails to parse, return the basic entry
}
return new FileEntry(Uri.UrlDecode(blobName.Replace("+", "%2B")));
})
.Cast<IFileEntry>()
.ToList();
}
catch (StorageException ex)
{
if (ex.RequestInformation.HttpStatusCode == 404)
{
throw new FolderMissingException(ex);
}
throw;
}
}
}
}
|
