Rod*_*phe 5 c# azure azure-table-storage
我正在尝试删除两个日期之间的所有实体(即2个分区键)WADLogsTable.到目前为止,我发现的最好的代码是这个(来自http://wintellect.com/blogs/jlane/deleting-entities-in-windows-azure-table-storage):
private static void DeleteAllEntitiesInBatches(CloudTable table, Expression<Func<DynamicTableEntity, bool>> filters)
{
Action<IEnumerable<DynamicTableEntity>> processor = entities =>
{
var batches = new Dictionary<string, TableBatchOperation>();
foreach (var entity in entities)
{
TableBatchOperation batch = null;
if (batches.TryGetValue(entity.PartitionKey, out batch) == false)
{
batches[entity.PartitionKey] = batch = new TableBatchOperation();
}
batch.Add(TableOperation.Delete(entity));
if (batch.Count == 100)
{
table.ExecuteBatch(batch);
batches[entity.PartitionKey] = new TableBatchOperation();
}
}
foreach (var batch in batches.Values)
{
if (batch.Count > 0)
{
table.ExecuteBatch(batch);
}
}
};
ProcessEntities(table, processor, filters);
}
private static void ProcessEntities(CloudTable table, Action<IEnumerable<DynamicTableEntity>> processor, Expression<Func<DynamicTableEntity, bool>> filters)
{
TableQuerySegment<DynamicTableEntity> segment = null;
while (segment == null || segment.ContinuationToken != null)
{
if (filters == null)
{
segment = table.ExecuteQuerySegmented(new TableQuery().Take(100), segment == null ? null : segment.ContinuationToken);
}
else
{
var query = table.CreateQuery<DynamicTableEntity>().Where(filters).Take(100).AsTableQuery();
segment = query.ExecuteSegmented(segment == null ? null : segment.ContinuationToken);
}
processor(segment.Results);
}
}
Run Code Online (Sandbox Code Playgroud)
但我不知道我应该传递什么作为"过滤器"参数.我想出了这个相当天真的尝试:
Expression<Func<DynamicTableEntity, bool>> filters = e => long.Parse(e.PartitionKey) >= startTicks && long.Parse(e.PartitionKey) <= endTicks;
Run Code Online (Sandbox Code Playgroud)
但这不起作用.在运行时,我收到以下错误:
表达式((Parse([10007] .PartitionKey)> = 635109048000000000)和(Parse([10007] .PartitionKey)<= 635115960000000000))不受支持.
我不知道我的问题是否与Azure表或Expression有关,但我们将不胜感激.
编辑:如果需要,我很乐意提供更多信息.
我在另一个论坛上得到了答案:
var startTicks = string.Format("{0:0000000000000000000}", start);
var endTicks = string.Format("{0:0000000000000000000}", end);
Expression<Func<DynamicTableEntity, bool>> filters = e => e.PartitionKey.CompareTo(startTicks) >= 0 && e.PartitionKey.CompareTo(endTicks) <= 0;
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
7045 次 |
| 最近记录: |