$ currentOp（汇总）_MonogDB 中文网

MongoDB 中文手册

参考 > 参考 > 经营者 > 聚合管道阶段 > $ currentOp（汇总）

在本页面

定义
约束条件
例
输出栏位

定义¶

3.6版的新功能。

$currentOp¶

返回文档流，其中包含有关活动和/或休眠操作以及在事务中持有锁的非活动会话的信息。该阶段为每个操作或会话返回一个文档。要运行$currentOp，请使用数据库db.aggregate()上的帮助程序admin。

的$currentOp聚合阶段优选在 currentOp命令和它的mongo外壳的辅助db.currentOp()。由于currentOp 命令和db.currentOp()帮助程序在单个文档中返回结果，currentOp因此结果集的总大小受文档最大16MB BSON大小限制。该$currentOp阶段在文件流上返回一个光标，每个文件报告一个操作。每个操作文档均受16MB BSON限制，但是与currentOp命令不同，结果集的总大小没有限制。

$currentOp 还可以使您在文档通过管道时对结果执行任意转换。

语法¶

在版本4.2中进行了更改。

复制

{ $currentOp: { allUsers: <boolean>, idleConnections: <boolean>, idleCursors: <boolean>, idleSessions: <boolean>, localOps: <boolean> } }

$currentOp 将选项文档作为其操作数：

选项	描述
全部用户	布尔值。如果设置为`false`，`$currentOp`将仅报告属于运行该命令的用户的操作/空闲连接/空闲光标/空闲会话。如果设置为`true`，`$currentOp`将报告属于所有用户的操作。注意对于实施访问控制的独立集和副本集，`inprog`如果，则需要特权。`allUsers: true` 对于实施访问控制的分片群集，`inprog` 必须具有特权才能运行`$currentOp`。默认为`false`。
idleConnections	布尔值。如果设置为`false`，`$currentOp`将仅报告活动操作。如果设置为`true`，将返回所有操作，包括空闲连接。默认为`false`。
idleCursors	布尔值。如果设置为`true`，`$currentOp`将报告为“ idle”的游标；否则为false。即打开但当前未在`getMore`操作中处于活动状态。有关空闲游标的信息已`type` 设置为`"idleCursor"`。当前在`getMore`操作信息中处于活动状态的光标的信息已 `type`设置为`"op"`并 `op`设置为`getmore`。默认为`false`。 4.2版中的新功能。
idleSessions	布尔值。如果设置为`true`，则除了进行主动/休眠操作外， `$currentOp`还将报告：在事务中持有锁的非活动会话。每个不活动的会话将在`$currentOp`流中显示为单独的文档。会话文档包括有关该`lsid`字段中的会话ID和该字段中的事务的信息`transaction`。从MongoDB 4.2开始，有关空闲会话的信息已 `type`设置为`"idleSession"`。 `$currentOp.twoPhaseCommitCoordinator` 在 `inactive` `state` 如果设置为`false`，`$currentOp`则不会报告以下内容：无效的会话 `$currentOp.twoPhaseCommitCoordinator` 信息在 `inactive` `state` 默认为`true`。版本4.0中的新功能。
localOps	布尔值。如果设置`true`为正在运行的聚合 `mongos`，则`$currentOp`仅报告在该本地运行的那些操作 `mongos`。如果为`false`， `$currentOp`则将改为报告在分片上运行的操作。该`localOps`参数对`$currentOp`在上运行的聚合无效 `mongod`。默认为`false`。版本4.0中的新功能。
回溯	布尔值。确定是否将调用堆栈信息作为`waitingForLatch`输出字段的一部分返回。如果设置为`true`，则`$currentOp`包含 `waitingForLatch.backtrace` 包含调用堆栈信息的字段（如果有）。如果不可用，则该字段包含一个空数组。如果设置为`false`，则`$currentOp`忽略该 `waitingForLatch.backtrace` 字段。默认为`false`。版本4.2.2中的新功能。

省略任何上述参数将导致$ currentOp使用该参数的默认值。指定一个空文档，如下所示，以使用所有参数的默认值。

复制

{ $currentOp: { } }

约束¶

管道¶

$currentOp 必须是管道的第一阶段。
以开头的管道$currentOp只能在admin数据库上运行。

访问控制¶

对于实施访问控制的独立集和副本集，如果allUsers：true， inprog则需要特权才能运行。$currentOp
对于实施访问控制的分片群集，inprog 必须具有特权才能运行$currentOp。

交易¶

$currentOp不允许进行交易。

例子¶

下面的示例返回有关作为事务一部分持有锁的非活动会话的信息。特别：

第一阶段返回所有活动操作以及作为事务一部分持有锁的非活动会话的文档。
第二阶段仅过滤与非活动会话相关的那些文档，这些文档将锁作为事务的一部分进行处理。

复制

db.getSiblingDB("admin").aggregate( [
   { $currentOp : { allUsers: true, idleSessions: true } },
   { $match : { active: false, transaction : { $exists: true } } }
] )

