This browser is no longer supported.
Upgrade to Microsoft Edge to take advantage of the latest features, security updates, and technical support.
![](data:image/svg+xml, %3Csvg xmlns='http://www.w3.org/2000/svg' height='64' class='font-weight-bold' style='font: 600 30.11764705882353px "SegoeUI", Arial' width='64'%3E%3Ccircle fill='hsl(140.8, 53%, 23%)' cx='32' cy='32' r='32' /%3E%3Ctext x='50%25' y='55%25' dominant-baseline='middle' text-anchor='middle' fill='%23FFF' %3EZT%3C/text%3E%3C/svg%3E)
When I use the change stream feature of mongodb in cosmos, it fails. How can I make mongodb in cosmos support this feature?
// ChangeStreamExample.js
const { MongoClient } = require("mongodb");
const uri = "xxxxxx";
async function run() {
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });
try {
await client.connect();
const database = client.db("tao-zhang");
const collection = database.collection("test01");
const changeStream = collection.watch();
while (await changeStream.hasNext()) {
const change = await changeStream.next();
const data = {
operationType: change.operationType,
namespace: change.ns.db + "." + change.ns.coll,
documentKey: change.documentKey,
resumeToken: change._id,
fullDocument: change.fullDocument,
wallTime: change.clusterTime
};
console.log(JSON.stringify(data, null, 4));
}
} catch (e) {
console.error("Error processing change stream:", e);
} finally {
await client.close();
}
}
run();
error:
(node:3212484) [MONGODB DRIVER] Warning: useNewUrlParser is a deprecated option: useNewUrlParser has no effect since Node.js Driver version 4.0.0 and will be removed in the next major version
(Use node --trace-warnings ... to show where the warning was created)
(node:3212484) [MONGODB DRIVER] Warning: useUnifiedTopology is a deprecated option: useUnifiedTopology has no effect since Node.js Driver version 4.0.0 and will be removed in the next major version
Error processing change stream: MongoServerError: Stage $changeStream is not supported yet in native pipeline
at Connection.sendCommand (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/cmap/connection.js:298:27)
at processTicksAndRejections (node:internal/process/task_queues:96:5)
at async Connection.command (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/cmap/connection.js:326:26)
at async Server.command (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/sdam/server.js:167:29)
at async AggregateOperation.executeCommand (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/operations/command.js:76:16)
at async AggregateOperation.execute (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/operations/aggregate.js:87:16)
at async tryOperation (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/operations/execute_operation.js:207:20)
at async executeOperation (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/operations/execute_operation.js:75:16)
at async ChangeStreamCursor._initialize (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/cursor/change_stream_cursor.js:81:26)
at async ChangeStreamCursor.cursorInit (/home/hanh/data/zhangtao/genai-retrieval-database/examples/node_modules/mongodb/lib/cursor/abstract_cursor.js:632:27) {
errorLabelSet: Set(0) {},
errorResponse: {
ok: 0,
errmsg: 'Stage $changeStream is not supported yet in native pipeline',
code: 115,
codeName: 'CommandNotSupported'
},
ok: 0,
code: 115,
codeName: 'CommandNotSupported'
}
I don't see a change stream, I really need this functionality. Please answer as soon as possible. Thank you!
![](data:image/svg+xml, %3Csvg xmlns='http://www.w3.org/2000/svg' height='64' class='font-weight-bold' style='font: 600 30.11764705882353px "SegoeUI", Arial' width='64'%3E%3Ccircle fill='hsl(249.60000000000002, 51%, 34%)' cx='32' cy='32' r='32' /%3E%3Ctext x='50%25' y='55%25' dominant-baseline='middle' text-anchor='middle' fill='%23FFF' %3EAP%3C/text%3E%3C/svg%3E)
Hi Zhang, Tao ,
Thank you for reaching out and posting the query.
Based on your inquiry, we understand that the error you are encountering when trying to use the change stream feature in Azure Cosmos DB for MongoDB API is:
RunCopy code
1Error processing change stream: MongoServerError: Stage $changeStream is not supported yet in native pipeline
I have reviewed the Microsoft document and made some modifications based on it
Key Points from the Documentation
Change Streams Availability: The documentation states that change streams are available for vCore-based Azure Cosmos DB for MongoDB (Preview). Ensure that you are using a vCore-based instance and that it is properly configured to support change streams.
Steps to Correct the Issue
Update Your Code: I have updated the code based on the Microsoft document. Could you please give it a try,
const { MongoClient } = require("mongodb");
const uri = "xxxxxx"; // Replace with your connection string
async function run() {
const { MongoClient } = require("mongodb");
const uri = "xxxxxx"; // Replace with your connection string
async function run() {
const client = new MongoClient(uri);
try {
await client.connect();
const database = client.db("tao-zhang");
const collection = database.collection("test01");
// Set up the change stream with the required stages
const changeStream = collection.watch([
{ $match: { "operationType": { $in: ["insert", "update", "replace"] } } },
{ $project: { "_id": 1, "fullDocument": 1, "ns": 1, "documentKey": 1 } }
], { fullDocument: "updateLookup" });
// Process the change stream
while (await changeStream.hasNext()) {
const change = await changeStream.next();
console.log(JSON.stringify(change, null, 4));
}
} catch (e) {
console.error("Error processing change stream:", e);
} finally {
await client.close();
}
}
run();
```Remove Deprecated Options:
The warnings about useNewUrlParser and useUnifiedTopology indicate that these options are deprecated in the MongoDB Node.js driver version 4.0.0 and later. You can safely remove these options from your MongoClient instantiation.
Testing:After making these changes, test your code again to see if it successfully establishes a change stream.
If you have confirmed that you are using a vCore-based Azure Cosmos DB for MongoDB instance and have updated your code according to the documentation, you should be able to utilize the change stream feature.
I would request you to refer the below mentioned links for more information
DOC- [https://learn.microsoft.com/en-us/azure/cosmos-db/mongodb/vcore/change-streams?tabs=javascript%2CInsert](https://learn.microsoft.com/en-us/azure/cosmos-db/mongodb/vcore/change-streams?tabs=javascript%2CInsert)
[https://learn.microsoft.com/en-us/azure/cosmos-db/mongodb/change-streams?tabs=javascript](https://learn.microsoft.com/en-us/azure/cosmos-db/mongodb/change-streams?tabs=javascript)
I hope this information helps. Please do let us know if you have any further queries.
I tried your modified code and it still shows no support, but my version is indeed vCore-based Azure Cosmos DB for MongoDB, do I need to set what to make it support change stream?
I did not find the relevant information in the document link you gave. I do not know how to make my vCore-based Azure Cosmos DB for MongoDB support change stream.
It is still in Preview, You need to create a request using the form mentioned in the documentation https://learn.microsoft.com/en-us/azure/cosmos-db/mongodb/vcore/change-streams?tabs=javascript%2CInsert.