연결 레지스트리 관리
이 페이지의 내용
각 스트림 처리 인스턴스는 스트리밍 데이터 소스 또는 싱크에 대해 구성된 모든 연결을 연결 레지스트리에 저장합니다. 이 페이지의 절차는 Atlas Stream Processing 연결을 만들고 구성하는 과정을 안내합니다.
전제 조건
연결을 만들고 구성하려면 다음이 필요합니다.
Atlas 프로젝트
연결 레지스트리를 관리하기 위한
Project Owner
또는Project Stream Processing Owner
역할이 있는 Atlas 사용자참고
Project Owner
역할이 있으면 데이터베이스 배포를 만들고, 프로젝트 액세스 및 프로젝트 설정을 관리하고, IP 액세스 목록 항목을 관리하는 등의 작업을 수행할 수 있습니다.Project Stream Processing Owner
역할은 스트림 처리 인스턴스 보기, 생성, 삭제 및 편집, 연결 레지스트리에 연결 보기, 추가, 수정 및 삭제와 같은 Atlas Stream Processing 작업을 활성화합니다.두 역할 간의 차이에 대한 자세한 내용은 프로젝트 역할을 참조하세요.
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 스트림 연결 목록 및 Atlas 스트림 연결 설명에 대한 Atlas CLI 문서를 참조하세요.
AtlasGo Atlas 에서 프로젝트 의 Stream Processing 페이지로 고 (Go) 합니다.
아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.
아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.
사이드바에서 Services 제목 아래의 Stream Processing를 클릭합니다.
스트림 처리 페이지가 표시됩니다.
Atlas 관리 API는 연결 레지스트리에서 하나 또는 모든 연결을 조회하기 위한 다양한 엔드포인트를 제공합니다.
mongosh
를 사용하여 사용 가능한 모든 연결을 나열하려면 sp.listConnections()
메서드를 사용하세요. 스트림 처리 인스턴스의 연결 레지스트리에 있는 각 연결을 설명하는 문서 목록을 반환합니다. 다음 구문을 포함합니다.
sp.listConnections()
연결 레지스트리에 연결 추가
Atlas Stream Processing은 다음 연결 유형을 지원합니다.
각 유형에는 고유한 구성 요구 사항이 있습니다.
Apache Kafka 연결 추가
중요
Atlas Stream Processing에 대한 VPC 피어링은 현재 비공개 미리 보기 단계에 있습니다. 자세한 내용을 알아보려면 계정 팀에 문의하세요.
스트림 처리 인스턴스에 Kafka 연결을 추가하려면 다음을 수행하세요.
Atlas CLI를 사용하여 지정한 Atlas Stream Processing 인스턴스에 대해 하나의 연결을 생성하려면 다음 명령을 실행합니다.
atlas streams connections create [connectionName] [options]
명령 구문 및 매개변수에 대해 자세히 알아보려면 Atlas 스트림 연결 생성에 대한 Atlas CLI 설명서를 참조하세요.
Atlas CLI를 사용하여 스트림 처리 인스턴스를 생성할 때, 새로운 연결의 매개변수를 정의하기 위해 .json
구성 파일을 제공해야 합니다. 이 파일의 형식은 정의하는 연결 유형에 따라 다릅니다.
Apache Kafka 연결의 경우 다음 구문을 사용하여 구성 파일을 제공하세요.
{ "name": "<name>", "type": "Kafka", "bootstrapServers": "<address:port>, ...", "security": { "protocol": "<protocol>" }, "authentication": { "mechanism": "<auth-mechanism>", "username": "<username>", "password": "<password>" } }
AtlasGo Atlas 에서 프로젝트 의 Stream Processing 페이지로 고 (Go) 합니다.
아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.
아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.
사이드바에서 Services 제목 아래의 Stream Processing를 클릭합니다.
스트림 처리 페이지가 표시됩니다.
새 연결을 추가합니다.
Kafka 연결을 선택합니다.
Connection Name을 제공하세요. 각 연결 이름은 스트림 처리 인스턴스 내에서 고유해야 합니다. 이는 Atlas Stream Processing 집계에서 연결을 참조하는 데 사용되는 이름입니다.
Network Access 유형을 선택합니다. Atlas Stream Processing은 Public IP 또는 VPC Peering 연결을 지원합니다.
Public IP 버튼을 클릭합니다. 이 네트워크 액세스 유형에는 추가 구성이 필요하지 않습니다.
VPC Peering 버튼을 클릭합니다.
Enable VPC Peering을 토글합니다. Atlas Stream Processing이 구성된 연결에서 적절한 VPC 피어링 연결을 자동으로 선택합니다.
VPC 피어링 연결이 없는 경우 Atlas 네트워크 피어링 연결을 구성합니다.
하나 이상의 부트스트랩 서버와 Apache Kafka 시스템에 대한 IP 주소를 지정합니다.
드롭다운 메뉴에서 Security Protocol Method를 선택합니다.
Atlas Stream Processing은
SASL_PLAINTEXT
또는SASL_SSL
을 지원합니다.SASL_PLAINTEXT
VPC 피어링과 호환되지 않습니다. VPC 피어링을 사용하려면SASL_SSL
메서드를 선택해야 합니다.드롭다운 메뉴에서 SASL Mechanism를 선택합니다.
Atlas Stream Processing은 다음을 지원합니다.
PLAIN
SCRAM-SHA-256
SCRAM-SHA-512
인증을 위한 Username을 제공하세요.
인증을 위한 비밀번호를 입력합니다.
Add connection를 클릭합니다.
드롭다운 메뉴에서 SASL Mechanism를 선택합니다.
Atlas Stream Processing은 다음을 지원합니다.
PLAIN
SCRAM-SHA-256
SCRAM-SHA-512
Upload를 클릭하여 Certificate Authority PEM file을 업로드합니다.
인증을 위한 Username을 제공하세요.
인증을 위한 비밀번호를 입력합니다.
Add connection를 클릭합니다.
Atlas 관리 API는 연결 레지스트리에 연결을 추가하기 위한 엔드포인트를 제공합니다.
중요
연결 레지스트리에 Apache Kafka 클러스터와 같은 외부 연결을 추가한 후 해당 외부 연결에 대한 액세스 목록에 Atlas IP 주소를 추가해야 합니다. 자세한 내용은 Atlas Control Plane에 대한 액세스 허용을 참조하세요.
Atlas 연결 추가
중요
Atlas Stream Processing에 대한 VPC 피어링은 현재 비공개 미리 보기 단계에 있습니다. 자세한 내용을 알아보려면 계정 팀에 문의하세요.
스트림 처리 인스턴스에 Atlas 데이터베이스 연결을 추가하려면 다음을 수행하세요.
Atlas CLI를 사용하여 지정한 Atlas Stream Processing 인스턴스에 대해 하나의 연결을 생성하려면 다음 명령을 실행합니다.
atlas streams connections create [connectionName] [options]
명령 구문 및 매개변수에 대해 자세히 알아보려면 Atlas 스트림 연결 생성에 대한 Atlas CLI 설명서를 참조하세요.
Atlas CLI를 사용하여 스트림 처리 인스턴스를 생성할 때, 새로운 연결의 매개변수를 정의하기 위해 .json
구성 파일을 제공해야 합니다. 이 파일의 형식은 정의하는 연결 유형에 따라 다릅니다.
Atlas 데이터베이스 연결의 경우 다음 구문을 가진 구성 파일을 제공합니다.
{ "name": "<name>", "type": "Cluster", "clusterName": "<clusterName>" }
AtlasGo Atlas 에서 프로젝트 의 Stream Processing 페이지로 고 (Go) 합니다.
아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.
아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.
사이드바에서 Services 제목 아래의 Stream Processing를 클릭합니다.
스트림 처리 페이지가 표시됩니다.
Atlas 관리 API는 연결 레지스트리에 연결을 추가하기 위한 엔드포인트를 제공합니다.
연결 레지스트리에서 연결 수정
연결 레지스트리에서 연결을 수정하려면 다음과 같이 하세요:
Atlas CLI를 사용하여 지정한 스트림 처리 인스턴스에서 한 연결의 세부 정보를 수정하려면 다음 명령을 실행합니다.
atlas streams connections update <connectionName> [options]
명령 구문 및 매개변수에 대한 자세한 내용은 Atlas CLI 문서에서 Atlas 스트림 연결 업데이트를 참조하세요.
AtlasGo Atlas 에서 프로젝트 의 Stream Processing 페이지로 고 (Go) 합니다.
아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.
아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.
사이드바에서 Services 제목 아래의 Stream Processing를 클릭합니다.
스트림 처리 페이지가 표시됩니다.
Atlas Administration API는 스트림 처리 인스턴스를 편집하기 위한 엔드포인트를 제공합니다.
연결 레지스트리에서 연결 삭제
연결 레지스트리에서 연결을 삭제하려면 다음과 같이 하세요:
Atlas CLI를 사용하여 지정한 Atlas Stream Processing 인스턴스에서 연결 한 개를 제거하려면 다음 명령을 실행합니다.
atlas streams connections delete <connectionName> [options]
명령 구문 및 매개변수에 대해 자세히 알아보려면 Atlas 스트림 연결 삭제에 대한 Atlas CLI 설명서를 참조하세요.
AtlasGo Atlas 에서 프로젝트 의 Stream Processing 페이지로 고 (Go) 합니다.
아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.
아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.
사이드바에서 Services 제목 아래의 Stream Processing를 클릭합니다.
스트림 처리 페이지가 표시됩니다.
Atlas Administration API는 스트림 처리 인스턴스를 편집하기 위한 엔드포인트를 제공합니다.
비공개 링크 연결 나열
Atlas Administration API 는 지정된 프로젝트 내에서 Atlas Stream Processing 을 위해 구성된 모든 Private Link 연결을 볼 수 있는 엔드포인트를 제공합니다.
1개의 비공개 링크 연결 보기
Atlas 관리 API 는 지정된 프로젝트 내에서 Atlas Stream Processing 를 위해 구성된 하나의 Private Link 연결의 세부 정보를 볼 수 있는 엔드포인트를 제공합니다.
비공개 링크 연결 만들기
Atlas Stream Processing 은 현재 Azure 및 AWS에서 호스팅되는 Confluent 클러스터에 대한 Private Link 연결 생성을 지원합니다.
Atlas Stream Processing 프로젝트 에서 사용할 Private Link 연결을 생성하려면 다음 단계를 따르세요.
중요
Atlas 프로젝트 당 특정 Confluent 클러스터 에 대해 둘 이상의 Private Link 연결을 가질 수 없습니다. 이 절차를 시작하기 전에 Return All Private Link Connections(모든 비공개 링크 연결 반환) 엔드포인트를 호출합니다. Atlas 내에서는 Confluent 클러스터 에 대한 기존 Private Link 연결이 있지만 Confluent 계정 내에는 연결되어 있지 않은 경우, Confluent 사이드 네트워킹을 구성하는 단계만 수행하세요.
Confluent 클러스터 를 구성합니다.
Atlas 프로젝트 에서 들어오는 연결을 허용하도록 Confluent 클러스터 를 구성해야 합니다.
중요
Confluent는 AWS에서 들어오는 연결만 허용합니다. Confluent Private Link 연결을 사용하려면 AWS에서 스트림 처리 인스턴스를 호스팅하다 해야 합니다.
그룹 및 리전 Atlas 관리 API 엔드포인트에 대한 계정 ID 및 VPC ID 반환을 호출합니다. 의 값을 기록해 둡니다.
awsAccountId
이후 단계에서 이 값이 필요합니다.Confluent 계정에서 연결하려는 클러스터 로 이동합니다. 클러스터 네트워킹 인터페이스에서 클러스터 네트워킹 세부 정보로 이동합니다.
Confluent 전용 클러스터 의 경우 원하는 이름을 입력합니다.AWS 계정 번호에 앞서 기록해 둔 필드 의 값을
awsAccountId
입력합니다.참고
Confluent 서버리스 클러스터에는 이 단계가 필요하지 않습니다.
cloud 제공자 에게 연결을 요청합니다.
Atlas 관리 API 는 Atlas Stream Processing 을 위해 구성된 Private Link 연결을 요청하기 위한 엔드포인트를 제공합니다.
AWS Private Link 연결의 경우 다음 키-값 쌍을 설정하다 해야 합니다.
키 | 값 |
---|---|
| Confluent 클러스터의 VPC Endpoint service name. |
| Confluent 클러스터 에 있는 부트스트랩 서버 의 정규화된 도메인 이름입니다. |
| 클러스터 에서 하위 도메인을 사용하지 않는 경우 이를 빈 배열 |
이러한 값은 Confluent 클러스터의 네트워킹 세부 정보에서 찾을 수 있습니다.
다음 예시 명령은 Confluent 클러스터 에 대한 연결을 요청하고 일반적인 응답을 보여줍니다.
curl --location 'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/privateLinkConnections' \ --digest \ --user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \ --header 'Content-Type: application/json' \ --header 'Accept: application/vnd.atlas.2023-02-01+json' \ --data '{ "vendor": "Confluent", "provider": "AWS", "region": "us_east_1", "serviceEndpointId": "com.amazonaws.vpce.us-east-1.vpce-svc-93da685022ee702a9", "dnsDomain": "sample.us-east-1.aws.confluent.cloud", "dnsSubDomain: [ "use1-az1.sample.us-east-1.aws.confluent.cloud", "use1-az2.sample.us-east-1.aws.confluent.cloud", "use1-az4.sample.us-east-1.aws.confluent.cloud" ] }'
{"_id":"6aa12e7ccd660d4b2380b1c1","dnsDomain":"sample.us-east-1.aws.confluent.cloud.","vendor":"Confluent","provider":"AWS","region":"us_east_1","serviceEndpointId":"com.amazonaws.vpce.us-east-1.vpce-svc-93da685022ee702a9"}
요청 을 보낸 후 응답 본문의 _id
필드 값을 확인합니다. 이후 단계에서 이 정보가 필요합니다.
인터페이스 엔드포인트 ID 를 Confluent에 제공합니다.
참고
이 단계는 Confluent 서버리스 클러스터에만 적용됩니다.
모든 비공개 링크 연결 반환 엔드포인트를 호출합니다. 값을 interfaceEndpointId
확인합니다.
Confluent 계정에서 연결하려는 클러스터 로 이동합니다. 클러스터 네트워킹 인터페이스에서 클러스터 네트워킹 세부 정보로 이동합니다. 액세스 포인트 인터페이스로 이동하여 새 액세스 점 를 추가합니다. Confluent가 인터페이스 엔드포인트 를 입력하라는 메시지를 표시하면 이전에 기록해 둔 interfaceEndpointId
값을 입력합니다.
Atlas 측 연결을 생성합니다.
다음 키-값 쌍이 있는연결을 추가합니다.
키 | 값 |
---|---|
| cloud 제공업체의 Kafka 부트스트랩 서버 의 IP 주소 입니다. |
|
|
|
|
| Confluent API 키와연결된 비밀번호 |
| Confluent API 키와 연결된 사용자 이름 |
|
|
|
|
|
|
필요에 따라 다른 모든 값을 설정합니다.
다음 예시 명령은 Atlas 에서 Apache Kafka 연결을 생성합니다.
curl --location 'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/spinstance/connections' \ --digest \ --user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \ --header 'Content-Type: application/json' \ --header 'Accept: application/vnd.atlas.2023-02-01+json' \ --data '{ "name": "confluent_demo", "bootstrapServers": "slr-ntgrbn.sample.us-east-1.aws.confluent.cloud:9092", "security": { "protocol": "SASL_SSL" }, "authentication": { "mechanism": "PLAIN", "password": "apiSecretDemo", "username": "apiUserDemo" }, "type": "Kafka", "networking": { "access": { "type": "PRIVATE_LINK", "connectionId": "38972b0cbe9c2aa40a30a246" } } }'
cloud 제공자 에게 연결을 요청합니다.
Atlas 관리 API 는 Atlas Stream Processing 을 위해 구성된 Private Link 연결을 요청하기 위한 엔드포인트를 제공합니다.
Azure Private Link 연결의 경우 다음 키-값 쌍을 설정하다 해야 합니다.
키 | 값 |
---|---|
| EventHub 네임스페이스 엔드포인트 |
|
curl --location 'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/privateLinkConnections' \ --digest \ --user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \ --header 'Content-Type: application/json' \ --header 'Accept: application/vnd.atlas.2023-02-01+json' \ --data '{ "provider": "AZURE", "region": "US_EAST_2", "serviceEndpointId": "/subscriptions/b82d6aa0-0b0a-ffa3-7c22-e167dc44f5b0/resourceGroups/asp/providers/Microsoft.EventHub/namespaces/sample", "dnsDomain": "sample.servicebus.windows.net" }'
{"_id":"6aa12e7ccd660d4b2380b1c1","dnsDomain":"sample.servicebus.windows.net","provider":"AZURE","region":"US_EAST_2","serviceEndpointId":"/subscriptions/b82d6aa0-0b0a-ffa3-7c22-e167dc44f5b0/resourceGroups/asp/providers/Microsoft.EventHub/namespaces/sample"}
요청 을 보낸 후 응답 본문의 _id
필드 값을 확인합니다. 이후 단계에서 이 정보가 필요합니다.
cloud 제공자 계정 내에서 요청된 연결을 수락합니다.
Azure 에 대한 Private Link 연결의 경우 Event Hub 네트워킹 페이지로 이동하여 Private endpoint connections 탭 을 선택합니다. 연결 테이블에서 새로 요청된 연결을 식별하고 승인합니다.
Atlas 측 연결을 생성합니다.
다음 키-값 쌍이 있는연결을 추가합니다.
키 | 값 |
---|---|
| cloud 제공업체의 Kafka 부트스트랩 서버 의 IP 주소 입니다. |
|
|
|
|
| Event Hub 연결 문자열 |
|
|
|
|
|
|
|
|
필요에 따라 다른 모든 값을 설정합니다.
다음 예시 명령은 Atlas 에서 Apache Kafka 연결을 생성합니다.
curl --location 'https://cloud.mongodb.com/api/atlas/v2/groups/8358217d3abb5c76c3434648/streams/spinstance/connections' \ --digest \ --user "slrntglrbn:933fb118-ac62-4991-db05-ee67a3481fde" \ --header 'Content-Type: application/json' \ --header 'Accept: application/vnd.atlas.2023-02-01+json' \ --data '{ "name": "eventhubpl33333", "bootstrapServers": "sample.servicebus.windows.net:9093", "security": { "protocol": "SASL_SSL" }, "authentication": { "mechanism": "PLAIN", "password": "Endpoint=sb://sample.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=Irlo3OoRkc27T3ZoGOlbhEOqXQRXzb12+Q2hNXm0lc=", "username": "$ConnectionString" }, "type": "Kafka", "networking": { "access": { "type": "PRIVATE_LINK", "connectionId": "38972b0cbe9c2aa40a30a246" } } }'
비공개 링크 연결 삭제
Atlas 관리 API 는 지정된 프로젝트 내에서 Atlas Stream Processing 을 위해 구성된 Private Link 연결을 삭제하기 위한 엔드포인트를 제공합니다.