从4.2版开始，您可以$currentOp.type用来指定等效过滤器：

复制

db.getSiblingDB("admin").aggregate( [
   { $currentOp : { allUsers: true, idleSessions: true } },
   { $match : { type: "idleSession" } }
] )

小费

对于从4.2.1版本开始的分片群集上的事务，在上述示例中包括localOps：true以获取事务的复合视图。

这两个操作均返回以下形式的文档：

副本集
分片群集（localOps：true）
分片集群

在mongod副本集的一部分上运行时：

复制

{
   "type" : "idleSession",
   "host" : "example.mongodb.com:27017",
   "desc" : "inactive transaction",
   "client" : "198.51.100.1:50428",
   "connectionId" : NumberLong(32),
   "appName" : "",
   "clientMetadata" : {
      "driver" : {
         "name" : "PyMongo",
         "version" : "3.9.0"
      },
      "os" : {
         "type" : "Darwin",
         "name" : "Darwin",
         "architecture" : "x86_64",
         "version" : "10.14.5"
      },
      "platform" : "CPython 3.7.1.final.0"
   },
   "lsid" : {
      "id" : UUID("ff21e1a9-a130-4fe0-942f-9e6b6c67ea3c"),
      "uid" : BinData(0,"3pxqkATNUYKV/soT7qqKE0zC0BFb0pBz1pk4xXcSHsI=")
   },
   "transaction" : {
      "parameters" : {
         "txnNumber" : NumberLong(4),
         "autocommit" : false,
         "readConcern" : {
            "level" : "snapshot",
            "afterClusterTime" : Timestamp(1563892246, 1)
         }
      },
      "readTimestamp" : Timestamp(0, 0),
      "startWallClockTime" : "2019-07-23T10:30:49.461-0400",
      "timeOpenMicros" : NumberLong(1913590),
      "timeActiveMicros" : NumberLong(55),
      "timeInactiveMicros" : NumberLong(1913535),
      "expiryTime" : "2019-07-23T10:31:49.461-0400"
   },
   "waitingForLock" : false,
   "active" : false,
   "locks" : {
      "ReplicationStateTransition" : "w",
      "Global" : "w",
      "Database" : "w",
      "Collection" : "w"
   },
   "lockStats" : {
      "ReplicationStateTransition" : {
         "acquireCount" : {
            "w" : NumberLong(5)
         }
      },
      "Global" : {
         "acquireCount" : {
            "r" : NumberLong(3),
            "w" : NumberLong(1)
         }
      },
      "Database" : {
         "acquireCount" : {
            "r" : NumberLong(2),
            "w" : NumberLong(1)
         }
      },
      "Collection" : {
         "acquireCount" : {
            "w" : NumberLong(1)
         }
      },
      "Mutex" : {
         "acquireCount" : {
            "r" : NumberLong(3)
         }
      },
      "oplog" : {
         "acquireCount" : {
            "r" : NumberLong(2)
         }
      }
   },
   "waitingForFlowControl" : false,
   "flowControlStats" : {
    }

}

从4.2.1版本开始，$currentOp使用localOps运行：true提供了在其上运行的正在进行的事务的复合视图（而不是按分片信息）mongos。

复制

db.getSiblingDB("admin").aggregate( [
   { $currentOp : { allUsers: true, idleSessions: true, localOps: true } },
   { $match : { type: "idleSession" } }
] );

// or

db.getSiblingDB("admin").aggregate( [
   { $currentOp : { allUsers: true, idleSessions: true, localOps: true } },
   { $match : { active: false, transaction : { $exists: true } } }
] )

复制

{
   "type" : "idleSession",
   "host" : "example.mongodb.com:27017",
   "desc" : "inactive transaction",
   "client" : "198.51.100.1:49618",
   "connectionId" : NumberLong(48),
   "appName" : "",
   "clientMetadata" : {
      "driver" : {
         "name" : "PyMongo",
         "version" : "3.9.0"
      },
      "os" : {
         "type" : "Darwin",
         "name" : "Darwin",
         "architecture" : "x86_64",
         "version" : "10.14.6"
      },
      "platform" : "CPython 3.7.1.final.0",
      "mongos" : {
         "host" : "example.mongodb.com:27017",
         "client" : "198.51.100.1:53268",
         "version" : "4.2.1"
      }
   },
   "lsid" : {
      "id" : UUID("2c9ce111-133e-45b7-a00f-a7871005cae1"),
      "uid" : BinData(0,"3pxqkATNUYKV/soT7qqKE0zC0BFb0pBz1pk4xXcSHsI=")
   },
   "active" : false,
   "transaction" : {
      "parameters" : {
         "txnNumber" : NumberLong(2),
         "autocommit" : false,
         "readConcern" : {
            "level" : "snapshot",
            "afterClusterTime" : Timestamp(1571869019, 2)
         }
      },
      "globalReadTimestamp" : Timestamp(1571869019, 2),
      "startWallClockTime" : "2019-10-23T18:16:59.341-0400",
      "timeOpenMicros" : NumberLong(169244639),
      "timeActiveMicros" : NumberLong(535),
      "timeInactiveMicros" : NumberLong(169244104),
      "numParticipants" : 2,
      "participants" : [
         {
            "name" : "shardB",
            "coordinator" : true,
            "readOnly" : false
         },
         {
            "name" : "shardA",
            "coordinator" : false,
            "readOnly" : false
         }
      ],
      "numReadOnlyParticipants" : 0,
      "numNonReadOnlyParticipants" : 2
   }
}

