$currentOp - Amazon DocumentDB

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

$currentOp

Tahap $currentOp agregasi mengembalikan informasi tentang operasi yang sedang berjalan dalam database. Tahap ini berguna untuk memantau kueri dan operasi aktif dalam jalur agregasi.

Parameter

  • allUsers(opsional): Ketika diatur ketrue, mengembalikan operasi untuk semua pengguna. Default-nya adalah false.

  • idleConnections(opsional): Ketika diatur ketrue, termasuk koneksi idle. Default-nya adalah false.

  • idleCursors(opsional): Ketika diatur ketrue, termasuk informasi tentang kursor siaga. Default-nya adalah false.

  • idleSessions(opsional): Ketika diatur ketrue, termasuk informasi tentang sesi idle. Default-nya adalah true.

  • localOps(opsional): Ketika diatur ketrue, termasuk operasi lokal. Default-nya adalah false.

Contoh (MongoDB Shell)

Contoh berikut menunjukkan menggunakan tahap $currentOp agregasi untuk mengambil informasi tentang operasi baca aktif.

Contoh kueri

db.aggregate([ { $currentOp: { allUsers: true, idleConnections: false } }, { $match: { op: "query" } } ])

Keluaran

[ { "opid": "12345", "active": true, "op": "query", "ns": "test.users", "secs_running": 2 } ]

Contoh kode

Untuk melihat contoh kode untuk menggunakan $currentOp perintah, pilih tab untuk bahasa yang ingin Anda gunakan:

Node.js
const { MongoClient } = require('mongodb'); async function example() { const client = await MongoClient.connect('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false'); const db = client.db('admin'); const result = await db.aggregate([ { $currentOp: { allUsers: true, idleConnections: false } }, { $match: { op: "query" } } ]).toArray(); console.log(result); await client.close(); } example();
Python
from pymongo import MongoClient def example(): client = MongoClient('mongodb://<username>:<password>@<cluster-endpoint>:27017/?tls=true&tlsCAFile=global-bundle.pem&replicaSet=rs0&readPreference=secondaryPreferred&retryWrites=false') db = client['admin'] result = list(db.aggregate([ { '$currentOp': { 'allUsers': True, 'idleConnections': False } }, { '$match': { 'op': 'query' } } ])) print(result) client.close() example()