通过查询资源管理器根据条件从 CosmosDB 中删除文档

Question

删除集合中所有符合 where 条件的文档的查询或其他快速方法是什么？
我想要DELETE * FROM c WHERE c.DocumentType = 'EULA' 之类的东西，但显然它不起作用。

注意：我没有为此寻找任何 C# 实现。

Answer 1

在集合中创建stored procedure 并通过传递带有删除条件的选择查询来执行它。使用这个存储过程的主要原因是因为延续令牌将在很大程度上减少 RU 并且成本更低。

Answer 2

如果您想在 C#/Dotnet Core 中执行此操作，此项目可能会有所帮助：https://github.com/lokijota/CosmosDbDeleteDocumentsByQuery。这是一个简单的 Visual Studio 项目，您可以在其中指定一个 SELECT 查询，所有匹配项都将 a) 备份到文件； b) 根据一组标志删除。

Answer 3

##### Here is the python script which can be used to delete data from Partitioned Cosmos Collection #### This will delete documents Id by Id based on the result set data.

Identify the data that needs to be deleted before below step

res_list = "select id from id_del"
res_id = [{id:x["id"]} 
             for x in sqlContext.sql(res_list).rdd.collect()]
config = {
   "Endpoint" : "Use EndPoint"
  "Masterkey" : "UseKey", 
      "WritingBatchSize" : "5000",
    'DOCUMENTDB_DATABASE': 'Database',
    'DOCUMENTDB_COLLECTION': 'collection-core'
}; 

for row in res_id:
# Initialize the Python DocumentDB client
  client = document_client.DocumentClient(config['Endpoint'], {'masterKey': config['Masterkey']})

# use a SQL based query to get   documents

## Looping thru partition to delete

  query = { 'query': "SELECT c.id FROM c where c.id = "+ "'" +row[id]+"'"   }
  print(query)
  options = {}
  options['enableCrossPartitionQuery'] = True
  options['maxItemCount'] = 1000
  result_iterable = client.QueryDocuments('dbs/Database/colls/collection-core', query, options)
  results = list(result_iterable)
  print('DOCS TO BE DELETED : ' + str(len(results)))
  if len(results) > 0 :
      for i in range(0,len(results)):
      #  print(results[i]['id'])
          docID = results[i]['id']
          print("docID :" + docID)
          options = {}
          options['enableCrossPartitionQuery'] = True
          options['maxItemCount'] = 1000
          options['partitionKey'] = docID
          client.DeleteDocument('dbs/Database/colls/collection-core/docs/'+docID,options=options)
          print ('deleted Partition:' +  docID)

Answer 4

我写了一个脚本来列出所有文件并删除所有文件，修改后也可以删除选中的文件。

var docdb = require("documentdb");
var async = require("async");

var config = {
  host: "https://xxxx.documents.azure.com:443/",
  auth: {
    masterKey: "xxxx"
  }
};

var client = new docdb.DocumentClient(config.host, config.auth);

var messagesLink = docdb.UriFactory.createDocumentCollectionUri("xxxx", "xxxx");

var listAll = function(callback) {
  var spec = {
    query: "SELECT * FROM c",
    parameters: []
  };

  client.queryDocuments(messagesLink, spec).toArray((err, results) => {
    callback(err, results);
  });
};

var deleteAll = function() {
  listAll((err, results) => {
    if (err) {
      console.log(err);
    } else {
      async.forEach(results, (message, next) => {
        client.deleteDocument(message._self, err => {
          if (err) {
            console.log(err);
            next(err);
          } else {
            next();
          }
        });
      });
    }
  });
};

var task = process.argv[2];
switch (task) {
  case "listAll":
    listAll((err, results) => {
      if (err) {
        console.error(err);
      } else {
        console.log(results);
      }
    });
    break;
  case "deleteAll":
    deleteAll();
    break;

  default:
    console.log("Commands:");
    console.log("listAll deleteAll");
    break;
}

Answer 5

这有点旧，但只是有相同的要求，并找到了@Gaurav Mantri 所写内容的具体示例。

存储过程脚本在这里：

https://social.msdn.microsoft.com/Forums/azure/en-US/ec9aa862-0516-47af-badd-dad8a4789dd8/delete-multiple-docdb-documents-within-the-azure-portal?forum=AzureDocumentDB

转到 Azure 门户，从上面获取脚本并在数据库中创建一个新的存储过程->您需要从中删除的集合。

然后在存储过程窗格的底部，脚本文本区域下方是放置参数的地方。就我而言，我只想删除所有内容，所以我使用了：

SELECT c._self FROM c

我猜你会是：

SELECT c._self FROM c WHERE c.DocumentType = 'EULA'

然后点击“保存并执行”。维奥拉，一些文件被删除了。在 Azure 门户中使用它后，我切换了 Azure DocumentDB Studio 并更好地了解正在发生的事情。 IE。我可以看到我被限制为一次删除 18 个（在结果中返回）。出于某种原因，我在 Azure 门户中看不到这个。

无论如何，即使每次执行仅限于一定数量的删除，也非常方便。执行 sp 也会受到限制，因此您不能只是捣碎键盘。我想我只会删除并重新创建集合，除非我有可管理数量的要删除的文档（考虑

感谢 Mimi Gentz @Microsoft 分享上面链接中的脚本。

HTH

Answer 6

我想要 DELETE * FROM c WHERE c.DocumentType = 'EULA' 但是，显然，它不起作用。

不支持以这种方式删除文档。您需要首先使用 SELECT 查询选择文档，然后单独删除它们。如果需要，您可以在存储过程中编写获取和删除的代码，然后执行该存储过程。