Atlas Stream Processing Methods

This version of the documentation is archived and no longer supported. View the current documentation to learn how to upgrade your version of MongoDB server.

Note

mongosh Methods

The methods listed on this table of contents page are mongosh methods. This is not the documentation for Node.js or other programming language specific driver methods.

In most cases, mongosh methods work the same way as the legacy mongo shell methods. However, some legacy methods are unavailable in mongosh.

For the legacy mongo shell documentation, refer to the documentation for the corresponding MongoDB Server release:

mongo shell v4.4

For MongoDB API drivers, refer to the language specific MongoDB driver documentation.

Atlas Stream Processors let you perform aggregation operations against streams of continuous data using the same data model and query API that you use with at-rest data.

Use the following methods to manage Stream Processors

Important

The following methods can only be run on deployments hosted on MongoDB Atlas.

Note

For details on a specific method, including syntax and examples, click on the link to the method's reference page.

Name	Description
`sp.createStreamProcessor()`	Creates a stream processor.
`sp.listConnections()`	Lists all existing connections in the connection registry of the current stream processing instance.
`sp.listStreamProcessors()`	Lists all existing stream processors on the current stream processing instance.
`sp.process()`	Creates an ephemeral stream processor.
`sp.processor.drop()`	Deletes an existing stream processor.
`sp.processor.sample()`	Returns an array of sampled results from a currently running stream processor.
`sp.processor.start()`	Starts an existing stream processor.
`sp.processor.stats()`	Returns statistics summarizing an existing stream processor.
`sp.processor.stop()`	Stops a currently running stream processor.

Back

db.collection.updateSearchIndex()

sp.createStreamProcessor()