Data Transmission Service:Como limpar documentos órfãos em um cluster sharded do MongoDB

Em um servidor que possa se conectar à instância de cluster sharded, crie um script JavaScript (JS) chamado cleanupOrphaned.js.

// List of shard names
var shardNames = ["shardName1", "shardName2"];
// List of databases
var databasesToProcess = ["database1", "database2", "database3"];
shardNames.forEach(function(shardName) {
    // Iterate over the specified list of databases
    databasesToProcess.forEach(function(dbName) {
        var dbInstance = db.getSiblingDB(dbName);
        // Get the names of all collections in the database instance
        var collectionNames = dbInstance.getCollectionNames();
        // Iterate over each collection
        collectionNames.forEach(function(collectionName) {
            // The full collection name
            var fullCollectionName = dbName + "." + collectionName;
            // Build the cleanupOrphaned command
            var command = {
                runCommandOnShard: shardName,
                command: { cleanupOrphaned: fullCollectionName }
            };
            // Execute the command
            var result = db.adminCommand(command); 
            if (result.ok) {
                print("Cleaned up orphaned documents for collection " + fullCollectionName + " on shard " + shardName);
                printjson(result);
            } else {
                print("Failed to clean up orphaned documents for collection " + fullCollectionName + " on shard " + shardName);
            }
        });
    });
});

No script, modifique os valores dos parâmetros shardNames e databasesToProcess:

• shardNames: uma matriz de IDs dos shards de onde você limpará documentos órfãos. Obtenha os IDs dos shards na Shard List, na página Basic Information da instância. Exemplo: d-bp15a3796d3a****.

• databasesToProcess: uma matriz de nomes dos bancos de dados de onde você limpará documentos órfãos.

No diretório do script cleanupOrphaned.js, execute o comando a seguir para limpar os documentos órfãos.

mongo --host <Mongoshost> --port <Primaryport>  --authenticationDatabase <database> -u <username> -p <password> cleanupOrphaned.js > output.txt

Em um servidor que possa se conectar à instância de cluster sharded, crie um script JS chamado cleanupOrphaned.js.

function cleanupOrphanedOnShard(shardName, fullCollectionName) {
    var nextKey = { };
    var result;
    while ( nextKey != null ) {
        var command = {
            runCommandOnShard: shardName,
            command: { cleanupOrphaned: fullCollectionName, startingFromKey: nextKey }
        };
        result = db.adminCommand(command);
        printjson(result);
        if (result.ok != 1 || !(result.results.hasOwnProperty(shardName)) || result.results[shardName].ok != 1 ) {
            print("Unable to complete at this time: failure or timeout.")
            break
        }
        nextKey = result.results[shardName].stoppedAtKey;
    }
    print("cleanupOrphaned done for coll: " + fullCollectionName + " on shard: " + shardName)
}
var shardNames = ["shardName1", "shardName2", "shardName3"]
var fullCollectionName = "database.collection"
shardNames.forEach(function(shardName) {
    cleanupOrphanedOnShard(shardName, fullCollectionName);
});

No script, modifique os valores dos parâmetros shardNames e fullCollectionName:

• shardNames: uma matriz de IDs dos shards de onde você limpará documentos órfãos. Obtenha os IDs dos shards na Shard List, na página Basic Information da instância. Exemplo: d-bp15a3796d3a****.

• fullCollectionName: o nome da coleção de onde você limpará documentos órfãos, no formato database.collection.

No diretório do script cleanupOrphaned.js, execute o comando a seguir para limpar os documentos órfãos.

mongo --host <Mongoshost> --port <Primaryport>  --authenticationDatabase <database> -u <username> -p <password> cleanupOrphaned.js > output.txt