logo标签列表

当一个字符串长度超过32768个字符时，Azure存储会抛出异常。

c#asp.netazureasp.net-coreazure-table-storage
3

我的应用程序是一个ASP.NET Core 1.0 Web API。如果我的控制器返回一个小字符串，一切都正常。但如果字符串长度超过32768，我会收到以下错误消息：

--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Server.Kestrel.Internal.Htpp.Frame`1.<RequestProcessAsync>d__2.MoveNext()
Request Information
RequestID:440ed7db-0002-006f-742e-a28f82000000
RequestDate:Tue, 21 Mar 2017 11:30:40 GMT
StatusMessage:Bad Request
ErrorCode:PropertyValueTooLarge

这是我的控制器：
[HttpGet]
[Produces("plain/text")]
public async Task<IActionResult> GetData()
{
    return this.Ok(this.GetResponse());
}

private string GetResponse()
{
    string retVal = string.Empty;
    for (int i = 0; i < 32769; i++)
    {
        retVal = retVal + "a";
    }
    return retVal;
}

完整的错误信息：
Microsoft.WindowsAzure.Storage.StorageException: BadRequest
   at Microsoft.WindowsAzure.Storage.Core.Executor.Executor.<ExecuteAsyncInternal>d__4`1.MoveNext() in C:\Program Files (x86)\Jenkins\workspace\release_dotnet_master\Lib\Windows Runtime\Core\Executor\Executor.cs:line 315
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter`1.GetResult()
   at MyProjectNameLogging.AzureStorageLoggingConnector.<WriteToRequestLogAsync>d__4.MoveNext() in AzureStorageLoggingTable.cs:line 29
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.GetResult()
   at MyProjectNameLogging.Repositories.RequestLoggingRepository.<WriteToLogAsync>d__6.MoveNext() in Repositories\RequestLoggingRepository.cs:line 36
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.GetResult()
   at MyProjectNameLogging.Middleware.RequestMiddleware.<Invoke>d__2.MoveNext() in Middleware\RequestMiddleware.cs:line 69
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Swashbuckle.SwaggerUi.Application.SwaggerUiMiddleware.<Invoke>d__5.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Swashbuckle.SwaggerUi.Application.RedirectMiddleware.<Invoke>d__4.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Swashbuckle.Swagger.Application.SwaggerMiddleware.<Invoke>d__6.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at Microsoft.AspNetCore.Authentication.AuthenticationMiddleware`1.<Invoke>d__18.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Cors.Infrastructure.CorsMiddleware.<Invoke>d__7.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Server.IISIntegration.IISMiddleware.<Invoke>d__8.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Server.Hosting.Internal.RequestServiceContainerMiddleware.<Invoke>d__3.MoveNext()
--- End of stack trace previous location where exception was thrown ---
   at System.Runtime.CompillerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
   at System.Runtime.CompillerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.AspNetCore.Server.Kestrel.Internal.Htpp.Frame`1.<RequestProcessAsync>d__2.MoveNext()
Request Information
RequestID:6d8afaf4-0002-00cd-1235-a2421e000000
RequestDate:Tue, 21 Mar 2017 12:24:57 GMT
StatusMessage:Bad Request
ErrorCode:PropertyValueTooLarge

我希望能够返回长度超过32768的字符串。 有什么建议吗？
1
虽然这不会对您有所帮助，但如果错误消息以文本形式而非图像形式出现在搜索结果中，其他人可能会受益，因为他们遇到相同的问题时可以更容易地找到答案。这甚至可能会为您和任何回答问题的人带来一些赞！ - Adrian Wragg
Ok()是什么？ - Jury Golubev
@bl4y 我已经添加了它们 :) - Moritz Schmidt
1
@MoritzSchmidt 只是提供信息，我刚刚运行了相同的代码，无论是原样还是将其从“a”更改为“aa”，两次都可以正常工作。我正在Docker中运行；我不确定这是否有所不同。 - Adrian Wragg
1
看起来你遇到了与Azure相关的问题，因此特别标记一下可能是值得的。这个错误（PropertyValueTooLarge）会带出很多与Azure相关的内容，而你的文件名也提到了Azure。 - Adrian Wragg
显示剩余2条评论
3个回答
9
您遇到了 Azure 存储字符串属性类型的限制（来源）：

Edm.String (String) - 一个 UTF-16 编码值。字符串值的大小最多可以达到 64 KB。

由于 UTF-16 编码的字符串需要 2 个字节来存储一个字符，因此最大字符串长度为 32768 个字符。

原來我試圖記錄我正在回應 Azure 的內容，但由於64KB的限制，這是不可能的。再次感謝你，你為我節省了很多時間。 - Moritz Schmidt
1
使用BLOB存储来记录数据。Azure存储服务（Blob Service）。 - Yoh Deadfall
事实证明，我尝试记录我正在响应的数据，但由于64KB限制，这是不可能的。再次感谢您，您为我节省了许多时间。 - Moritz Schmidt
这种情况发生的原因是什么？我用相同的数据（字符串大小约为200Kb）尝试了几次，有时会抛出异常，有时又能正常工作。你有什么想法吗？ - Moritz Schmidt
1
@Moritz，我不知道。请向Azure支持团队提出这个问题。他们应该知道他们的代码是如何工作的。 - Yoh Deadfall
2
尽管此问题已有答案，但我想为可能遇到此线程的其他人提供解决方案。我需要在我的表实体中存储比64k更多的单个属性。我在网上找到了几个关于Lokad Fat Entities的参考资料，但似乎它不再得到积极支持，并且我在NuGet.org上可用的版本中遇到了运行时错误。因此，这是一个受Lokad解决方案启发的类。我希望其他人也会发现它有用。
    public class ExtEntity<T> : TableEntity where T : new()
{
    private const int MAX_BYTES_PER_ARR = 65500; // don't use full 64k to avoid any weird edge case

    // Serialized in DB and deserialized for callers
    public Byte[] A0 { get; set; }
    public Byte[] A1 { get; set; }
    public Byte[] A2 { get; set; }
    public Byte[] A3 { get; set; }
    public Byte[] A4 { get; set; }
    public Byte[] A5 { get; set; }
    public Byte[] A6 { get; set; }
    public Byte[] A7 { get; set; }
    public Byte[] A8 { get; set; }
    public Byte[] A9 { get; set; }
    public Byte[] A10 { get; set; }
    public Byte[] A11 { get; set; }
    public Byte[] A12 { get; set; }
    public Byte[] A13 { get; set; }
    public Byte[] A14 { get; set; }
    public Byte[] A15 { get; set; }
    private T value;

    public T Value
    {
        // Accessors automatically serialize and deserialize T value
        get
        {
            // ASSUMES that value will never change after first time deserialized!
            if (this.value == null)
            {
                int n = 0;
                using (var memStream = new MemoryStream())
                {
                    while (true)
                    {
                        string propName = "A" + n++;
                        PropertyInfo prop = this.GetType().GetProperty(propName);
                        byte[] arr = (byte[])prop.GetValue(this);
                        if (arr == null || arr.Length == 0)
                        {
                            break;
                        }
                        memStream.Write(arr, 0, arr.Length);
                    }
                    memStream.Seek(0, SeekOrigin.Begin);
                    var binForm = new BinaryFormatter();
                    this.value = (T)binForm.Deserialize(memStream);
                }
            }
            return this.value;
        }
        set
        {
            // First, ensure the type is serializable.
            if (!typeof(T).IsSerializable && !(typeof(ISerializable).IsAssignableFrom(typeof(T))))
                throw new InvalidOperationException("ExtEntity<T>.get_Value Exception: A serializable Type is required.");

            // Assign the value
            this.value = value;

            // Then searialize it for Table Storage use
            BinaryFormatter bf = new BinaryFormatter();
            using (var memStream = new MemoryStream())
            {
                // Serialize into memory stream, then seek back to origin
                bf.Serialize(memStream, this.value);
                memStream.Seek(0, SeekOrigin.Begin);

                // Chunk data from memory stream into stored properties
                int bytesRemaining = (int)memStream.Length;
                int n = 0;
                while (bytesRemaining > 0)
                {
                    if (n > 15)
                    {
                        throw new ApplicationException("ExtEntity<T>.set_Value Exception: Data is too large.");
                    }
                    int numToRead = Math.Min(bytesRemaining, ExtEntity<T>.MAX_BYTES_PER_ARR);
                    byte[] arr = new byte[numToRead];
                    int numRead = memStream.Read(arr, 0, numToRead);
                    if (numRead != numToRead)
                    {
                        throw new ApplicationException("ExtEntity<T>.set_Value Exception: Unexpected number of bytes returned.");
                    }

                    string propName = "A" + n++;
                    PropertyInfo prop = this.GetType().GetProperty(propName);
                    prop.SetValue(this, arr);
                    bytesRemaining -= numRead;
                }
            }
        }
    }
}

使用示例：

public class RawDataBlockEntity : ExtEntity<RawDataBlock>
{
    public RawDataBlockEntity(string rawDataId, string blockId, RawDataBlock block)
    {
        this.PartitionKey = rawDataId;
        this.RowKey = blockId;

        this.Value = block;
    }

    public RawDataBlockEntity() { }
}
1

试试这个：

return new ContentResult { Content = this.GetResponse(), StatusCode = 200 };
任何解释？ - D.Rosado
网页内容由stack overflow 提供, 点击上面的
可以查看英文原文，
原文链接