正如您在评论中提到的,您的情况取决于分配的RUs。我提供了以下示例存储过程代码。您可以参考它。
function deleteSproc(query) {
var collection = getContext().getCollection();
var collectionLink = collection.getSelfLink();
var response = getContext().getResponse();
var responseBody = {
deleted: 0,
continuation: ""
};
// Validate input.
if (!query) throw new Error("The query is undefined or null.");
tryQueryAndDelete();
function tryQueryAndDelete(continuation) {
var requestOptions = {
continuation: continuation,
pageSize: 10
};
var isAccepted = collection.queryDocuments(collectionLink, query, requestOptions, function (err, documents, responseOptions) {
if (err) throw err;
if (documents.length > 0) {
tryDelete(documents);
if(responseOptions.continuation){
tryQueryAndDelete(responseOptions.continuation);
}else{
response.setBody(responseBody);
}
}
});
if (!isAccepted) {
response.setBody(responseBody);
}
}
function tryDelete(documents) {
if (documents.length > 0) {
var requestOptions = {etag: documents[0]._etag};
// Delete the document.
var isAccepted = collection.deleteDocument(
documents[0]._self,
requestOptions,
function (err, updatedDocument, responseOptions) {
if (err) throw err;
responseBody.deleted++;
documents.shift();
// Try updating the next document in the array.
tryDelete(documents);
}
);
if (!isAccepted) {
response.setBody(responseBody);
}
}
}
}
此外,据我所知,存储过程有5秒的执行限制。如果遇到超时错误,可以将continuation标记作为参数传递到存储过程中,并多次执行存储过程。
有什么问题,请告诉我。谢谢您。