从azure存储表js中检索1000多条记录

Question

我有一个检索一千多条记录的问题。不知怎的，只有前1000个被检索到。从我的研究中，我发现我必须使用getContinuation Token来获取后续记录。请告知我应该如何将其添加到我的代码中。

tableService.queryEntities(table, tableQuery, null, function(error, results) {
if (error) {
alert('List table entities error, please open browser console to view detailed error');
console.log(error);
} else {
//display records
});

Answer 1

要使用基于代码的回调，请使用递归。

var entities = [];
function queryEntitiesSegmented(table, tableQuery, continuationToken){
tableService.queryEntities(table, tableQuery, continuationToken, (error, results)=> {
if (error) {   console.log(error); } 
else { 
entities.push.apply(entities, results.entries);
if(results.continuationToken){
queryEntitiesSegmented(table, tableQuery, results.continuationToken);
}
else{
entities.forEach(entity=>{
// display each one
})
}
}
});
}
queryEntitiesSegmented(table, tableQuery, null);

另一种选择是异步和等待。

const queryEntitiesSegmented = async(table, tableQuery, continuationToken)=>{
return new Promise((resolve,reject)=>{
tableService.queryEntities(table, tableQuery, continuationToken, (error, results)=> {
if (error) {  reject(error); } 
else { resolve(results);  }
});
});
}
async function queryAllEntities(){
var tableQuery = new azure.TableQuery();
var table = 'tableName';
var continuationToken = null;
var entities = [];
do{
var results =  await queryEntitiesSegmented(table, tableQuery, continuationToken);
continuationToken = results.continuationToken;
entities.push.apply(entities, results.entries);
}
while(continuationToken!=null);
return entities;
}
queryAllEntities().then(entities=>{
entities.forEach(entity=>{
//display each one
})
}).catch(error=>{ console.log(error); })

Answer 2

如果你想使用它，我就为此创建了一个npm包。https://www.npmjs.com/package/azure-table-query-recursive

使用

const {queryAzureTableStorage, TableQuery, createTableService} = require('azure-table-query-recursive');
const validConnectionString = 'DefaultEndpointsProtocol=https;AccountName=xxxxxxx;AccountKey=xxxxxxxxxxxxxxxxxxxxxxx==;EndpointSuffix=core.windows.net';
const query = `PartitionKey eq 'apartitionkey'`;
const table = 'aTable';
//Constract a tableStorage object
const tableStorage = createTableService(validConnectionString);
//Constract an azure table query
const azureQuery = new TableQuery().where(query);
const tableResults = await queryAzureTableStorage(azureQuery, table, tableStorage);

Answer 3

以下工作在C#中：

var resultList = new List<T>();
TableQuery<T> query = new TableQuery<T>();
TableContinuationToken continuationToken = null;

var table = _tableClient.GetTableReference(tableName);
do
{
var token = continuationToken;
var queryResult = TryOperation(() => table.ExecuteQuerySegmented(new TableQuery<T>(), token), tableName);
if (queryResult != null)
{
resultList.AddRange(queryResult.Results);
continuationToken = queryResult.ContinuationToken;
}
} while (continuationToken != null);
return resultList;