SERVER-45869 more automatically converted structured

31 files changed, 345 insertions, 153 deletions

diff --git a/src/mongo/db/auth/authz_manager_external_state_local.cpp b/src/mongo/db/auth/authz_manager_external_state_local.cpp
index 923acc650fa..289d2d4dec7 100644
--- a/src/mongo/db/auth/authz_manager_external_state_local.cpp
+++ b/src/mongo/db/auth/authz_manager_external_state_local.cpp
@@ -43,6 +43,7 @@
 #include "mongo/db/auth/user_document_parser.h"
 #include "mongo/db/operation_context.h"
 #include "mongo/db/server_options.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 #include "mongo/util/net/ssl_types.h"
 #include "mongo/util/str.h"
@@ -55,13 +56,16 @@ Status AuthzManagerExternalStateLocal::initialize(OperationContext* opCtx) {
     Status status = _initializeRoleGraph(opCtx);
     if (!status.isOK()) {
         if (status == ErrorCodes::GraphContainsCycle) {
-            error() << "Cycle detected in admin.system.roles; role inheritance disabled. "
-                       "Remove the listed cycle and any others to re-enable role inheritance. "
-                    << redact(status);
+            LOGV2_ERROR(
+                23750,
+                "Cycle detected in admin.system.roles; role inheritance disabled. "
+                "Remove the listed cycle and any others to re-enable role inheritance. {status}",
+                "status"_attr = redact(status));
         } else {
-            error() << "Could not generate role graph from admin.system.roles; "
-                       "only system roles available: "
-                    << redact(status);
+            LOGV2_ERROR(23751,
+                        "Could not generate role graph from admin.system.roles; "
+                        "only system roles available: {status}",
+                        "status"_attr = redact(status));
         }
     }
 
@@ -466,9 +470,11 @@ namespace {
 void addRoleFromDocumentOrWarn(RoleGraph* roleGraph, const BSONObj& doc) {
     Status status = roleGraph->addRoleFromDocument(doc);
     if (!status.isOK()) {
-        warning() << "Skipping invalid admin.system.roles document while calculating privileges"
-                     " for user-defined roles:  "
-                  << redact(status) << "; document " << redact(doc);
+        LOGV2_WARNING(23747,
+                      "Skipping invalid admin.system.roles document while calculating privileges"
+                      " for user-defined roles:  {status}; document {doc}",
+                      "status"_attr = redact(status),
+                      "doc"_attr = redact(doc));
     }
 }
 
@@ -495,9 +501,10 @@ Status AuthzManagerExternalStateLocal::_initializeRoleGraph(OperationContext* op
 
     RoleGraphState newState;
     if (status == ErrorCodes::GraphContainsCycle) {
-        error() << "Inconsistent role graph during authorization manager initialization.  Only "
-                   "direct privileges available. "
-                << redact(status);
+        LOGV2_ERROR(23752,
+                    "Inconsistent role graph during authorization manager initialization.  Only "
+                    "direct privileges available. {status}",
+                    "status"_attr = redact(status));
         newState = roleGraphStateHasCycle;
         status = Status::OK();
     } else if (status.isOK()) {
@@ -574,21 +581,30 @@ private:
             if (_o2) {
                 oplogEntryBuilder << "o2" << *_o2;
             }
-            error() << "Unsupported modification to roles collection in oplog; "
-                       "restart this process to reenable user-defined roles; "
-                    << redact(status) << "; Oplog entry: " << redact(oplogEntryBuilder.done());
+            LOGV2_ERROR(23753,
+                        "Unsupported modification to roles collection in oplog; "
+                        "restart this process to reenable user-defined roles; {status}; Oplog "
+                        "entry: {oplogEntryBuilder_done}",
+                        "status"_attr = redact(status),
+                        "oplogEntryBuilder_done"_attr = redact(oplogEntryBuilder.done()));
             // If a setParameter is enabled, this condition is fatal.
             fassert(51152, !roleGraphInvalidationIsFatal);
         } else if (!status.isOK()) {
-            warning() << "Skipping bad update to roles collection in oplog. " << redact(status)
-                      << " Oplog entry: " << redact(_op);
+            LOGV2_WARNING(
+                23748,
+                "Skipping bad update to roles collection in oplog. {status} Oplog entry: {op}",
+                "status"_attr = redact(status),
+                "op"_attr = redact(_op));
         }
         status = _externalState->_roleGraph.recomputePrivilegeData();
         if (status == ErrorCodes::GraphContainsCycle) {
             _externalState->_roleGraphState = _externalState->roleGraphStateHasCycle;
-            error() << "Inconsistent role graph during authorization manager initialization.  "
-                       "Only direct privileges available. "
-                    << redact(status) << " after applying oplog entry " << redact(_op);
+            LOGV2_ERROR(
+                23754,
+                "Inconsistent role graph during authorization manager initialization.  "
+                "Only direct privileges available. {status} after applying oplog entry {op}",
+                "status"_attr = redact(status),
+                "op"_attr = redact(_op));
         } else {
             fassert(17183, status);
             _externalState->_roleGraphState = _externalState->roleGraphStateConsistent;
@@ -612,9 +628,10 @@ private:
                 : extractUserNameFromIdString(_o["_id"].str());
 
             if (!userName.isOK()) {
-                warning() << "Invalidating user cache based on user being updated failed, will "
-                             "invalidate the entire cache instead: "
-                          << userName.getStatus();
+                LOGV2_WARNING(23749,
+                              "Invalidating user cache based on user being updated failed, will "
+                              "invalidate the entire cache instead: {userName_getStatus}",
+                              "userName_getStatus"_attr = userName.getStatus());
                 _authzManager->invalidateUserCache(_opCtx);
                 return;
             }
diff --git a/src/mongo/db/auth/user_document_parser.cpp b/src/mongo/db/auth/user_document_parser.cpp
index 8eb6dc7a94b..3b9548f93dc 100644
--- a/src/mongo/db/auth/user_document_parser.cpp
+++ b/src/mongo/db/auth/user_document_parser.cpp
@@ -41,6 +41,7 @@
 #include "mongo/db/auth/user.h"
 #include "mongo/db/jsobj.h"
 #include "mongo/db/namespace_string.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 #include "mongo/util/str.h"
 
@@ -456,30 +457,42 @@ Status V2UserDocumentParser::initializeUserPrivilegesFromUserDocument(const BSON
     std::string errmsg;
     for (BSONObjIterator it(privilegesElement.Obj()); it.more(); it.next()) {
         if ((*it).type() != Object) {
-            warning() << "Wrong type of element in inheritedPrivileges array for "
-                      << user->getName() << ": " << *it;
+            LOGV2_WARNING(
+                23743,
+                "Wrong type of element in inheritedPrivileges array for {user_getName}: {it}",
+                "user_getName"_attr = user->getName(),
+                "it"_attr = *it);
             continue;
         }
         Privilege privilege;
         ParsedPrivilege pp;
         if (!pp.parseBSON((*it).Obj(), &errmsg)) {
-            warning() << "Could not parse privilege element in user document for "
-                      << user->getName() << ": " << errmsg;
+            LOGV2_WARNING(
+                23744,
+                "Could not parse privilege element in user document for {user_getName}: {errmsg}",
+                "user_getName"_attr = user->getName(),
+                "errmsg"_attr = errmsg);
             continue;
         }
         std::vector<std::string> unrecognizedActions;
         Status status =
             ParsedPrivilege::parsedPrivilegeToPrivilege(pp, &privilege, &unrecognizedActions);
         if (!status.isOK()) {
-            warning() << "Could not parse privilege element in user document for "
-                      << user->getName() << causedBy(status);
+            LOGV2_WARNING(23745,
+                          "Could not parse privilege element in user document for "
+                          "{user_getName}{causedBy_status}",
+                          "user_getName"_attr = user->getName(),
+                          "causedBy_status"_attr = causedBy(status));
             continue;
         }
         if (unrecognizedActions.size()) {
             std::string unrecognizedActionsString;
             str::joinStringDelim(unrecognizedActions, &unrecognizedActionsString, ',');
-            warning() << "Encountered unrecognized actions \" " << unrecognizedActionsString
-                      << "\" while parsing user document for " << user->getName();
+            LOGV2_WARNING(23746,
+                          "Encountered unrecognized actions \" {unrecognizedActionsString}\" while "
+                          "parsing user document for {user_getName}",
+                          "unrecognizedActionsString"_attr = unrecognizedActionsString,
+                          "user_getName"_attr = user->getName());
         }
         privileges.push_back(privilege);
     }
diff --git a/src/mongo/db/commands/dbcommands.cpp b/src/mongo/db/commands/dbcommands.cpp
index 5b880adfdd9..ce4087e9026 100644
--- a/src/mongo/db/commands/dbcommands.cpp
+++ b/src/mongo/db/commands/dbcommands.cpp
@@ -87,6 +87,7 @@
 #include "mongo/db/stats/storage_stats.h"
 #include "mongo/db/storage/storage_engine_init.h"
 #include "mongo/db/write_concern.h"
+#include "mongo/logv2/log.h"
 #include "mongo/scripting/engine.h"
 #include "mongo/util/fail_point.h"
 #include "mongo/util/log.h"
@@ -319,7 +320,8 @@ public:
         if (cmd.getAutoIndexId()) {
             const char* deprecationWarning =
                 "the autoIndexId option is deprecated and will be removed in a future release";
-            warning() << deprecationWarning;
+            LOGV2_WARNING(
+                23800, "{deprecationWarning}", "deprecationWarning"_attr = deprecationWarning);
             result.append("note", deprecationWarning);
         }
 
@@ -535,7 +537,7 @@ public:
         }
 
         if (PlanExecutor::FAILURE == state) {
-            warning() << "Internal error while reading " << ns;
+            LOGV2_WARNING(23801, "Internal error while reading {ns}", "ns"_attr = ns);
             uassertStatusOK(WorkingSetCommon::getMemberObjectStatus(obj).withContext(
                 "Executor error while reading during dataSize command"));
         }
diff --git a/src/mongo/db/commands/distinct.cpp b/src/mongo/db/commands/distinct.cpp
index d04cb68ebbc..0c2d046b9cb 100644
--- a/src/mongo/db/commands/distinct.cpp
+++ b/src/mongo/db/commands/distinct.cpp
@@ -57,6 +57,7 @@
 #include "mongo/db/query/view_response_formatter.h"
 #include "mongo/db/s/collection_sharding_state.h"
 #include "mongo/db/views/resolved_view.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 
 namespace mongo {
@@ -271,10 +272,14 @@ public:
             // We should always have a valid status member object at this point.
             auto status = WorkingSetCommon::getMemberObjectStatus(obj);
             invariant(!status.isOK());
-            warning() << "Plan executor error during distinct command: "
-                      << redact(PlanExecutor::statestr(state)) << ", status: " << status
-                      << ", stats: "
-                      << redact(Explain::getWinningPlanStats(executor.getValue().get()));
+            LOGV2_WARNING(
+                23797,
+                "Plan executor error during distinct command: {PlanExecutor_statestr_state}, "
+                "status: {status}, stats: {Explain_getWinningPlanStats_executor_getValue_get}",
+                "PlanExecutor_statestr_state"_attr = redact(PlanExecutor::statestr(state)),
+                "status"_attr = status,
+                "Explain_getWinningPlanStats_executor_getValue_get"_attr =
+                    redact(Explain::getWinningPlanStats(executor.getValue().get())));
 
             uassertStatusOK(status.withContext("Executor error during distinct command"));
         }
diff --git a/src/mongo/db/commands/find_and_modify.cpp b/src/mongo/db/commands/find_and_modify.cpp
index e18e0dcadf0..80dd15884ea 100644
--- a/src/mongo/db/commands/find_and_modify.cpp
+++ b/src/mongo/db/commands/find_and_modify.cpp
@@ -70,6 +70,7 @@
 #include "mongo/db/stats/top.h"
 #include "mongo/db/transaction_participant.h"
 #include "mongo/db/write_concern.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 #include "mongo/util/scopeguard.h"
 
@@ -97,9 +98,13 @@ boost::optional<BSONObj> advanceExecutor(OperationContext* opCtx,
         // We should always have a valid status member object at this point.
         auto status = WorkingSetCommon::getMemberObjectStatus(value);
         invariant(!status.isOK());
-        warning() << "Plan executor error during findAndModify: " << PlanExecutor::statestr(state)
-                  << ", status: " << status
-                  << ", stats: " << redact(Explain::getWinningPlanStats(exec));
+        LOGV2_WARNING(23802,
+                      "Plan executor error during findAndModify: {PlanExecutor_statestr_state}, "
+                      "status: {status}, stats: {Explain_getWinningPlanStats_exec}",
+                      "PlanExecutor_statestr_state"_attr = PlanExecutor::statestr(state),
+                      "status"_attr = status,
+                      "Explain_getWinningPlanStats_exec"_attr =
+                          redact(Explain::getWinningPlanStats(exec)));
 
         uassertStatusOKWithContext(status, "Plan executor error during findAndModify");
         MONGO_UNREACHABLE;
diff --git a/src/mongo/db/commands/find_cmd.cpp b/src/mongo/db/commands/find_cmd.cpp
index abeb4641446..eec207cd98f 100644
--- a/src/mongo/db/commands/find_cmd.cpp
+++ b/src/mongo/db/commands/find_cmd.cpp
@@ -54,6 +54,7 @@
 #include "mongo/db/stats/server_read_concern_metrics.h"
 #include "mongo/db/storage/storage_engine.h"
 #include "mongo/db/transaction_participant.h"
+#include "mongo/logv2/log.h"
 #include "mongo/rpc/get_status_from_command_result.h"
 #include "mongo/util/log.h"
 
@@ -535,9 +536,14 @@ public:
                 // We should always have a valid status member object at this point.
                 auto status = WorkingSetCommon::getMemberObjectStatus(doc);
                 invariant(!status.isOK());
-                warning() << "Plan executor error during find command: "
-                          << PlanExecutor::statestr(state) << ", status: " << status
-                          << ", stats: " << redact(Explain::getWinningPlanStats(exec.get()));
+                LOGV2_WARNING(
+                    23798,
+                    "Plan executor error during find command: {PlanExecutor_statestr_state}, "
+                    "status: {status}, stats: {Explain_getWinningPlanStats_exec_get}",
+                    "PlanExecutor_statestr_state"_attr = PlanExecutor::statestr(state),
+                    "status"_attr = status,
+                    "Explain_getWinningPlanStats_exec_get"_attr =
+                        redact(Explain::getWinningPlanStats(exec.get())));
 
                 uassertStatusOK(status.withContext("Executor error during find command"));
             }
diff --git a/src/mongo/db/commands/map_reduce_out_options.cpp b/src/mongo/db/commands/map_reduce_out_options.cpp
index 2aa96605de8..d8ab3fcfe55 100644
--- a/src/mongo/db/commands/map_reduce_out_options.cpp
+++ b/src/mongo/db/commands/map_reduce_out_options.cpp
@@ -34,6 +34,7 @@
 
 #include "mongo/db/commands/map_reduce_out_options.h"
 #include "mongo/db/namespace_string.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 
 namespace mongo {
@@ -68,7 +69,7 @@ MapReduceOutOptions MapReduceOutOptions::parseFromBSON(const BSONElement& elemen
                 uassert(
                     ErrorCodes::BadValue, "sharded field value must be true", sharded.boolean());
                 if (shardedDeprecationSampler.tick()) {
-                    warning() << "The out.sharded option in MapReduce is deprecated";
+                    LOGV2_WARNING(23703, "The out.sharded option in MapReduce is deprecated");
                 }
                 return true;
             } else {
diff --git a/src/mongo/db/commands/mr_common.cpp b/src/mongo/db/commands/mr_common.cpp
index 4943ef16307..c6ee2483487 100644
--- a/src/mongo/db/commands/mr_common.cpp
+++ b/src/mongo/db/commands/mr_common.cpp
@@ -55,6 +55,7 @@
 #include "mongo/db/pipeline/expression_function.h"
 #include "mongo/db/pipeline/expression_js_emit.h"
 #include "mongo/db/query/util/make_data_structure.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/intrusive_counter.h"
 #include "mongo/util/log.h"
 #include "mongo/util/str.h"
@@ -310,7 +311,7 @@ OutputOptions parseOutputOptions(const std::string& dbname, const BSONObj& cmdOb
                         (outputOptions.outType == OutputType::Reduce ||
                          outputOptions.outType == OutputType::Merge));
             } else if (nonAtomicDeprecationSampler.tick()) {
-                warning() << "Setting out.nonAtomic to false in MapReduce is deprecated.";
+                LOGV2_WARNING(23796, "Setting out.nonAtomic to false in MapReduce is deprecated.");
             }
         }
     } else {
diff --git a/src/mongo/db/commands/run_aggregate.cpp b/src/mongo/db/commands/run_aggregate.cpp
index 8a306ca2014..a61456df9c8 100644
--- a/src/mongo/db/commands/run_aggregate.cpp
+++ b/src/mongo/db/commands/run_aggregate.cpp
@@ -71,6 +71,7 @@
 #include "mongo/db/storage/storage_options.h"
 #include "mongo/db/views/view.h"
 #include "mongo/db/views/view_catalog.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 #include "mongo/util/scopeguard.h"
 #include "mongo/util/string_map.h"
@@ -201,9 +202,13 @@ bool handleCursorCommand(OperationContext* opCtx,
             // We should always have a valid status member object at this point.
             auto status = WorkingSetCommon::getMemberObjectStatus(nextDoc);
             invariant(!status.isOK());
-            warning() << "Aggregate command executor error: " << PlanExecutor::statestr(state)
-                      << ", status: " << status
-                      << ", stats: " << redact(Explain::getWinningPlanStats(exec));
+            LOGV2_WARNING(23799,
+                          "Aggregate command executor error: {PlanExecutor_statestr_state}, "
+                          "status: {status}, stats: {Explain_getWinningPlanStats_exec}",
+                          "PlanExecutor_statestr_state"_attr = PlanExecutor::statestr(state),
+                          "status"_attr = status,
+                          "Explain_getWinningPlanStats_exec"_attr =
+                              redact(Explain::getWinningPlanStats(exec)));
 
             uassertStatusOK(status.withContext("PlanExecutor error during aggregation"));
         }
diff --git a/src/mongo/db/exec/geo_near.cpp b/src/mongo/db/exec/geo_near.cpp
index 204b840f24e..0ec4d890707 100644
--- a/src/mongo/db/exec/geo_near.cpp
+++ b/src/mongo/db/exec/geo_near.cpp
@@ -31,6 +31,7 @@
 
 #include "mongo/db/exec/geo_near.h"
 
+#include "mongo/logv2/log.h"
 #include <memory>
 #include <vector>
 
@@ -125,12 +126,15 @@ static void extractGeometries(const BSONObj& doc,
                     // Valid geometry element
                     geometries->push_back(std::move(stored));
                 } else {
-                    warning() << "geoNear stage read non-geometry element " << redact(nextEl)
-                              << " in array " << redact(el);
+                    LOGV2_WARNING(23760,
+                                  "geoNear stage read non-geometry element {nextEl} in array {el}",
+                                  "nextEl"_attr = redact(nextEl),
+                                  "el"_attr = redact(el));
                 }
             }
         } else {
-            warning() << "geoNear stage read non-geometry element " << redact(el);
+            LOGV2_WARNING(
+                23761, "geoNear stage read non-geometry element {el}", "el"_attr = redact(el));
         }
     }
 }
