从 Azure 表存储中检索记录抛出未设置对象引用

Question

我有非常简单的代码来从表存储中检索所有项目。下面的代码因对象引用未设置异常而失败

    public async Task<List<StringInternTableEntity>> GetAllRowsAsync()
    {
        var entities = new List<StringInternTableEntity>();

        try
        {
            TableContinuationToken token = null;
            do
            {
                var queryResult = await this.azureCloudTable.ExecuteQuerySegmentedAsync(new TableQuery<StringInternTableEntity>(), token);
                entities.AddRange(queryResult.Results);
                token = queryResult.ContinuationToken;
            } while (token != null);

        }
        catch (Exception ex)
        {
            return null;
        }

        return entities;
    }

public class StringInternTableEntity : TableEntity
{
    public StringInternTableEntity()
    {
    }

    public StringInternTableEntity(string runStartTimeStamp, string wordKey)
    {
        PartitionKey = runStartTimeStamp;
        RowKey = wordKey;
    }

    public int NumberValue { get; set; }
}

" 在 Microsoft.Azure.Cosmos.Table.Extensions.TableExtensionExecutor。c__DisplayClass24_02.<<ExecuteQuerySegmentedInternalAsync>b__0>d.MoveNext()\r\n at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()\r\n at Microsoft.Azure.Cosmos.Table.Extensions.TableExtensionRetryPolicy.<ExecuteUnderRetryPolicy>d__21.MoveNext()\r\n 在 System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()\r\n 在 System .Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)\r\n 在 System.Runtime.CompilerServices.TaskAwaiter`1.GetResult()\r\n 在 Citadel.Common.Utils.AzureCloudTableHelper.d__9.MoveNext() :\Users\kalsa\source\repos\Citadel3\Citadel.Common\Utils\AzureCloudTableHelper.cs:line 166"

另外，在我的表中，我有 1 个简单的条目。

Answer 1

你可以试试下面的代码，我修改了检索数据的逻辑并最终将其存储到列表中

 public async Task<List<StringInternTableEntity>> GetAllRowsAsync()
        {
             var query = this.azureCloudTable.CreateQuery<StringInternTableEntity>();
                var result = new List<StringInternTableEntity>();
                var token = new TableContinuationToken();
                do
                {
                    var segment = await this.azureCloudTable.ExecuteQuerySegmentedAsync(query, token);
                    token = segment.ContinuationToken;
                    result.AddRange(segment);
                } while (token != null);
                List<StringInternTableEntity> lstClientID = new List<StringInternTableEntity>();
                foreach (StringInternTableEntity codeMapping in result)
                {
                    lstClientID.Add(codeMapping);
                }
                return lstClientID;
        }