每个 Stream Processing 工作区都会在其连接注册表中存储与流数据源或接收器的每个配置连接。此页面上的程序将引导您创建和配置 Atlas Stream Processing 连接。
支持的集成
配置Atlas Stream Processing连接时，请确保选择适合您使用案例的连接类型。Atlas Stream Processing支持以下提供者：
Provider (See note) | 说明 | 连接类型 | 高级网络 |
|---|---|---|---|
Kafka Broker | 可配置的服务器，用于接收和存储事件流，并将其组织为分区主题。 | Private Link 或 VPC 对等互连。支持取决于 Kafka 供应商。 | |
Atlas 集群 | 云托管的MongoDB服务器提供永久存储和事件驱动的变更流。 | Atlas 托管 | |
Atlas 集群（时间序列集合） | MongoDB time series collection used as a destination for processed data. | 汇集器仅限 | Atlas 托管 |
AWSS3 | 托管在Amazon Web Services上的对象存储容器。 | 汇集器仅限 | |
AWS Kinesis | 用于接收和存储事件流并提供各种集成工具的云托管平台。 | ||
Azure Blob 存储 | 托管在 Azure 上的对象存储容器。 | 汇集器仅限 | |
Google Cloud Pub/Sub | Google Cloud 托管的服务，支持异步流式传输。 | 汇集器仅限 | |
HTTPS | 每次有文档通过时，都会通过API端点检索数据的 HTTPS请求。然后， Atlas Stream Processing使用这些数据来丰富触发请求的文档。 | 不受支持 | |
AWS Lambda | Atlas Stream Processing支持在Atlas Stream Processing管道中嵌入对Amazon Web Services Lambda资源的调用。您可以同步或异步执行这些调用，并且可以将同步调用的响应传递到管道中的后续阶段。 要了解更多信息，请参阅 Atlas Stream Processing $externalFunction 文档。 |
注意
Amazon Web Services Kinesis 和 S3、Azure Blob 存储以及 Google Cloud Platform Pub/Sub 连接都需要云提供商访问配置，无论您选择何种网络访问方法：
要设置用于 Kinesis 和 S3 连接的统一的 Amazon Web Services 访问，请参阅 设置统一的 Amazon Web Services 访问。
若要为 Blob 存储连接设立 Azure 服务主体访问，请参阅设置和管理 Azure 服务主体访问。
要设置用于 Pub/Sub 连接的 GCP 服务账户访问，请参阅设置和托管 Google Cloud 服务账户访问权限。
注意
您不能使用时间序列集合作为Atlas Stream Processing的源。时间序列集合不支持变更流。
提示
有关详细信息，请参阅时间序列集合限制。
先决条件
要创建和配置连接，您必须具备以下条件：
Atlas项目
具有管理连接注册表的
Project Owner或Project Stream Processing Owner角色的 Atlas 用户注意
尽管
Project Owner和Project Stream Processing Owner角色都授予用户在连接注册表中创建、查看、编辑和删除连接的权限，Project Owner角色还允许用户执行创建数据库部署、管理项目访问等任务。如需详细了解这些角色之间的区别，请参阅项目角色。
Atlas 集群
跨项目连接
Atlas Stream Processing 支持从其他项目中的 Atlas 集群读取和写入。要启用此功能，请按照以下步骤操作：
在 Atlas 中，转到 Organization Settings（项目设置）页面。
如果尚未显示，组织从导航栏中的Organizations菜单。
在侧边栏中，单击 Organization Settings。
显示“组织设置”页面。
切换 Enable Atlas Stream Processing Across Projects 开启。
要创建跨项目连接，您必须具备以下条件之一：
Org Stream Processing Owner权限.Stream Processing Project Owner参与该连接的两个 Atlas 项目中的权限。
将连接添加到连接注册表
每种Atlas Stream Processing连接类型都有不同的配置要求和过程。要学习；了解更多信息，请参阅添加Atlas Stream Processing连接。
查看连接注册表中的连接
要查看连接到 Stream Processing 工作区：
要列出使用Atlas CLI指定的一个流处理工作区的所有连接，运行以下命令：
atlas streams connections list [options]
要使用 Atlas CLI 返回指定的一个Atlas Stream Processing连接的详细信息，请运行以下命令：
atlas streams connections describe <streamConnectionName> [options]
要进一步了解上述命令的语法和参数，请参阅 Atlas CLI 文档的 atlas streams connections list 和 atlas streams connections describe 部分。
AtlasGoStream Processing在Atlas中，Go项目的 页面。
如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。
如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。
在侧边栏中，单击 Streaming Data 标题下的 Stream Processing。
此时将显示 Stream Processing 页面。
要使用 mongosh 列出所有可用连接，请使用 sp.listConnections() 方法。该方法会返回一个文档列表，用来描述 Stream Processing 工作区中连接注册表里的每个连接。该方法采用以下语法：
sp.listConnections()
从连接注册表修改连接
要从连接注册表修改连接，请执行以下操作：
要使用Atlas CLI修改指定的流处理工作区上的一个连接的详细信息，运行以下命令：
atlas streams connections update <connectionName> [options]
To learn more about the command syntax and parameters, see the Atlas CLI documentation for atlas streams connections update.
AtlasGoStream Processing在Atlas中，Go项目的 页面。
如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。
如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。
在侧边栏中，单击 Streaming Data 标题下的 Stream Processing。
此时将显示 Stream Processing 页面。
Atlas 管理 API 提供了用于编辑 Stream Processing 工作区的端点。
删除连接注册表中的连接
要从连接注册表中删除连接，请执行以下操作：
要从使用Atlas CLI指定的流处理工作区中删除一个连接，运行以下命令：
atlas streams connections delete <connectionName> [options]
To learn more about the command syntax and parameters, see the Atlas CLI documentation for atlas streams connections delete.
AtlasGoStream Processing在Atlas中，Go项目的 页面。
如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。
如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。
在侧边栏中，单击 Streaming Data 标题下的 Stream Processing。
此时将显示 Stream Processing 页面。
Atlas 管理 API 提供了用于编辑 Stream Processing 工作区的端点。
从连接注册表测试连接
要验证来自连接注册表的连接是否在Atlas用户界面中正常工作：
AtlasGoStream Processing在Atlas中，Go项目的 页面。
如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。
如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。
在侧边栏中，单击 Streaming Data 标题下的 Stream Processing。
此时将显示 Stream Processing 页面。
列出专用链接连接
Atlas Administration API提供了一个端点，用于查看指定项目中为Atlas Stream Processing配置的所有专用链接连接。
查看一个专用链接连接
Atlas Administration API提供了一个端点，用于查看为指定项目内的Atlas Stream Processing配置的一个专用链接连接的详细信息。
删除专用链接连接
Atlas Administration API提供了一个端点，用于删除为指定项目内的Atlas Stream Processing配置的专用链接连接。