本文整理汇总了C#中ICloudBlob类的典型用法代码示例。如果您正苦于以下问题:C# ICloudBlob类的具体用法?C# ICloudBlob怎么用?C# ICloudBlob使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ICloudBlob类属于命名空间,在下文中一共展示了ICloudBlob类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: Write
public async Task Write(ICloudBlob blob, string content)
{
using (Stream stream = new MemoryStream(Encoding.UTF8.GetBytes(content)))
{
await blob.UploadFromStreamAsync(stream);
}
}
开发者ID:abatishchev,项目名称:ab,代码行数:7,代码来源:AzureBlobClient.cs
示例2: UpdateBlob
public UpdateBlob(ICloudBlob blob, IBlobLeaseFactory blobLeaseFactory)
{
_blob = blob;
_blobLeaseFactory = blobLeaseFactory;
_updateDomain = string.Empty;
_instanceIds = new HashSet<string>();
}
开发者ID:Microsoft,项目名称:Yams,代码行数:7,代码来源:UpdateBlob.cs
示例3: Create
/// <summary>
/// Creates a new instance from a ICloudBlob.
/// </summary>
/// <param name="original">The original cloud blob.</param>
/// <returns></returns>
public static AzureBlobInfo Create(ICloudBlob original)
{
var file = original as CloudBlockBlob;
if (file != null)
{
var modified = DateTimeOffset.MinValue;
var modifiedOk = false;
if (file.Metadata.ContainsKey("CbModifiedTime"))
{
modifiedOk = DateTimeOffset.TryParse(file.Metadata["CbModifiedTime"], out modified);
}
return new AzureBlobInfo
{
BlobElement = file,
ContentType = file.Properties.ContentType,
Name = file.Name,
Size = file.Properties.Length,
Location = file.Uri.AbsoluteUri,
ModifiedTime = modifiedOk ? modified : default(DateTimeOffset?)
};
}
var folder = original as CloudBlobDirectory;
if (folder == null)
{
return null;
}
return new AzureBlobInfo
{
Name = folder.Prefix,
Location = folder.Uri.AbsoluteUri
};
}
开发者ID:codingfreak,项目名称:cfUtils,代码行数:37,代码来源:AzureBlobInfo.cs
示例4: AzureIndexInput
public AzureIndexInput(AzureDirectory azuredirectory, ICloudBlob blob)
: base(blob.Name)
{
_name = blob.Uri.Segments[blob.Uri.Segments.Length - 1];
_fileMutex = BlobMutexManager.GrabMutex(_name);
_fileMutex.WaitOne();
try
{
_azureDirectory = azuredirectory;
_blobContainer = azuredirectory.BlobContainer;
_blob = blob;
string fileName = _name;
StreamOutput fileStream = _azureDirectory.CreateCachedOutputAsStream(fileName);
// get the blob
_blob.DownloadToStream(fileStream);
fileStream.Flush();
Debug.WriteLine("GET {0} RETREIVED {1} bytes", _name, fileStream.Length);
fileStream.Close();
// and open it as an input
_indexInput = CacheDirectory.openInput(fileName, IOContext.DEFAULT);
}
finally
{
_fileMutex.ReleaseMutex();
}
}
开发者ID:JayBeavers,项目名称:AzureDirectory,代码行数:33,代码来源:AzureIndexInput.cs
示例5: CreateBlobIfNoneExists
private static async Task CreateBlobIfNoneExists(ICloudBlob updateBlob)
{
if (!await updateBlob.ExistsAsync())
{
await BlobUtils.CreateEmptyBlob(updateBlob);
}
}
开发者ID:Microsoft,项目名称:Yams,代码行数:7,代码来源:UpdateBlobFactory.cs
示例6: DownloadText
public static string DownloadText(ICloudBlob blob, Encoding encoding, AccessCondition accessCondition = null, BlobRequestOptions options = null, OperationContext operationContext = null)
{
using (MemoryStream stream = new MemoryStream())
{
blob.DownloadToStream(stream, accessCondition, options, operationContext);
return encoding.GetString(stream.ToArray());
}
}
开发者ID:Juliako,项目名称:azure-sdk-for-net,代码行数:8,代码来源:BlobTestBase35.cs
示例7: Read
public async Task<string> Read(ICloudBlob blob)
{
using (Stream stream = await blob.OpenReadAsync())
using (StreamReader reader = new StreamReader(stream))
{
return await reader.ReadToEndAsync();
}
}
开发者ID:abatishchev,项目名称:ab,代码行数:8,代码来源:AzureBlobClient.cs
示例8: UploadTextAsync
static async Task UploadTextAsync(ICloudBlob blob, string text, AccessCondition accessCondition)
{
blob.Properties.ContentEncoding = "UTF-8";
blob.Properties.ContentType = "text/plain";
using (var stream = new MemoryStream(Encoding.UTF8.GetBytes(text))) {
await blob.UploadFromStreamAsync(stream, accessCondition, null, null);
}
}
开发者ID:cskardon,项目名称:SnowMaker,代码行数:8,代码来源:BlobOptimisticDataStoreAsync.cs
示例9: DownloadTextAsync
public static async Task<string> DownloadTextAsync(ICloudBlob blob, Encoding encoding, AccessCondition accessCondition = null, BlobRequestOptions options = null, OperationContext operationContext = null)
{
using (MemoryStream stream = new MemoryStream())
{
await blob.DownloadToStreamAsync(stream.AsOutputStream(), accessCondition, options, operationContext);
byte[] buffer = stream.ToArray();
return encoding.GetString(buffer, 0, buffer.Length);
}
}
开发者ID:Juliako,项目名称:azure-sdk-for-net,代码行数:9,代码来源:BlobTestBaseRT.cs
示例10: GetDownloadUrlFor
/// <summary>
/// Return a secret, persistent Download Url for a given Blob
/// </summary>
static string GetDownloadUrlFor(ICloudBlob blob)
{
var signature = blob.GetSharedAccessSignature(new SharedAccessBlobPolicy
{
SharedAccessExpiryTime = new DateTime(2050, 1, 1, 0, 0, 0, 0, DateTimeKind.Utc)
}, DownloadPolicyName);
return string.Format("{0}{1}", blob.Uri.ToString().Replace(" ", "%20"), signature);
}
开发者ID:Plasma,项目名称:AzureBlobUtility,代码行数:12,代码来源:Program.cs
示例11: UploadText
static void UploadText(ICloudBlob blob, string text, AccessCondition accessCondition)
{
blob.Properties.ContentEncoding = "UTF-8";
blob.Properties.ContentType = "text/plain";
using (var stream = new MemoryStream(Encoding.UTF8.GetBytes(text)))
{
blob.UploadFromStream(stream, accessCondition);
}
}
开发者ID:cskardon,项目名称:SnowMaker,代码行数:9,代码来源:BlobOptimisticDataStore.cs
示例12: WaitForCopyAsync
public static async Task WaitForCopyAsync(ICloudBlob blob)
{
bool copyInProgress = true;
while (copyInProgress)
{
await Task.Delay(1000);
await blob.FetchAttributesAsync();
copyInProgress = (blob.CopyState.Status == CopyStatus.Pending);
}
}
开发者ID:huoxudong125,项目名称:azure-sdk-for-net,代码行数:10,代码来源:BlobTestBase.cs
示例13: AzureStorageBlob
/// <summary>
/// Azure storage blob constructor
/// </summary>
/// <param name="blob">ICloud blob object</param>
public AzureStorageBlob(ICloudBlob blob)
{
Name = blob.Name;
ICloudBlob = blob;
BlobType = blob.BlobType;
Length = blob.Properties.Length;
ContentType = blob.Properties.ContentType;
LastModified = blob.Properties.LastModified;
SnapshotTime = blob.SnapshotTime;
}
开发者ID:thomasyip-msft,项目名称:azure-powershell,代码行数:14,代码来源:AzureStorageBlob.cs
示例14: WaitForCopyTask
public static void WaitForCopyTask(ICloudBlob blob)
{
bool copyInProgress = true;
while (copyInProgress)
{
Thread.Sleep(1000);
blob.FetchAttributesAsync().Wait();
copyInProgress = (blob.CopyState.Status == CopyStatus.Pending);
}
}
开发者ID:huoxudong125,项目名称:azure-sdk-for-net,代码行数:10,代码来源:BlobTestBase.cs
示例15: CreateCopyJob
/// <summary>
/// Creates a job to copy from a blob.
/// </summary>
/// <param name="destBlob">Destination blob to copy to.
/// User should call the method on this object.</param>
/// <param name="sourceBlob">Source blob to copy from.</param>
/// <returns>Job object to do copying.</returns>
public static BlobCopyJob CreateCopyJob(
this ICloudBlob destBlob,
ICloudBlob sourceBlob)
{
return new BlobCopyJob()
{
SourceBlob = sourceBlob,
DestBlob = destBlob
};
}
开发者ID:ggais,项目名称:azure-storage-net-data-movement,代码行数:17,代码来源:CloudBlobExtensions.cs
示例16: SetValidUntil
//https://github.com/Particular/NServiceBus.Azure/blob/e9db29beb21d1fd914191e479cb5948fffd92f3b/src/NServiceBus.Azure/DataBus/Azure/BlobStorage/BlobStorageDataBus.cs#L41
protected override void SetValidUntil(ICloudBlob cloudBlob, TimeSpan timeToBeReceived)
{
if (timeToBeReceived == TimeSpan.MaxValue)
{
cloudBlob.Metadata["ValidUntil"] = TimeSpan.MaxValue.ToString();
}
else
{
cloudBlob.Metadata["ValidUntil"] = (DateTime.Now + timeToBeReceived).ToString();
}
}
开发者ID:jberke,项目名称:NServiceBus.Azure,代码行数:12,代码来源:ValidUntilV2BlobStorageDataBusTests.cs
示例17: GetSasUrl
public static string GetSasUrl(ICloudBlob blob, SharedAccessBlobPermissions permissions)
{
var policy = new SharedAccessBlobPolicy
{
SharedAccessExpiryTime = DateTime.Now.AddMinutes(30),
Permissions = permissions
};
string sasBlobToken = blob.GetSharedAccessSignature(policy);
//Return the URI string for the container, including the SAS token.
return blob.Uri + sasBlobToken;
}
开发者ID:Plasma,项目名称:AzureSpeed,代码行数:11,代码来源:StorageUtils.cs
示例18: OperationHandle
/// <summary>
/// Initializes a new instance of <see cref="OperationHandle" /> class.
/// </summary>
/// <param name="source">A source blob.</param>
/// <param name="target">A destination blob.</param>
/// <param name="sasToken">A security access token.</param>
public OperationHandle(ICloudBlob source, ICloudBlob target, String sasToken)
{
DeleteIsCompleted = false;
CopyIsCompleted = false;
SourceBlob = source;
TargetBlob = target;
this.sasToken = sasToken;
}
开发者ID:stas-sultanov,项目名称:SXN.Azure,代码行数:18,代码来源:OperationHandle.cs
示例19: UpdateBlob
private static async Task UpdateBlob(ICloudBlob blob)
{
try
{
byte[] dataBytes = new byte[40];
await blob.UploadFromByteArrayAsync(dataBytes, 0, 40);
}
catch (Exception e)
{
Console.WriteLine(e);
}
}
开发者ID:benaadams,项目名称:TestCase-AzureStorageHandles,代码行数:12,代码来源:Program.cs
示例20: BlobReadStreamBase
/// <summary>
/// Initializes a new instance of the BlobReadStreamBase class.
/// </summary>
/// <param name="blob">Blob reference to read from</param>
/// <param name="accessCondition">An object that represents the access conditions for the blob. If null, no condition is used.</param>
/// <param name="options">An object that specifies any additional options for the request.</param>
/// <param name="operationContext">An <see cref="OperationContext"/> object for tracking the current operation.</param>
protected BlobReadStreamBase(ICloudBlob blob, AccessCondition accessCondition, BlobRequestOptions options, OperationContext operationContext)
{
this.blob = blob;
this.isLengthAvailable = false;
this.currentOffset = 0;
this.buffer = new MemoryStream();
this.accessCondition = accessCondition;
this.lockedToETag = false;
this.options = options;
this.operationContext = operationContext;
this.blobMD5 = options.DisableContentMD5Validation.Value ? null : new MD5Wrapper();
this.lastException = null;
}
开发者ID:Juliako,项目名称:azure-sdk-for-net,代码行数:20,代码来源:BlobReadStreamBase.cs
注:本文中的ICloudBlob类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论