지능적이고 내구성있는 스트림을 위해 MongoDB 및 Amazon Kinesis를 통합합니다

실시간 데이터 스트리밍을위한 MongoDB 및 Amazon Kinesis 통합 이 기사는 MongoDB와 Amazon Kinesis를 통합하여 라이브 이벤트에 반응하는 강력한 실시간 데이터 스트림을 만드는 방법을 보여줍니다. 이것은 MongoDB 내에서 관련 데이터 변경이 발생할 때 AWS kinesis 조치를 시작하는 MongoDB 스티치 트리거를 사용하여 달성됩니다.

이 통합을 통해 사용자 행동의 실시간 분석, 개인화 된 제품 권장 사항 및 사기 탐지를 포함한 다양한 응용 프로그램이 가능합니다. MongoDB에 저장되고 Kinesis로 스트리밍 된 데이터는 Amazon Kinesis Data Analytics와 같은 다운 스트림 서비스에 의해 처리 될 수 있습니다. 전제 조건 :

Mongodb Atlas 인스턴스 : atlas 인스턴스 (예 : 라는 데이터베이스 사용 및 전자 상거래 애플리케이션 데이터 용 라는 컬렉션). 도움을 받으려면 Mongodb Atlas 시작 가이드를 참조하십시오 aws 계정 및 Kinesis 스트림 : 구성된 Kinesis Stream ()이있는 AWS 계정 (Kinesis Analytics와 같은 다운 스트림 애플리케이션으로 데이터를 보냅니다. Mongodb 스티치 응용 프로그램 : 스티치 응용 프로그램 (아틀라스 내에서 생성)

단계별 통합 :

컬렉션 만들기 : 스티치 응용 프로그램에서 컬렉션을 만듭니다 (데이터베이스 : , 컬렉션 : ). 사용자 별 데이터에 대한 액세스를 제한하는 템플릿을 사용하십시오 (사용자 ID 필드 지정).

AWS의 스티치 구성 :
1. AWS 서비스를 추가하여 AWS Kinesis와 통신하도록 Stitch를 구성합니다. streamdata clickdata Kinesis 스트리밍 기능을 만듭니다.
kinesis 스트림에 문서를 보내기 위해 스티치 함수 ()를 만듭니다. 다음 코드를 붙여 넣으십시오

exports = function(event){
 const awsService = context.services.get('aws');
 try{
   awsService.kinesis().PutRecord({
     Data: JSON.stringify(event.fullDocument),
     StreamName: "stitchStream",
     PartitionKey: "1"
      }).then(function(response) {
        return response;
      });
 }
 catch(error){
  console.log(JSON.parse(error));
 }
};

함수 테스트 :
4. 스티치 콘솔을 사용하여 함수를 테스트하고 샘플 객체를 제공합니다 : event

스티치 트리거 구성 :

event = {
   "operationType": "replace",
   "fullDocument": { /* ...sample document... */ },
   "ns": { "db": "streamdata", "coll": "clickdata" }
};
exports(event);

컬렉션의 삽입, 업데이트 및 교체시 함수를 자동으로 실행하기 위해 스티치 트리거를 만듭니다.

5. 트리거 테스트 : Amazon Kinesis 대시 보드를 사용하여 데이터가 Kinesis 스트림으로 스트리밍되는지 확인하십시오. putKinesisRecord clickdata 고급 기능 : 추가 처리 (이상 감지, 집계 등)를 위해 Amazon Kinesis Data Analytics와 같은 서비스를 활용합니다.

이 세부 가이드를 사용하면 MongoDB 및 Amazon Kinesis를 완벽하게 통합하여 실시간 데이터 처리 및 분석을 위해 두 플랫폼의 전력을 활용할 수 있습니다. 추가 지원 및 문제 해결을 위해 제공된 리소스를 참조하십시오.

위 내용은 지능적이고 내구성있는 스트림을 위해 MongoDB 및 Amazon Kinesis를 통합합니다의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!