管理连接
每个流处理实例都会在其连接注册表中存储与流数据源或接收器的每个配置连接。此页面上的程序将引导您创建和配置 Atlas Stream Processing 连接。
先决条件
要创建和配置连接,您必须具备以下条件:
一个 Atlas 项目
具有管理连接注册表的
Project Owner
或Project Stream Processing Owner
角色的 Atlas 用户注意
虽然
Project Owner
和Project Stream Processing Owner
角色都授予在连接注册表中创建、查看、编辑和删除连接的特权,但Project Owner
角色还允许用户执行创建数据库部署、管理项目访问权限和更多。请参阅项目角色,详细学习;了解这些角色之间的区别。
Atlas 集群
将连接添加到连接注册表
有关创建每种类型连接的信息,请参阅以下页面:
每种类型都有独特的配置要求。
查看连接注册表中的连接
要查看与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 文档 atlasstreams connections list和atlas streams connections describe。
AtlasGoStream Processing在Atlas中,Go项目的 页面。
如果尚未显示,请从导航栏上的 Organizations 菜单中选择包含项目的组织。
如果尚未显示,请从导航栏的 Projects 菜单中选择您的项目。
在侧边栏中,单击 Services 标题下的 Stream Processing。
此时将显示 Stream Processing 页面。
要使用 mongosh
列出所有可用连接,请使用 sp.listConnections()
方法。该方法会返回一个文档列表,用来描述流处理实例中连接注册表里的每个连接。该方法采用以下语法:
sp.listConnections()
从连接注册表修改连接
要从连接注册表修改连接,请执行以下操作:
要使用 Atlas CLI 修改指定的 Atlas Stream Processing 实例上的一个连接的详细信息,请运行以下命令:
atlas streams connections update <connectionName> [options]
要了解有关命令语法和参数的更多信息,请参阅 atlas 流连接更新的 Atlas CLI 文档。
AtlasGoStream Processing在Atlas中,Go项目的 页面。
如果尚未显示,请从导航栏上的 Organizations 菜单中选择包含项目的组织。
如果尚未显示,请从导航栏的 Projects 菜单中选择您的项目。
在侧边栏中,单击 Services 标题下的 Stream Processing。
此时将显示 Stream Processing 页面。
Atlas Administration API 提供用于编辑流处理实例的端点。
删除连接注册表中的连接
要从连接注册表中删除连接,请执行以下操作:
要从使用 Atlas CLI 指定的 Atlas Stream Processing 实例中删除一个连接,请运行以下命令:
atlas streams connections delete <connectionName> [options]
要了解有关命令语法和参数的更多信息,请参阅 Atlas Streams 连接删除的 Atlas CLI 文档。
AtlasGoStream Processing在Atlas中,Go项目的 页面。
如果尚未显示,请从导航栏上的 Organizations 菜单中选择包含项目的组织。
如果尚未显示,请从导航栏的 Projects 菜单中选择您的项目。
在侧边栏中,单击 Services 标题下的 Stream Processing。
此时将显示 Stream Processing 页面。
Atlas Administration API 提供用于编辑流处理实例的端点。
列出专用链接连接
Atlas Administration API提供了一个端点,用于查看指定项目中为Atlas Stream Processing配置的所有专用链接连接。
查看一个专用链接连接
Atlas Administration API提供了一个端点,用于查看为指定项目内的Atlas Stream Processing配置的一个专用链接连接的详细信息。
删除专用链接连接
Atlas Administration API提供了一个端点,用于删除为指定项目内的Atlas Stream Processing配置的专用链接连接。