在4.2.0，当没有运行，你可以只返回正在进行的交易信息真实：localOps上mongos。如果没有运行localOps：真实的mongos，交易信息是每个碎片。

在mongos没有localOps：true的情况下运行时，事务信息是按分片进行的。

复制

{
   "shard" : "shardB",
   "type" : "idleSession",
   "host" : "shardB.mongodb.com:27018",
   "desc" : "inactive transaction",
   "client_s" : "198.51.100.1:53961",
   "connectionId" : NumberLong(63),
   "appName" : "",
   "clientMetadata" : {
      "driver" : {
         "name" : "PyMongo",
         "version" : "3.9.0"
      },
      "os" : {
         "type" : "Darwin",
         "name" : "Darwin",
         "architecture" : "x86_64",
         "version" : "10.14.6"
      },
      "platform" : "CPython 3.7.1.final.0",
      "mongos" : {
         "host" : "example.mongodb.com:27017",
         "client" : "198.51.100.1:53976",
         "version" : "4.2.0"
      }
   },
   "lsid" : {
      "id" : UUID("720d403c-8daf-40bb-b61e-329e20b0493b"),
      "uid" : BinData(0,"3pxqkATNUYKV/soT7qqKE0zC0BFb0pBz1pk4xXcSHsI=")
   },
   "transaction" : {
      "parameters" : {
         "txnNumber" : NumberLong(1),
         "autocommit" : false,
         "readConcern" : {
            "level" : "snapshot"
         }
      },
      "readTimestamp" : Timestamp(0, 0),
      "startWallClockTime" : "2019-10-21T18:31:12.192-0400",
      "timeOpenMicros" : NumberLong(24137008),
      "timeActiveMicros" : NumberLong(52),
      "timeInactiveMicros" : NumberLong(24136956),
      "expiryTime" : "2019-10-21T18:32:12.192-0400"
   },
   "waitingForLock" : false,
   "active" : false,
   "locks" : {
      "ReplicationStateTransition" : "w",
      "Global" : "w",
      "Database" : "w",
      "Collection" : "w"
   },
   "lockStats" : {
      "ReplicationStateTransition" : {
         "acquireCount" : {
            "w" : NumberLong(3)
         }
      },
      "Global" : {
         "acquireCount" : {
            "r" : NumberLong(1),
            "w" : NumberLong(1)
         }
      },
      "Database" : {
         "acquireCount" : {
            "r" : NumberLong(1),
            "w" : NumberLong(1)
         }
      },
      "Collection" : {
         "acquireCount" : {
            "r" : NumberLong(1),
            "w" : NumberLong(1)
         }
      },
      "Mutex" : {
         "acquireCount" : {
            "r" : NumberLong(6)
         }
      }
   }
}
{
   "shard" : "shardA",
   "type" : "idleSession",
   ...
}

输出字段¶

每个输出文档可能包含与该操作相关的以下字段的子集：

$currentOp.type¶

4.2版中的新功能。

操作类型。值可以是：

op
idleSession
idleCursor

如果$currentOp.type为op，则$currentOp.op 提供有关特定操作的详细信息。

$currentOp.host¶: 运行操作的主机的名称。

$currentOp.shard¶

运行该操作的分片的名称。

仅在分片群集中存在。

$currentOp.desc¶: 操作说明。

$currentOp.connectionId¶: 特定操作源自的连接的标识符。

$currentOp.client¶

操作起源的客户端连接的IP地址（或主机名）和临时端口。

对于多文档事务，$currentOp.client存储有关最新客户端的信息，以在事务内运行操作。

仅适用于独立机和副本集

$currentOp.client_s¶

操作来源的IP地址（或主机名）和临时端口 mongos。

仅适用于分片群集

$currentOp.clientMetadata¶

有关客户端的其他信息。

对于多文档事务，$currentOp.client存储有关最新客户端的信息，以在事务内运行操作。

$currentOp.appName¶: 3.4版的新功能。

运行该操作的客户端应用程序的标识符。使用appName连接字符串选项可以为appName字段设置自定义值。

$currentOp.active¶: 一个布尔值，指定操作是否已开始。值是true该操作是否已开始或false该操作是否空闲（例如空闲连接，非活动会话或当前空闲的内部线程）。即使一个操作已屈服于另一个操作，它也可以处于活动状态。