Docs 菜单
Docs 主页
/
Atlas
/
Atlas Stream Processing

管理连接

每个流处理实例都会在其连接注册表中存储与流数据源或接收器的每个配置连接。此页面上的程序将引导您创建和配置 Atlas Stream Processing 连接。

先决条件

要创建和配置连接，您必须具备以下条件：

  • 一个 Atlas 项目

  • 具有管理连接注册表的 Project Owner 或 Project Stream Processing Owner 角色的 Atlas 用户

    注意

    尽管 Project Owner 和 Project Stream Processing Owner 角色赋予用户在连接注册表中创建、查看、编辑和删除连接的权限，Project Owner 角色还允许用户执行创建数据库部署、管理项目访问等任务。

    如需详细了解这些角色之间的区别，请参阅项目角色。

  • Atlas 集群

Considerations

配置Atlas Stream Processing连接时，请确保选择适合您使用案例的连接类型。Atlas Stream Processing支持以下提供者：

提供商
说明
连接类型

Kafka Broker

可配置的服务器，用于接收和存储事件流，并将其组织为分区主题。

Sink 和 Source

Atlas 集群

云托管的MongoDB服务器提供永久存储和事件驱动的 变更流。

Sink 和 Source

AWS S3

托管在Amazon Web Services上的对象存储容器。

仅接收器

HTTPS

每次有文档通过时，都会通过API端点检索数据的 HTTPS请求。然后， Atlas Stream Processing使用这些数据来丰富触发请求的文档。

补充来源；必须跟在 $source 阶段之后。

外部函数连接

Atlas Stream Processing支持在Atlas Stream Processing管道中嵌入对Amazon Web Services Lambda资源的调用。您可以同步或异步执行这些调用，并且可以将同步调用的响应传递到管道中的后续阶段。

要学习；了解更多信息，请参阅Atlas Stream Processing外部函数文档。

触发器

将连接添加到连接注册表

每种Atlas Stream Processing连接类型都有不同的配置要求和过程。要学习；了解更多信息，请参阅添加Atlas Stream Processing连接。

查看连接注册表中的连接

要查看与Atlas Stream Processing实例的连接，请执行以下操作：

要列出使用 Atlas CLI 指定的一个Atlas Stream Processing实例的所有连接，请运行以下命令：

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 部分。

提示

请参阅：相关链接

1

AtlasGoStream Processing在Atlas中，Go项目的 页面。

  1. 如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。

  2. 如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。

  3. 在侧边栏中，单击 Streaming Data 标题下的 Stream Processing。

此时将显示 Stream Processing 页面。

2

转到 Connection Registry（快速入门）页面。

  1. 找到包含要查看的连接注册表的流处理实例的概览面板。

  2. 单击 Configure（连接）。

  3. 选择 Connection Registry 标签页。

Atlas Stream Processing 显示您实例连接注册表中可用的所有连接。

Atlas 管理 API 提供不同的端点来检索连接注册表中的一个或所有连接。

查看连接注册表中的一个连接

列出连接注册表中的所有连接

要使用 mongosh 列出所有可用连接，请使用 sp.listConnections() 方法。该方法会返回一个文档列表，用来描述流处理实例中连接注册表里的每个连接。该方法采用以下语法：

sp.listConnections()

从连接注册表修改连接

要从连接注册表修改连接，请执行以下操作：

要使用 Atlas CLI 修改指定的 Atlas Stream Processing 实例上的一个连接的详细信息，请运行以下命令：

atlas streams connections update <connectionName> [options]

要了解有关命令语法和参数的更多信息，请参阅 atlas 流连接更新的 Atlas CLI 文档。

1

AtlasGoStream Processing在Atlas中，Go项目的 页面。

  1. 如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。

  2. 如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。

  3. 在侧边栏中，单击 Streaming Data 标题下的 Stream Processing。

此时将显示 Stream Processing 页面。

2

转到 Connection Registry（搜索测试器）。

找到包含要修改的连接注册表的流处理实例的概览面板，然后单击右上角的 Configure。

3

选择 Connection Registry（连接注册表）标签页。

4

修改连接。

  1. 对于您要在表中修改的连接，请单击 Actions 列中的铅笔图标。

    仅当流处理器当前未使用连接时，才能编辑连接。如果要编辑正在使用的连接，请先停止使用该连接的所有流处理器。

  2. 修改您想要修改的字段。

  3. 单击 Save changes（连接）。

Atlas Administration API 提供用于编辑流处理实例的端点。

更新一个流实例

删除连接注册表中的连接

要从连接注册表中删除连接，请执行以下操作：

要从使用 Atlas CLI 指定的 Atlas Stream Processing 实例中删除一个连接，请运行以下命令：

atlas streams connections delete <connectionName> [options]

要了解有关命令语法和参数的更多信息，请参阅 Atlas Streams 连接删除的 Atlas CLI 文档。

1

AtlasGoStream Processing在Atlas中，Go项目的 页面。

  1. 如果尚未显示，请从导航栏上的 Organizations 菜单中选择包含项目的组织。

  2. 如果尚未显示，请从导航栏的 Projects 菜单中选择您的项目。

  3. 在侧边栏中，单击 Streaming Data 标题下的 Stream Processing。

此时将显示 Stream Processing 页面。

2

转到 Connection Registry（搜索测试器）。

  1. 找到包含要修改的连接注册表的流处理实例的概述面板

  2. 单击右上角的 Configure。

  3. 选择 Connection Registry 标签页。

3

删除该连接。

  1. 对于要在表中修改的连接，请单击该条目的 Actions 列中的垃圾桶图标。

  2. 出现提示时，单击 Delete。

Atlas Administration API 提供用于编辑流处理实例的端点。

删除一个流实例

列出专用链接连接

Atlas Administration API提供了一个端点，用于查看指定项目中为Atlas Stream Processing配置的所有专用链接连接。

返回所有私有链接

查看一个专用链接连接

Atlas Administration API提供了一个端点，用于查看为指定项目内的Atlas Stream Processing配置的一个专用链接连接的详细信息。

返回一个私有链接

删除专用链接连接

Atlas Administration API提供了一个端点，用于删除为指定项目内的Atlas Stream Processing配置的专用链接连接。

删除一个私有链接

后退

管理 Stream Processing 实例

来年

添加公共连接

在此页面上