각 스트림 처리 인스턴스는 스트리밍 데이터 소스 또는 싱크에 대해 구성된 모든 연결을 연결 레지스트리에 저장합니다. 이 페이지의 절차는 Atlas Stream Processing 연결을 만들고 구성하는 과정을 안내합니다.
전제 조건
연결을 만들고 구성하려면 다음이 필요합니다.
Atlas 프로젝트
연결 레지스트리를 관리하기 위한
Project Owner또는Project Stream Processing Owner역할이 있는 Atlas 사용자참고
Project Owner및Project Stream Processing Owner역할은 모두 연결 레지스트리에서 연결을 생성, 조회, 편집 및 삭제할 수 있는 권한을 부여합니다. 반면,Project Owner역할은 사용자가 데이터베이스 배포 생성, 프로젝트 액세스 관리 등의 작업을 수행할 수 있도록 추가 권한을 부여합니다.이 역할들 간의 차이에 대해 더 알고 싶다면 프로젝트 역할을 참조하세요.
Atlas 클러스터
고려 사항
Atlas Stream Processing 연결을 구성할 때는 사용 사례 에 적합한 연결 유형을 선택해야 합니다. Atlas Stream Processing 다음과 같은 제공자를 지원합니다.
제공자 | 설명 | 연결 유형 |
|---|---|---|
Kafka 브로커 | 이벤트 스트림을 수신하고 저장하여 이를 분할된 주제로 구성하는 구성 가능한 서버 . | 싱크 및 소스 |
Atlas cluster | 영구 저장 와 이벤트 중심의 Change Streams를 모두 제공하는 클라우드 호스팅 MongoDB 서버 . | 싱크 및 소스 |
AWS S3 | Amazon Web Services 에서 호스팅되는 객체 저장 컨테이너 . | 싱크 전용 |
HTTPS | 문서 통과할 때마다 API 엔드포인트를 통해 데이터를 조회 위한 HTTPS 요청 . 그런 다음 Atlas Stream Processing 이 데이터를 사용하여 요청 트리거한 문서 보강합니다. | 보충 소스; |
외부 함수 연결 | Atlas Stream Processing은 Atlas Stream Processing 파이프라인 내에 Amazon Web Services Lambda 리소스에 대한 호출을 임베딩할 수 있도록 지원합니다. 이러한 호출을 동기 또는 비동기적으로 실행할 수 있으며, 동기 호출의 응답을 파이프라인 의 후속 단계로 전달할 수 있습니다. 자세한 학습 은 Atlas Stream Processing External Functions(외부 함수 처리) 문서를 참조하세요. | 트리거 |
연결 레지스트리에 연결 추가
각 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 스트림 연결 목록 및 Atlas 스트림 연결 설명에 대한 Atlas CLI 설명서를 참조하세요.
AtlasGo Atlas 에서 프로젝트 의 Stream Processing 페이지로 고 (Go) 합니다.
아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.
아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.
사이드바에서 Streaming Data 제목 아래의 Stream Processing를 클릭합니다.
스트림 처리 페이지가 표시됩니다.
Atlas 관리 API는 연결 레지스트리에서 하나 또는 모든 연결을 조회하기 위한 다양한 엔드포인트를 제공합니다.
mongosh를 사용하여 사용 가능한 모든 연결을 나열하려면 sp.listConnections() 메서드를 사용하세요. 스트림 처리 인스턴스의 연결 레지스트리에 있는 각 연결을 설명하는 문서 목록을 반환합니다. 다음 구문을 포함합니다.
sp.listConnections()
연결 레지스트리에서 연결 수정
연결 레지스트리에서 연결을 수정하려면 다음과 같이 하세요:
Atlas CLI를 사용하여 지정한 스트림 처리 인스턴스에서 한 연결의 세부 정보를 수정하려면 다음 명령을 실행합니다.
atlas streams connections update <connectionName> [options]
명령 구문 및 매개변수에 대한 자세한 내용은 Atlas CLI 문서에서 Atlas 스트림 연결 업데이트를 참조하세요.
AtlasGo Atlas 에서 프로젝트 의 Stream Processing 페이지로 고 (Go) 합니다.
아직 표시되지 않은 경우 탐색 표시줄의 Organizations 메뉴에서 프로젝트가 포함된 조직을 선택합니다.
아직 표시되지 않은 경우 내비게이션 바의 Projects 메뉴에서 프로젝트를 선택합니다.
사이드바에서 Streaming Data 제목 아래의 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 메뉴에서 프로젝트를 선택합니다.
사이드바에서 Streaming Data 제목 아래의 Stream Processing를 클릭합니다.
스트림 처리 페이지가 표시됩니다.
Atlas Administration API는 스트림 처리 인스턴스를 편집하기 위한 엔드포인트를 제공합니다.
비공개 링크 연결 나열
Atlas 관리 API 지정된 프로젝트 내에서 Atlas Stream Processing 위해 구성된 모든 Private Link 연결을 볼 수 있는 엔드포인트를 제공합니다.
1개의 비공개 링크 연결 보기
Atlas 관리 API 지정된 프로젝트 내에서 Atlas Stream Processing 위해 구성된 하나의 Private Link 연결의 세부 정보를 볼 수 있는 엔드포인트를 제공합니다.
비공개 링크 연결 삭제
Atlas 관리 API 지정된 프로젝트 내에서 Atlas Stream Processing 위해 구성된 Private Link 연결을 삭제하기 위한 엔드포인트를 제공합니다.