Database Manual / Reference / mongosh Methods

Atlas Stream Processing MethodsAtlas流处理方法

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.此目录页上列出的方法是mongosh方法。这不是Node.js或其他特定于编程语言的驱动程序方法的文档。

In most cases, mongosh methods work the same way as the legacy mongo shell methods. However, some legacy methods are unavailable in mongosh.在大多数情况下，mongosh方法的工作方式与遗留的mongoshell方法相同。然而，一些遗留方法在mongosh中不可用。

For MongoDB API drivers, refer to the language specific MongoDB driver documentation.有关MongoDB API驱动程序，请参阅特定语言的MongoDB驱动程序文档。

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.Atlas流处理器允许您使用与静态数据相同的数据模型和查询API对连续数据流执行聚合操作。

Use the following methods to manage Stream Processors使用以下方法管理流处理器

Important

The following methods can only be run on deployments hosted on MongoDB Atlas.以下方法只能在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.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.停止当前正在运行的流处理器。