diff --git a/src/mongo/db/exec/projection.cpp b/src/mongo/db/exec/projection.cpp
index 4fc1ad9d9f1..ecf20579300 100644
--- a/src/mongo/db/exec/projection.cpp
+++ b/src/mongo/db/exec/projection.cpp
@@ -42,6 +42,7 @@
 #include "mongo/db/jsobj.h"
 #include "mongo/db/matcher/expression.h"
 #include "mongo/db/record_id.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 #include "mongo/util/str.h"
 
@@ -141,7 +142,9 @@ PlanStage::StageState ProjectionStage::doWork(WorkingSetID* out) {
         // Punt to our specific projection impl.
         Status projStatus = transform(member);
         if (!projStatus.isOK()) {
-            warning() << "Couldn't execute projection, status = " << redact(projStatus);
+            LOGV2_WARNING(23827,
+                          "Couldn't execute projection, status = {projStatus}",
+                          "projStatus"_attr = redact(projStatus));
             *out = WorkingSetCommon::allocateStatusMember(&_ws, projStatus);
             return PlanStage::FAILURE;
         }
diff --git a/src/mongo/db/exec/shard_filter.cpp b/src/mongo/db/exec/shard_filter.cpp
index fe2435a54fb..ed28c9f890c 100644
--- a/src/mongo/db/exec/shard_filter.cpp
+++ b/src/mongo/db/exec/shard_filter.cpp
@@ -38,6 +38,7 @@
 #include "mongo/db/exec/filter.h"
 #include "mongo/db/exec/scoped_timer.h"
 #include "mongo/db/exec/working_set_common.h"
+#include "mongo/logv2/log.h"
 #include "mongo/s/shard_key_pattern.h"
 #include "mongo/util/log.h"
 
@@ -87,10 +88,13 @@ PlanStage::StageState ShardFilterStage::doWork(WorkingSetID* out) {
 
                     // Skip this working set member with a warning - no shard key should not be
                     // possible unless manually inserting data into a shard
-                    warning() << "no shard key found in document "
-                              << redact(member->doc.value().toBson()) << " for shard key pattern "
-                              << _shardFilterer.getKeyPattern() << ", "
-                              << "document may have been inserted manually into shard";
+                    LOGV2_WARNING(
+                        23787,
+                        "no shard key found in document {member_doc_value_toBson} for shard key "
+                        "pattern {shardFilterer_getKeyPattern}, document may have been inserted "
+                        "manually into shard",
+                        "member_doc_value_toBson"_attr = redact(member->doc.value().toBson()),
+                        "shardFilterer_getKeyPattern"_attr = _shardFilterer.getKeyPattern());
                 } else {
                     invariant(res == ShardFilterer::DocumentBelongsResult::kDoesNotBelong);
                 }
diff --git a/src/mongo/db/exec/stagedebug_cmd.cpp b/src/mongo/db/exec/stagedebug_cmd.cpp
index dfa5052b1d3..5867bbb0b96 100644
--- a/src/mongo/db/exec/stagedebug_cmd.cpp
+++ b/src/mongo/db/exec/stagedebug_cmd.cpp
@@ -63,6 +63,7 @@
 #include "mongo/db/matcher/extensions_callback_real.h"
 #include "mongo/db/namespace_string.h"
 #include "mongo/db/query/plan_executor.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 
 namespace mongo {
@@ -195,8 +196,11 @@ public:
         resultBuilder.done();
 
         if (PlanExecutor::FAILURE == state) {
-            error() << "Plan executor error during StageDebug command: FAILURE, stats: "
-                    << redact(Explain::getWinningPlanStats(exec.get()));
+            LOGV2_ERROR(23795,
+                        "Plan executor error during StageDebug command: FAILURE, stats: "
+                        "{Explain_getWinningPlanStats_exec_get}",
+                        "Explain_getWinningPlanStats_exec_get"_attr =
+                            redact(Explain::getWinningPlanStats(exec.get())));
 
             uassertStatusOK(WorkingSetCommon::getMemberObjectStatus(obj).withContext(
                 "Executor error during StageDebug command"));
diff --git a/src/mongo/db/ftdc/ftdc_system_stats_windows.cpp b/src/mongo/db/ftdc/ftdc_system_stats_windows.cpp
index 92045f16e4d..cf2ac6a4e61 100644
--- a/src/mongo/db/ftdc/ftdc_system_stats_windows.cpp
+++ b/src/mongo/db/ftdc/ftdc_system_stats_windows.cpp
@@ -42,6 +42,7 @@
 #include "mongo/bson/bsonobjbuilder.h"
 #include "mongo/db/ftdc/collector.h"
 #include "mongo/db/ftdc/controller.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 #include "mongo/util/perfctr_collect.h"
 
@@ -144,8 +145,9 @@ void installSystemMetricsCollector(FTDCController* controller) {
 
     auto swCollector = createCollector();
     if (!swCollector.getStatus().isOK()) {
-        warning() << "Failed to initialize Performance Counters for FTDC: "
-                  << swCollector.getStatus();
+        LOGV2_WARNING(23718,
+                      "Failed to initialize Performance Counters for FTDC: {swCollector_getStatus}",
+                      "swCollector_getStatus"_attr = swCollector.getStatus());
         return;
     }
 
diff --git a/src/mongo/db/index/expression_keys_private.cpp b/src/mongo/db/index/expression_keys_private.cpp
index cf2f81a7020..a9ef9f1ba30 100644
--- a/src/mongo/db/index/expression_keys_private.cpp
+++ b/src/mongo/db/index/expression_keys_private.cpp
@@ -46,6 +46,7 @@
 #include "mongo/db/index/s2_common.h"
 #include "mongo/db/index_names.h"
 #include "mongo/db/query/collation/collation_index_key.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/assert_util.h"
 #include "mongo/util/log.h"
 #include "mongo/util/str.h"
@@ -635,8 +636,11 @@ void ExpressionKeysPrivate::getS2Keys(const BSONObj& obj,
     }
 
     if (keysToAdd.size() > params.maxKeysPerInsert) {
-        warning() << "Insert of geo object generated a high number of keys."
-                  << " num keys: " << keysToAdd.size() << " obj inserted: " << redact(obj);
+        LOGV2_WARNING(23755,
+                      "Insert of geo object generated a high number of keys. num keys: "
+                      "{keysToAdd_size} obj inserted: {obj}",
+                      "keysToAdd_size"_attr = keysToAdd.size(),
+                      "obj"_attr = redact(obj));
     }
 
     invariant(keys->empty());
diff --git a/src/mongo/db/index/s2_access_method.cpp b/src/mongo/db/index/s2_access_method.cpp
index da5bc634ee9..8db6683b567 100644
--- a/src/mongo/db/index/s2_access_method.cpp
+++ b/src/mongo/db/index/s2_access_method.cpp
@@ -41,6 +41,7 @@
 #include "mongo/db/index/expression_params.h"
 #include "mongo/db/index_names.h"
 #include "mongo/db/jsobj.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 
 namespace mongo {
@@ -77,7 +78,9 @@ S2AccessMethod::S2AccessMethod(IndexCatalogEntry* btreeState,
             geoFields >= 1);
 
     if (descriptor->isSparse()) {
-        warning() << "Sparse option ignored for index spec " << descriptor->keyPattern().toString();
+        LOGV2_WARNING(23742,
+                      "Sparse option ignored for index spec {descriptor_keyPattern}",
+                      "descriptor_keyPattern"_attr = descriptor->keyPattern().toString());
     }
 }
 
diff --git a/src/mongo/db/pipeline/document_source_geo_near.cpp b/src/mongo/db/pipeline/document_source_geo_near.cpp
index 5081865eeba..9726ad37caf 100644
--- a/src/mongo/db/pipeline/document_source_geo_near.cpp
+++ b/src/mongo/db/pipeline/document_source_geo_near.cpp
@@ -36,6 +36,7 @@
 #include "mongo/db/exec/document_value/document.h"
 #include "mongo/db/pipeline/document_source_sort.h"
 #include "mongo/db/pipeline/lite_parsed_document_source.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 
 namespace mongo {
@@ -171,7 +172,7 @@ void DocumentSourceGeoNear::parseOptions(BSONObj options) {
     }
 
     if (options.hasField("uniqueDocs"))
-        warning() << "ignoring deprecated uniqueDocs option in $geoNear aggregation stage";
+        LOGV2_WARNING(23758, "ignoring deprecated uniqueDocs option in $geoNear aggregation stage");
 
     if (auto keyElt = options[kKeyFieldName]) {
         uassert(ErrorCodes::TypeMismatch,
diff --git a/src/mongo/db/repl/check_quorum_for_config_change.cpp b/src/mongo/db/repl/check_quorum_for_config_change.cpp
index 3faf2b20fa5..01f4e6c5e55 100644
--- a/src/mongo/db/repl/check_quorum_for_config_change.cpp
+++ b/src/mongo/db/repl/check_quorum_for_config_change.cpp
@@ -40,6 +40,7 @@
 #include "mongo/db/repl/scatter_gather_algorithm.h"
 #include "mongo/db/repl/scatter_gather_runner.h"
 #include "mongo/db/server_options.h"
+#include "mongo/logv2/log.h"
 #include "mongo/rpc/metadata/repl_set_metadata.h"
 #include "mongo/util/log.h"
 #include "mongo/util/str.h"
@@ -187,8 +188,10 @@ void QuorumChecker::_tabulateHeartbeatResponse(const RemoteCommandRequest& reque
                                                const executor::RemoteCommandResponse& response) {
     ++_numResponses;
     if (!response.isOK()) {
-        warning() << "Failed to complete heartbeat request to " << request.target << "; "
-                  << response.status;
+        LOGV2_WARNING(23722,
+                      "Failed to complete heartbeat request to {request_target}; {response_status}",
+                      "request_target"_attr = request.target,
+                      "response_status"_attr = response.status);
         _badResponses.push_back(std::make_pair(request.target, response.status));
         return;
     }
@@ -201,13 +204,17 @@ void QuorumChecker::_tabulateHeartbeatResponse(const RemoteCommandRequest& reque
         std::string message = str::stream()
             << "Our set name did not match that of " << request.target.toString();
         _vetoStatus = Status(ErrorCodes::NewReplicaSetConfigurationIncompatible, message);
-        warning() << message;
+        LOGV2_WARNING(23723, "{message}", "message"_attr = message);
         return;
     }
 
     if (!hbStatus.isOK() && hbStatus != ErrorCodes::InvalidReplicaSetConfig) {
-        warning() << "Got error (" << hbStatus << ") response on heartbeat request to "
-                  << request.target << "; " << hbResp;
+        LOGV2_WARNING(
+            23724,
+            "Got error ({hbStatus}) response on heartbeat request to {request_target}; {hbResp}",
+            "hbStatus"_attr = hbStatus,
+            "request_target"_attr = request.target,
+            "hbResp"_attr = hbResp);
         _badResponses.push_back(std::make_pair(request.target, hbStatus));
         return;
     }
@@ -219,7 +226,7 @@ void QuorumChecker::_tabulateHeartbeatResponse(const RemoteCommandRequest& reque
                 << " is no larger than the version on " << request.target.toString()
                 << ", which is " << hbResp.getConfigVersion();
             _vetoStatus = Status(ErrorCodes::NewReplicaSetConfigurationIncompatible, message);
-            warning() << message;
+            LOGV2_WARNING(23725, "{message}", "message"_attr = message);
             return;
         }
     }
@@ -234,7 +241,7 @@ void QuorumChecker::_tabulateHeartbeatResponse(const RemoteCommandRequest& reque
                 << " did not match that of " << request.target.toString() << ", which is "
                 << replMetadata.getValue().getReplicaSetId();
             _vetoStatus = Status(ErrorCodes::NewReplicaSetConfigurationIncompatible, message);
-            warning() << message;
+            LOGV2_WARNING(23726, "{message}", "message"_attr = message);
         }
     }
 
diff --git a/src/mongo/db/repl/session_update_tracker.cpp b/src/mongo/db/repl/session_update_tracker.cpp
index c539e608670..f3e381995e2 100644
--- a/src/mongo/db/repl/session_update_tracker.cpp
+++ b/src/mongo/db/repl/session_update_tracker.cpp
@@ -39,6 +39,7 @@
 #include "mongo/db/session.h"
 #include "mongo/db/session_txn_record_gen.h"
 #include "mongo/db/transaction_participant_gen.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/assert_util.h"
 #include "mongo/util/log.h"
 
@@ -191,10 +192,16 @@ void SessionUpdateTracker::_updateSessionInfo(const OplogEntry& entry) {
         return;
     }
 
-    severe() << "Entry for session " << lsid->toBSON() << " has txnNumber "
-             << *sessionInfo.getTxnNumber() << " < " << *existingSessionInfo.getTxnNumber();
-    severe() << "New oplog entry: " << redact(entry.toString());
-    severe() << "Existing oplog entry: " << redact(iter->second.toString());
+    LOGV2_FATAL(23792,
+                "Entry for session {lsid} has txnNumber {sessionInfo_getTxnNumber} < "
+                "{existingSessionInfo_getTxnNumber}",
+                "lsid"_attr = lsid->toBSON(),
+                "sessionInfo_getTxnNumber"_attr = *sessionInfo.getTxnNumber(),
+                "existingSessionInfo_getTxnNumber"_attr = *existingSessionInfo.getTxnNumber());
+    LOGV2_FATAL(23793, "New oplog entry: {entry}", "entry"_attr = redact(entry.toString()));
+    LOGV2_FATAL(23794,
+                "Existing oplog entry: {iter_second}",
+                "iter_second"_attr = redact(iter->second.toString()));
 
     fassertFailedNoTrace(50843);
 }
diff --git a/src/mongo/db/s/move_chunk_command.cpp b/src/mongo/db/s/move_chunk_command.cpp
index 645930188ac..23713ad2c55 100644
--- a/src/mongo/db/s/move_chunk_command.cpp
+++ b/src/mongo/db/s/move_chunk_command.cpp
@@ -43,6 +43,7 @@
 #include "mongo/db/s/move_timing_helper.h"
 #include "mongo/db/s/sharding_state.h"
 #include "mongo/db/s/sharding_statistics.h"
+#include "mongo/logv2/log.h"
 #include "mongo/s/client/shard_registry.h"
 #include "mongo/s/grid.h"
 #include "mongo/s/request_types/migration_secondary_throttle_options.h"
@@ -61,7 +62,9 @@ namespace {
  */
 void uassertStatusOKWithWarning(const Status& status) {
     if (!status.isOK()) {
-        warning() << "Chunk move failed" << causedBy(redact(status));
+        LOGV2_WARNING(23777,
+                      "Chunk move failed{causedBy_status}",
+                      "causedBy_status"_attr = causedBy(redact(status)));
         uassertStatusOK(status);
     }
 }
diff --git a/src/mongo/db/s/move_primary_command.cpp b/src/mongo/db/s/move_primary_command.cpp
index 58b9deec87d..0d29b270f28 100644
--- a/src/mongo/db/s/move_primary_command.cpp
+++ b/src/mongo/db/s/move_primary_command.cpp
@@ -36,6 +36,7 @@
 #include "mongo/db/s/active_move_primaries_registry.h"
 #include "mongo/db/s/move_primary_source_manager.h"
 #include "mongo/db/s/sharding_state.h"
+#include "mongo/logv2/log.h"
 #include "mongo/s/grid.h"
 #include "mongo/s/request_types/move_primary_gen.h"
 #include "mongo/util/log.h"
@@ -49,7 +50,9 @@ namespace {
  */
 void uassertStatusOKWithWarning(const Status& status) {
     if (!status.isOK()) {
-        warning() << "movePrimary failed" << causedBy(redact(status));
+        LOGV2_WARNING(23762,
+                      "movePrimary failed{causedBy_status}",
+                      "causedBy_status"_attr = causedBy(redact(status)));
         uassertStatusOK(status);
     }
 }
diff --git a/src/mongo/db/s/move_timing_helper.cpp b/src/mongo/db/s/move_timing_helper.cpp
index e0bdce57620..7090cf6e009 100644
--- a/src/mongo/db/s/move_timing_helper.cpp
+++ b/src/mongo/db/s/move_timing_helper.cpp
@@ -36,6 +36,7 @@
 #include "mongo/db/client.h"
 #include "mongo/db/curop.h"
 #include "mongo/db/s/sharding_logging.h"
+#include "mongo/logv2/log.h"
 #include "mongo/s/grid.h"
 #include "mongo/util/log.h"
 
@@ -90,8 +91,10 @@ MoveTimingHelper::~MoveTimingHelper() {
                                                 _b.obj(),
                                                 ShardingCatalogClient::kMajorityWriteConcern);
     } catch (const std::exception& e) {
-        warning() << "couldn't record timing for moveChunk '" << _where
-                  << "': " << redact(e.what());
+        LOGV2_WARNING(23759,
+                      "couldn't record timing for moveChunk '{where}': {e_what}",
+                      "where"_attr = _where,
+                      "e_what"_attr = redact(e.what()));
     }
 }
 
diff --git a/src/mongo/db/s/range_deletion_util.cpp b/src/mongo/db/s/range_deletion_util.cpp
index c5a65400279..b9a979279de 100644
--- a/src/mongo/db/s/range_deletion_util.cpp
+++ b/src/mongo/db/s/range_deletion_util.cpp
@@ -60,6 +60,7 @@
 #include "mongo/db/storage/remove_saver.h"
 #include "mongo/db/write_concern.h"
 #include "mongo/executor/task_executor.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/future_util.h"
 #include "mongo/util/log.h"
 
@@ -85,15 +86,25 @@ bool collectionUuidHasChanged(const NamespaceString& nss,
                               UUID expectedCollectionUuid) {
 
     if (!currentCollection) {
-        LOG(1) << "Abandoning range deletion task for " << nss.ns() << " with UUID "
-               << expectedCollectionUuid << " because the collection has been dropped";
+        LOGV2_DEBUG(23763,
+                    1,
+                    "Abandoning range deletion task for {nss_ns} with UUID "
+                    "{expectedCollectionUuid} because the collection has been dropped",
+                    "nss_ns"_attr = nss.ns(),
+                    "expectedCollectionUuid"_attr = expectedCollectionUuid);
         return true;
     }
 
     if (currentCollection->uuid() != expectedCollectionUuid) {
-        LOG(1) << "Abandoning range deletion task for " << nss.ns() << " with UUID "
-               << expectedCollectionUuid << " because UUID of " << nss.ns()
-               << "has changed (current is " << currentCollection->uuid() << ")";
+        LOGV2_DEBUG(
+            23764,
+            1,
+            "Abandoning range deletion task for {nss_ns} with UUID {expectedCollectionUuid} "
+            "because UUID of {nss_ns2}has changed (current is {currentCollection_uuid})",
+            "nss_ns"_attr = nss.ns(),
+            "expectedCollectionUuid"_attr = expectedCollectionUuid,
+            "nss_ns2"_attr = nss.ns(),
+            "currentCollection_uuid"_attr = currentCollection->uuid());
         return true;
     }
 
@@ -123,7 +134,7 @@ StatusWith<int> deleteNextBatch(OperationContext* opCtx,
     if (!idx) {
         std::string msg = str::stream()
             << "Unable to find shard key index for " << keyPattern.toString() << " in " << nss.ns();
-        LOG(0) << msg;
+        LOGV2(23765, "{msg}", "msg"_attr = msg);
         return {ErrorCodes::InternalError, msg};
     }
 
@@ -136,7 +147,12 @@ StatusWith<int> deleteNextBatch(OperationContext* opCtx,
     const auto min = extend(range.getMin());
     const auto max = extend(range.getMax());
 
-    LOG(1) << "begin removal of " << min << " to " << max << " in " << nss.ns();
+    LOGV2_DEBUG(23766,
+                1,
+                "begin removal of {min} to {max} in {nss_ns}",
+                "min"_attr = min,
+                "max"_attr = max,
+                "nss_ns"_attr = nss.ns());
 
     const auto indexName = idx->indexName();
     const IndexDescriptor* descriptor =
@@ -144,7 +160,7 @@ StatusWith<int> deleteNextBatch(OperationContext* opCtx,
     if (!descriptor) {
         std::string msg = str::stream()
             << "shard key index with name " << indexName << " on '" << nss.ns() << "' was dropped";
-        LOG(0) << msg;
+        LOGV2(23767, "{msg}", "msg"_attr = msg);
         return {ErrorCodes::InternalError, msg};
     }
 
@@ -169,7 +185,7 @@ StatusWith<int> deleteNextBatch(OperationContext* opCtx,
                                                      InternalPlanner::FORWARD);
 
     if (MONGO_unlikely(hangBeforeDoingDeletion.shouldFail())) {
-        LOG(0) << "Hit hangBeforeDoingDeletion failpoint";
+        LOGV2(23768, "Hit hangBeforeDoingDeletion failpoint");
         hangBeforeDoingDeletion.pauseWhileSet(opCtx);
     }
 
@@ -194,9 +210,16 @@ StatusWith<int> deleteNextBatch(OperationContext* opCtx,
         }
 
         if (state == PlanExecutor::FAILURE) {
-            warning() << PlanExecutor::statestr(state) << " - cursor error while trying to delete "
-                      << redact(min) << " to " << redact(max) << " in " << nss
-                      << ": FAILURE, stats: " << Explain::getWinningPlanStats(exec.get());
+            LOGV2_WARNING(
+                23776,
+                "{PlanExecutor_statestr_state} - cursor error while trying to delete {min} to "
+                "{max} in {nss}: FAILURE, stats: {Explain_getWinningPlanStats_exec_get}",
+                "PlanExecutor_statestr_state"_attr = PlanExecutor::statestr(state),
+                "min"_attr = redact(min),
+                "max"_attr = redact(max),
+                "nss"_attr = nss,
+                "Explain_getWinningPlanStats_exec_get"_attr =
+                    Explain::getWinningPlanStats(exec.get()));
             break;
         }
 
@@ -247,9 +270,13 @@ ExecutorFuture<void> deleteRangeInBatches(const std::shared_ptr<executor::TaskEx
                    auto numDeleted = uassertStatusOK(deleteNextBatch(
                        opCtx, collection, keyPattern, range, numDocsToRemovePerBatch));
 
-                   LOG(0) << "Deleted " << numDeleted << " documents in pass in namespace "
-                          << nss.ns() << " with UUID " << collectionUuid << " for range "
-                          << range.toString();
+                   LOGV2(23769,
+                         "Deleted {numDeleted} documents in pass in namespace {nss_ns} with UUID "
+                         "{collectionUuid} for range {range}",
+                         "numDeleted"_attr = numDeleted,
+                         "nss_ns"_attr = nss.ns(),
+                         "collectionUuid"_attr = collectionUuid,
+                         "range"_attr = range.toString());
 
                    return numDeleted;
                });
@@ -299,8 +326,12 @@ void removePersistentRangeDeletionTask(const NamespaceString& nss,
                                << collectionUuid << RangeDeletionTask::kRangeFieldName
                                << range.toBSON()));
         } catch (const DBException& e) {
-            LOG(0) << "Failed to delete range deletion task for range " << range
-                   << " in collection " << nss << causedBy(e.what());
+            LOGV2(23770,
+                  "Failed to delete range deletion task for range {range} in collection "
+                  "{nss}{causedBy_e_what}",
+                  "range"_attr = range,
+                  "nss"_attr = nss,
+                  "causedBy_e_what"_attr = causedBy(e.what()));
         }
     });
 }
@@ -314,8 +345,12 @@ ExecutorFuture<void> waitForDeletionsToMajorityReplicate(
         repl::ReplClientInfo::forClient(opCtx->getClient()).setLastOpToSystemLastOpTime(opCtx);
         auto clientOpTime = repl::ReplClientInfo::forClient(opCtx->getClient()).getLastOp();
 
-        LOG(0) << "Waiting for majority replication of local deletions in namespace " << nss.ns()
-               << " with UUID " << collectionUuid << " for range " << redact(range.toString());
+        LOGV2(23771,
+              "Waiting for majority replication of local deletions in namespace {nss_ns} with UUID "
+              "{collectionUuid} for range {range}",
+              "nss_ns"_attr = nss.ns(),
+              "collectionUuid"_attr = collectionUuid,
+              "range"_attr = redact(range.toString()));
 
         // Asynchronously wait for majority write concern.
         return WaitForMajorityService::get(opCtx->getServiceContext())
@@ -350,9 +385,12 @@ SharedSemiFuture<void> removeDocumentsInRange(
                               executor->now() + delayForActiveQueriesOnSecondariesToComplete);
         })
         .then([=]() mutable {
-            LOG(0) << "Beginning deletion of any documents in " << nss.ns() << " range "
-                   << redact(range.toString()) << " with numDocsToRemovePerBatch "
-                   << numDocsToRemovePerBatch;
+            LOGV2(23772,
+                  "Beginning deletion of any documents in {nss_ns} range {range} with "
+                  "numDocsToRemovePerBatch {numDocsToRemovePerBatch}",
+                  "nss_ns"_attr = nss.ns(),
+                  "range"_attr = redact(range.toString()),
+                  "numDocsToRemovePerBatch"_attr = numDocsToRemovePerBatch);
 
             notifySecondariesThatDeletionIsOccurring(nss, collectionUuid, range);
 
@@ -372,11 +410,16 @@ SharedSemiFuture<void> removeDocumentsInRange(
         })
         .onCompletion([=](Status s) {
             if (s.isOK()) {
-                LOG(0) << "Completed deletion of documents in " << nss.ns() << " range "
-                       << redact(range.toString());
+                LOGV2(23773,
+                      "Completed deletion of documents in {nss_ns} range {range}",
+                      "nss_ns"_attr = nss.ns(),
+                      "range"_attr = redact(range.toString()));
             } else {
-                LOG(0) << "Failed to delete of documents in " << nss.ns() << " range "
-                       << redact(range.toString()) << causedBy(redact(s));
+                LOGV2(23774,
+                      "Failed to delete of documents in {nss_ns} range {range}{causedBy_s}",
+                      "nss_ns"_attr = nss.ns(),
+                      "range"_attr = redact(range.toString()),
+                      "causedBy_s"_attr = causedBy(redact(s)));
             }
 
             if (s.isOK() ||
@@ -384,8 +427,12 @@ SharedSemiFuture<void> removeDocumentsInRange(
                     ErrorCodes::RangeDeletionAbandonedBecauseCollectionWithUUIDDoesNotExist) {
                 removePersistentRangeDeletionTask(nss, collectionUuid, range);
 
-                LOG(1) << "Completed removal of persistent range deletion task for " << nss.ns()
-                       << " range " << redact(range.toString());
+                LOGV2_DEBUG(23775,
+                            1,
+                            "Completed removal of persistent range deletion task for {nss_ns} "
+                            "range {range}",
+                            "nss_ns"_attr = nss.ns(),
+                            "range"_attr = redact(range.toString()));
             }
 
             // Propagate any errors to callers waiting on the result.
diff --git a/src/mongo/db/s/shard_server_op_observer.cpp b/src/mongo/db/s/shard_server_op_observer.cpp
index 3ad62a62953..caf4b68b561 100644
--- a/src/mongo/db/s/shard_server_op_observer.cpp
+++ b/src/mongo/db/s/shard_server_op_observer.cpp
@@ -48,6 +48,7 @@
 #include "mongo/db/s/sharding_initialization_mongod.h"
 #include "mongo/db/s/sharding_state.h"
 #include "mongo/db/s/type_shard_identity.h"
+#include "mongo/logv2/log.h"
 #include "mongo/s/balancer_configuration.h"
 #include "mongo/s/catalog/type_shard_collection.h"
 #include "mongo/s/catalog/type_shard_database.h"
@@ -434,8 +435,9 @@ void ShardServerOpObserver::onDelete(OperationContext* opCtx,
                     uasserted(40070,
                               "cannot delete shardIdentity document while in --shardsvr mode");
                 } else {
-                    warning() << "Shard identity document rolled back.  Will shut down after "
-                                 "finishing rollback.";
+                    LOGV2_WARNING(23779,
+                                  "Shard identity document rolled back.  Will shut down after "
+                                  "finishing rollback.");
                     ShardIdentityRollbackNotifier::get(opCtx)->recordThatRollbackHappened();
                 }
             }
@@ -455,8 +457,9 @@ repl::OpTime ShardServerOpObserver::onDropCollection(OperationContext* opCtx,
 
         // Can't confirm whether there was a ShardIdentity document or not yet, so assume there was
         // one and shut down the process to clear the in-memory sharding state
-        warning() << "admin.system.version collection rolled back. Will shut down after finishing "
-                     "rollback";
+        LOGV2_WARNING(23780,
+                      "admin.system.version collection rolled back. Will shut down after finishing "
+                      "rollback");
 
         ShardIdentityRollbackNotifier::get(opCtx)->recordThatRollbackHappened();
     }
diff --git a/src/mongo/db/s/split_chunk.cpp b/src/mongo/db/s/split_chunk.cpp
index 5ecdbd5f04d..ee29084c850 100644
--- a/src/mongo/db/s/split_chunk.cpp
+++ b/src/mongo/db/s/split_chunk.cpp
@@ -47,6 +47,7 @@
 #include "mongo/db/s/collection_sharding_state.h"
 #include "mongo/db/s/shard_filtering_metadata_refresh.h"
 #include "mongo/db/s/sharding_state.h"
+#include "mongo/logv2/log.h"
 #include "mongo/s/catalog/type_chunk.h"
 #include "mongo/s/client/shard_registry.h"
 #include "mongo/s/grid.h"
@@ -213,8 +214,10 @@ StatusWith<boost::optional<ChunkRange>> splitChunk(OperationContext* opCtx,
 
     Collection* const collection = autoColl.getCollection();
     if (!collection) {
-        warning() << "will not perform top-chunk checking since " << nss.toString()
-                  << " does not exist after splitting";
+        LOGV2_WARNING(
+            23778,
+            "will not perform top-chunk checking since {nss} does not exist after splitting",
+            "nss"_attr = nss.toString());
         return boost::optional<ChunkRange>(boost::none);
     }
 
diff --git a/src/mongo/db/service_context.cpp b/src/mongo/db/service_context.cpp
index 760efa6c4e8..4f83efcff15 100644
--- a/src/mongo/db/service_context.cpp
+++ b/src/mongo/db/service_context.cpp
@@ -44,6 +44,7 @@
 #include "mongo/db/op_observer.h"
 #include "mongo/db/operation_context.h"
 #include "mongo/db/storage/recovery_unit_noop.h"
+#include "mongo/logv2/log.h"
 #include "mongo/transport/service_entry_point.h"
 #include "mongo/transport/session.h"
 #include "mongo/transport/transport_layer.h"
@@ -110,8 +111,11 @@ ServiceContext::ServiceContext()
 ServiceContext::~ServiceContext() {
     stdx::lock_guard<Latch> lk(_mutex);
     for (const auto& client : _clients) {
-        severe() << "Client " << client->desc() << " still exists while destroying ServiceContext@"
-                 << reinterpret_cast<uint64_t>(this);
+        LOGV2_FATAL(23828,
+                    "Client {client_desc} still exists while destroying "
+                    "ServiceContext@{reinterpret_cast_uint64_t_this}",
+                    "client_desc"_attr = client->desc(),
+                    "reinterpret_cast_uint64_t_this"_attr = reinterpret_cast<uint64_t>(this));
     }
     invariant(_clients.empty());
 }
diff --git a/src/mongo/db/snapshot_window_util.cpp b/src/mongo/db/snapshot_window_util.cpp
index eaf8f9f45cc..fb9e7f4f9b2 100644
--- a/src/mongo/db/snapshot_window_util.cpp
+++ b/src/mongo/db/snapshot_window_util.cpp
@@ -38,6 +38,7 @@
 #include "mongo/db/service_context.h"
 #include "mongo/db/snapshot_window_options.h"
 #include "mongo/db/storage/storage_engine.h"
+#include "mongo/logv2/log.h"
 #include "mongo/platform/mutex.h"
 #include "mongo/util/concurrency/with_lock.h"
 #include "mongo/util/fail_point.h"
@@ -111,28 +112,34 @@ void increaseTargetSnapshotWindowSize(OperationContext* opCtx) {
     StorageEngine* engine = opCtx->getServiceContext()->getStorageEngine();
     if (engine && engine->isCacheUnderPressure(opCtx)) {
         invariant(!engine->isEphemeral() || getTestCommandsEnabled());
-        warning() << "Attempted to increase the time window of available snapshots for "
-                     "point-in-time operations (readConcern level 'snapshot' or transactions), but "
-                     "the storage engine cache pressure, per the cachePressureThreshold setting of "
-                     "'"
-                  << snapshotWindowParams.cachePressureThreshold.load()
-                  << "', is too high to allow it to increase. If this happens frequently, consider "
-                     "either increasing the cache pressure threshold or increasing the memory "
-                     "available to the storage engine cache, in order to improve the success rate "
-                     "or speed of point-in-time requests.";
+        LOGV2_WARNING(
+            23788,
+            "Attempted to increase the time window of available snapshots for "
+            "point-in-time operations (readConcern level 'snapshot' or transactions), but "
+            "the storage engine cache pressure, per the cachePressureThreshold setting of "
+            "'{snapshotWindowParams_cachePressureThreshold_load}', is too high to allow it to "
+            "increase. If this happens frequently, consider "
+            "either increasing the cache pressure threshold or increasing the memory "
+            "available to the storage engine cache, in order to improve the success rate "
+            "or speed of point-in-time requests.",
+            "snapshotWindowParams_cachePressureThreshold_load"_attr =
+                snapshotWindowParams.cachePressureThreshold.load());
         _decreaseTargetSnapshotWindowSize(lock, opCtx);
         return;
     }
 
     if (snapshotWindowParams.targetSnapshotHistoryWindowInSeconds.load() ==
         snapshotWindowParams.maxTargetSnapshotHistoryWindowInSeconds.load()) {
-        warning() << "Attempted to increase the time window of available snapshots for "
-                     "point-in-time operations (readConcern level 'snapshot' or transactions), but "
-                     "maxTargetSnapshotHistoryWindowInSeconds has already been reached. If this "
-                     "happens frequently, consider increasing the "
-                     "maxTargetSnapshotHistoryWindowInSeconds setting value, which is currently "
-                     "set to '"
-                  << snapshotWindowParams.maxTargetSnapshotHistoryWindowInSeconds.load() << "'.";
+        LOGV2_WARNING(
+            23789,
+            "Attempted to increase the time window of available snapshots for "
+            "point-in-time operations (readConcern level 'snapshot' or transactions), but "
+            "maxTargetSnapshotHistoryWindowInSeconds has already been reached. If this "
+            "happens frequently, consider increasing the "
+            "maxTargetSnapshotHistoryWindowInSeconds setting value, which is currently "
+            "set to '{snapshotWindowParams_maxTargetSnapshotHistoryWindowInSeconds_load}'.",
+            "snapshotWindowParams_maxTargetSnapshotHistoryWindowInSeconds_load"_attr =
+                snapshotWindowParams.maxTargetSnapshotHistoryWindowInSeconds.load());
         return;
     }
 
diff --git a/src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.cpp b/src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.cpp
index 69e553375e0..6760f71a89c 100644
--- a/src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.cpp
+++ b/src/mongo/db/storage/ephemeral_for_test/ephemeral_for_test_record_store.cpp
@@ -38,6 +38,7 @@
 #include "mongo/db/operation_context.h"
 #include "mongo/db/storage/oplog_hack.h"
 #include "mongo/db/storage/recovery_unit.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 #include "mongo/util/str.h"
 #include "mongo/util/unowned_ptr.h"
@@ -305,8 +306,10 @@ const EphemeralForTestRecordStore::EphemeralForTestRecord* EphemeralForTestRecor
     WithLock, const RecordId& loc) const {
     Records::const_iterator it = _data->records.find(loc);
     if (it == _data->records.end()) {
-        error() << "EphemeralForTestRecordStore::recordFor cannot find record for " << ns() << ":"
-                << loc;
+        LOGV2_ERROR(23720,
+                    "EphemeralForTestRecordStore::recordFor cannot find record for {ns}:{loc}",
+                    "ns"_attr = ns(),
+                    "loc"_attr = loc);
     }
     invariant(it != _data->records.end());
     return &it->second;
@@ -316,8 +319,10 @@ EphemeralForTestRecordStore::EphemeralForTestRecord* EphemeralForTestRecordStore
     WithLock, const RecordId& loc) {
     Records::iterator it = _data->records.find(loc);
     if (it == _data->records.end()) {
-        error() << "EphemeralForTestRecordStore::recordFor cannot find record for " << ns() << ":"
-                << loc;
+        LOGV2_ERROR(23721,
+                    "EphemeralForTestRecordStore::recordFor cannot find record for {ns}:{loc}",
+                    "ns"_attr = ns(),
+                    "loc"_attr = loc);
     }
     invariant(it != _data->records.end());
     return &it->second;
diff --git a/src/mongo/db/storage/remove_saver.cpp b/src/mongo/db/storage/remove_saver.cpp
index 7012f671c37..65d30c49518 100644
--- a/src/mongo/db/storage/remove_saver.cpp
+++ b/src/mongo/db/storage/remove_saver.cpp
@@ -39,6 +39,7 @@
 #include "mongo/db/service_context.h"
 #include "mongo/db/storage/encryption_hooks.h"
 #include "mongo/db/storage/storage_options.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/errno_util.h"
 #include "mongo/util/log.h"
 
@@ -84,30 +85,39 @@ RemoveSaver::~RemoveSaver() {
         size_t resultLen;
         Status status = _protector->finalize(protectedBuffer.get(), protectedSizeMax, &resultLen);
         if (!status.isOK()) {
-            severe() << "Unable to finalize DataProtector while closing RemoveSaver: "
-                     << redact(status);
+            LOGV2_FATAL(23736,
+                        "Unable to finalize DataProtector while closing RemoveSaver: {status}",
+                        "status"_attr = redact(status));
             fassertFailed(34350);
         }
 
         _out->write(reinterpret_cast<const char*>(protectedBuffer.get()), resultLen);
         if (_out->fail()) {
-            severe() << "Couldn't write finalized DataProtector data to: " << _file.string()
-                     << " for remove saving: " << redact(errnoWithDescription());
+            LOGV2_FATAL(23737,
+                        "Couldn't write finalized DataProtector data to: {file_string} for remove "
+                        "saving: {errnoWithDescription}",
+                        "file_string"_attr = _file.string(),
+                        "errnoWithDescription"_attr = redact(errnoWithDescription()));
             fassertFailed(34351);
         }
 
         protectedBuffer.reset(new uint8_t[protectedSizeMax]);
         status = _protector->finalizeTag(protectedBuffer.get(), protectedSizeMax, &resultLen);
         if (!status.isOK()) {
-            severe() << "Unable to get finalizeTag from DataProtector while closing RemoveSaver: "
-                     << redact(status);
+            LOGV2_FATAL(
+                23738,
+                "Unable to get finalizeTag from DataProtector while closing RemoveSaver: {status}",
+                "status"_attr = redact(status));
             fassertFailed(34352);
         }
 
         if (resultLen != _protector->getNumberOfBytesReservedForTag()) {
-            severe() << "Attempted to write tag of size " << resultLen
-                     << " when DataProtector only reserved "
-                     << _protector->getNumberOfBytesReservedForTag() << " bytes";
+            LOGV2_FATAL(23739,
+                        "Attempted to write tag of size {resultLen} when DataProtector only "
+                        "reserved {protector_getNumberOfBytesReservedForTag} bytes",
+                        "resultLen"_attr = resultLen,
+                        "protector_getNumberOfBytesReservedForTag"_attr =
+                            _protector->getNumberOfBytesReservedForTag());
             fassertFailed(34353);
         }
 
@@ -115,8 +125,11 @@ RemoveSaver::~RemoveSaver() {
         _out->write(reinterpret_cast<const char*>(protectedBuffer.get()), resultLen);
 
         if (_out->fail()) {
-            severe() << "Couldn't write finalizeTag from DataProtector to: " << _file.string()
-                     << " for remove saving: " << redact(errnoWithDescription());
+            LOGV2_FATAL(23740,
+                        "Couldn't write finalizeTag from DataProtector to: {file_string} for "
+                        "remove saving: {errnoWithDescription}",
+                        "file_string"_attr = _file.string(),
+                        "errnoWithDescription"_attr = redact(errnoWithDescription()));
             fassertFailed(34354);
         }
     }
@@ -133,7 +146,7 @@ Status RemoveSaver::goingToDelete(const BSONObj& o) {
         if (_out->fail()) {
             string msg = str::stream() << "couldn't create file: " << _file.string()
                                        << " for remove saving: " << redact(errnoWithDescription());
-            error() << msg;
+            LOGV2_ERROR(23734, "{msg}", "msg"_attr = msg);
             _out.reset();
             _out = nullptr;
             return Status(ErrorCodes::FileNotOpen, msg);
@@ -168,7 +181,7 @@ Status RemoveSaver::goingToDelete(const BSONObj& o) {
     if (_out->fail()) {
         string msg = str::stream() << "couldn't write document to file: " << _file.string()
                                    << " for remove saving: " << redact(errnoWithDescription());
-        error() << msg;
+        LOGV2_ERROR(23735, "{msg}", "msg"_attr = msg);
         return Status(ErrorCodes::OperationFailed, msg);
     }
 
diff --git a/src/mongo/db/storage/storage_repair_observer.cpp b/src/mongo/db/storage/storage_repair_observer.cpp
index 8aab8e82979..c5506aac4a4 100644
--- a/src/mongo/db/storage/storage_repair_observer.cpp
+++ b/src/mongo/db/storage/storage_repair_observer.cpp
@@ -49,6 +49,7 @@
 #include "mongo/db/service_context.h"
 #include "mongo/db/storage/storage_file_util.h"
 #include "mongo/db/storage/storage_options.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/file.h"
 #include "mongo/util/log.h"
 
@@ -123,8 +124,11 @@ void StorageRepairObserver::_touchRepairIncompleteFile() {
     boost::filesystem::ofstream fileStream(_repairIncompleteFilePath);
     fileStream << "This file indicates that a repair operation is in progress or incomplete.";
     if (fileStream.fail()) {
-        severe() << "Failed to write to file " << _repairIncompleteFilePath.string() << ": "
-                 << errnoWithDescription();
+        LOGV2_FATAL(
+            23756,
+            "Failed to write to file {repairIncompleteFilePath_string}: {errnoWithDescription}",
+            "repairIncompleteFilePath_string"_attr = _repairIncompleteFilePath.string(),
+            "errnoWithDescription"_attr = errnoWithDescription());
         fassertFailedNoTrace(50920);
     }
     fileStream.close();
@@ -138,8 +142,10 @@ void StorageRepairObserver::_removeRepairIncompleteFile() {
     boost::filesystem::remove(_repairIncompleteFilePath, ec);
 
     if (ec) {
-        severe() << "Failed to remove file " << _repairIncompleteFilePath.string() << ": "
-                 << ec.message();
+        LOGV2_FATAL(23757,
+                    "Failed to remove file {repairIncompleteFilePath_string}: {ec_message}",
+                    "repairIncompleteFilePath_string"_attr = _repairIncompleteFilePath.string(),
+                    "ec_message"_attr = ec.message());
         fassertFailedNoTrace(50921);
     }
     fassertNoTrace(50927, fsyncParentDirectory(_repairIncompleteFilePath));
diff --git a/src/mongo/db/storage/wiredtiger/wiredtiger_cursor.cpp b/src/mongo/db/storage/wiredtiger/wiredtiger_cursor.cpp
index ba3899d9a6e..1008ad1b460 100644
--- a/src/mongo/db/storage/wiredtiger/wiredtiger_cursor.cpp
+++ b/src/mongo/db/storage/wiredtiger/wiredtiger_cursor.cpp
@@ -35,6 +35,7 @@
 
 #include "mongo/db/storage/recovery_unit.h"
 #include "mongo/db/storage/wiredtiger/wiredtiger_util.h"
+#include "mongo/logv2/log.h"
 #include "mongo/util/log.h"
 
 namespace mongo {
@@ -81,7 +82,7 @@ WiredTigerCursor::WiredTigerCursor(const std::string& uri,
         // A WiredTiger table will not be available in the latest checkpoint if the checkpoint
         // thread hasn't ran after the initial WiredTiger table was created.
         if (!_isCheckpoint) {
-            error() << ex;
+            LOGV2_ERROR(23719, "{ex}", "ex"_attr = ex);
             fassertFailedNoTrace(50883);
         }
         throw;