使用.NET开发工具包在Cosmos DB中支持批量删除

<ItemGroup>
  <PackageReference Include="Microsoft.Azure.Cosmos" Version="3.0.0" />
</ItemGroup>

using Microsoft.Azure.Cosmos;

string endpointUrl = "your_cosmosdb_endpoint_url";
string primaryKey = "your_cosmosdb_primary_key";

CosmosClient cosmosClient = new CosmosClient(endpointUrl, primaryKey);

string databaseId = "your_database_id";
string containerId = "your_container_id";

Database database = await cosmosClient.GetDatabase(databaseId);
Container container = await database.GetContainer(containerId);

string query = "SELECT * FROM c WHERE c.property = 'value'";
QueryDefinition queryDefinition = new QueryDefinition(query);

List<dynamic> documentsToDelete = new List<dynamic>();

using (FeedIterator<dynamic> resultSet = container.GetItemQueryIterator<dynamic>(queryDefinition))
{
    while (resultSet.HasMoreResults)
    {
        FeedResponse<dynamic> response = await resultSet.ReadNextAsync();
        documentsToDelete.AddRange(response);
    }
}

List<Task> deleteTasks = new List<Task>();

foreach (dynamic document in documentsToDelete)
{
    deleteTasks.Add(container.DeleteItemAsync<dynamic>(document.id.ToString(), new PartitionKey(document.partitionKey.ToString())));
}

await Task.WhenAll(deleteTasks);