2

我想直接使用流上传到我的天蓝色本地开发帐户。我为 azure blob 存储创建了一个类。

public class AzureBlob
{
    delegate void UploadFinished(IAsyncResult result);
    public void uploadFile()
    {
        //Initial configuration
        CloudStorage account = CloudStorageAccount.DevelopmentStorageAccount;
        CloudBlobClient client = account.CreateBlobClient();
        CloudBlobContainer container = client.GetContainerReference("myfiles");
        Stream stream = new MemoryStream();

        //Upload to azure
        CloudBlob blob = container.GetBlobReference("sample.txt");
        UploadFinished uploadFinished = delegate(IAsyncResult result)
        {
            Console.WriteLine("Upload finished {0} {1}", result.IsCompleted, stream.Position);
        };
        blob.BeginUploadFromStream(stream, new AsyncCallback(uploadFinished));

        //Write to stream
        for(int i=0;i<100;i++)
        {
            for(int j=0;j<50;j++)
            {
                stream.WriteByte(65);
            }
        }
        stream.Close();


    }
}

我面临的第一个问题是我在存储中获取了文件，但它不包含任何数据。即使我在回调中使用 EndOfUploadStream 方法（根据一些stackoverflow答案是一个解决方案）。其次，我将断点放在回调中，我发现回调在我关闭流之前执行了一次，并且程序不断更新流。此时流位置在 913 左右（大部分是随机的）。请帮助我直接通过流异步上传 blob。

4

2 回答 2

2

在我看来，您有比赛条件。您在实际将内容放入其中之前就开始上传流。

你可能想要这样的东西：

Stream stream = new MemoryStream();

//Write to stream
for(int i=0;i<100;i++)
{
    for(int j=0;j<50;j++)
    {
        stream.WriteByte(65);
    }
}
stream.SetPosition(0); // <-- need to reset stream position to 0 before uploading

//Upload to azure
CloudBlob blob = container.GetBlobReference("sample.txt");
UploadFinished uploadFinished = delegate(IAsyncResult result)
{
    blob.EndUploadFromStream(result); // <-- have to call this in your handler
    Console.WriteLine("Upload finished {0} {1}", result.IsCompleted, stream.Position);
};
blob.BeginUploadFromStream(stream, new AsyncCallback(uploadFinished));
于 2012-12-15T16:57:40.190 回答
2

smarx的好答案！此外，将 stream.Close() 移动到回调中。

delegate void BeginUploadFinished(IAsyncResult result);
public void UploadFile()
{
    //Initial configuration
    var account = CloudStorageAccount.DevelopmentStorageAccount;
    var client = account.CreateCloudBlobClient();
    var container = client.GetContainerReference("myfiles");
    Stream stream = new MemoryStream();
    var state = new Object{};

    //Upload to azure
    var blob = container.GetBlobReference("test.txt");
    BeginUploadFinished beginUploadFinished = delegate(IAsyncResult result)
    {
        blob.EndUploadFromStream(result);
        Trace.WriteLine("EndUploadFromStream", "Information");
        stream.Close();
        stream.Dispose();
    };

    //Write to stream
    Trace.WriteLine("Writing Stream", "Information");
    for (var i = 0; i < 100; i++)
    {
        for (var j = 0; j < 50; j++)
        {
            stream.WriteByte(65);
        }
    }
    stream.Seek(0, SeekOrigin.Begin);

    Trace.WriteLine("BeginUploadFromStream", "Information");
    var _result =  blob.BeginUploadFromStream(stream, new AsyncCallback(beginUploadFinished), state);
    _result.AsyncWaitHandle.WaitOne();
}
于 2012-12-15T18:54:34.180 回答